Function TestRetryOnFailedConnectWithAuthError

test/conn_test.go:3081–3123

(t *testing.T)

}

func TestRetryOnFailedConnectWithAuthError(t *testing.T) {
	o := test.DefaultTestOptions
	o.Username = "user"
	o.Password = "password"
	s := RunServerWithOptions(&o)
	defer s.Shutdown()

	errChan := make(chan error, 10)
	closedCh := make(chan bool, 1)

	// Try to connect without credentials
	nc, err := nats.Connect(nats.DefaultURL,
		nats.RetryOnFailedConnect(true),
		nats.MaxReconnects(2),
		nats.ReconnectWait(10*time.Millisecond),
		nats.ReconnectErrHandler(func(_ *nats.Conn, err error) {
			errChan <- err
		}),
		nats.ClosedHandler(func(_ *nats.Conn) {
			closedCh <- true
		}),
	)
	if err != nil {
		t.Fatalf("Unexpected error: %v", err)
	}
	defer nc.Close()

	// Wait for closed due to auth failure
	select {
	case <-closedCh:
	case <-time.After(500 * time.Millisecond):
		t.Fatal("Connection should have closed due to auth failure")
	}

	select {
	case err := <-errChan:
		if !errors.Is(err, nats.ErrAuthorization) {
			t.Fatalf("Expected ErrAuthorization for auth failure, got: %v", err)
		}
	case <-time.After(500 * time.Millisecond):
		t.Fatal("Should have received authorization error in ReconnectErrCB")
	}
}

func TestRetryOnFailedConnectWithTLSError(t *testing.T) {
	opts := test.DefaultTestOptions