709385cbaa
Some checks failed
NATS Server Tests / Lint (push) Failing after 3s
NATS Server Tests / Build (Latest Go) (push) Has been skipped
NATS Server Tests / Build (Minimum Go) (push) Has been skipped
NATS Server Tests / Build (Minimum Go, windows-2022) (push) Has been skipped
NATS Server Tests / Build (Minimum Go, windows-2025) (push) Has been skipped
NATS Server Tests / Test Stores (push) Has been skipped
NATS Server Tests / Test JetStream (push) Has been skipped
NATS Server Tests / Test Raft (push) Has been skipped
NATS Server Tests / Test JetStream Consumers (push) Has been skipped
NATS Server Tests / Test JetStream Cluster 1 (push) Has been skipped
NATS Server Tests / Test JetStream Cluster 2 (push) Has been skipped
NATS Server Tests / Test JetStream Cluster 3 (push) Has been skipped
NATS Server Tests / Test JetStream Cluster 4 (push) Has been skipped
NATS Server Tests / Test JetStream Supercluster (push) Has been skipped
NATS Server Tests / Test No-Race 1 (push) Has been skipped
NATS Server Tests / Test No-Race 2 (push) Has been skipped
NATS Server Tests / Test MQTT (push) Has been skipped
NATS Server Tests / Test Message Tracing (push) Has been skipped
NATS Server Tests / Test JWT (push) Has been skipped
NATS Server Tests / Test Remaining Server Tests (push) Has been skipped
NATS Server Tests / Test Other Packages (push) Has been skipped
Vulnerability Scan / govulncheck (push) Failing after 12m2s
84 lines
2.7 KiB
Go
84 lines
2.7 KiB
Go
package server
|
|
|
|
import (
|
|
"errors"
|
|
"testing"
|
|
)
|
|
|
|
func TestIsNatsErr(t *testing.T) {
|
|
if !IsNatsErr(ApiErrors[JSNotEnabledForAccountErr], JSNotEnabledForAccountErr) {
|
|
t.Fatalf("Expected error match")
|
|
}
|
|
|
|
if IsNatsErr(ApiErrors[JSNotEnabledForAccountErr], JSClusterNotActiveErr) {
|
|
t.Fatalf("Expected error mismatch")
|
|
}
|
|
|
|
if IsNatsErr(ApiErrors[JSNotEnabledForAccountErr], JSClusterNotActiveErr, JSClusterNotAvailErr) {
|
|
t.Fatalf("Expected error mismatch")
|
|
}
|
|
|
|
if !IsNatsErr(ApiErrors[JSNotEnabledForAccountErr], JSClusterNotActiveErr, JSNotEnabledForAccountErr) {
|
|
t.Fatalf("Expected error match")
|
|
}
|
|
|
|
if !IsNatsErr(&ApiError{ErrCode: 10039}, 1, JSClusterNotActiveErr, JSNotEnabledForAccountErr) {
|
|
t.Fatalf("Expected error match")
|
|
}
|
|
|
|
if IsNatsErr(&ApiError{ErrCode: 10039}, 1, 2, JSClusterNotActiveErr) {
|
|
t.Fatalf("Expected error mismatch")
|
|
}
|
|
|
|
if IsNatsErr(nil, JSClusterNotActiveErr) {
|
|
t.Fatalf("Expected error mismatch")
|
|
}
|
|
|
|
if IsNatsErr(errors.New("x"), JSClusterNotActiveErr) {
|
|
t.Fatalf("Expected error mismatch")
|
|
}
|
|
}
|
|
|
|
func TestApiError_Error(t *testing.T) {
|
|
if es := ApiErrors[JSClusterNotActiveErr].Error(); es != "JetStream not in clustered mode (10006)" {
|
|
t.Fatalf("Expected 'JetStream not in clustered mode (10006)', got %q", es)
|
|
}
|
|
}
|
|
|
|
func TestApiError_NewWithTags(t *testing.T) {
|
|
ne := NewJSRestoreSubscribeFailedError(errors.New("failed error"), "the.subject")
|
|
if ne.Description != "JetStream unable to subscribe to restore snapshot the.subject: failed error" {
|
|
t.Fatalf("Expected 'JetStream unable to subscribe to restore snapshot the.subject: failed error' got %q", ne.Description)
|
|
}
|
|
|
|
if ne == ApiErrors[JSRestoreSubscribeFailedErrF] {
|
|
t.Fatalf("Expected a new instance")
|
|
}
|
|
}
|
|
|
|
func TestApiError_NewWithUnless(t *testing.T) {
|
|
if ne := NewJSStreamRestoreError(errors.New("failed error"), Unless(ApiErrors[JSNotEnabledForAccountErr])); !IsNatsErr(ne, JSNotEnabledForAccountErr) {
|
|
t.Fatalf("Expected JSNotEnabledForAccountErr got %s", ne)
|
|
}
|
|
|
|
if ne := NewJSStreamRestoreError(errors.New("failed error")); !IsNatsErr(ne, JSStreamRestoreErrF) {
|
|
t.Fatalf("Expected JSStreamRestoreErrF got %s", ne)
|
|
}
|
|
|
|
if ne := NewJSStreamRestoreError(errors.New("failed error"), Unless(errors.New("other error"))); !IsNatsErr(ne, JSStreamRestoreErrF) {
|
|
t.Fatalf("Expected JSStreamRestoreErrF got %s", ne)
|
|
}
|
|
|
|
if ne := NewJSPeerRemapError(Unless(ApiErrors[JSNotEnabledForAccountErr])); !IsNatsErr(ne, JSNotEnabledForAccountErr) {
|
|
t.Fatalf("Expected JSNotEnabledForAccountErr got %s", ne)
|
|
}
|
|
|
|
if ne := NewJSPeerRemapError(Unless(nil)); !IsNatsErr(ne, JSPeerRemapErr) {
|
|
t.Fatalf("Expected JSPeerRemapErr got %s", ne)
|
|
}
|
|
|
|
if ne := NewJSPeerRemapError(Unless(errors.New("other error"))); !IsNatsErr(ne, JSPeerRemapErr) {
|
|
t.Fatalf("Expected JSPeerRemapErr got %s", ne)
|
|
}
|
|
}
|