wrap no responder errors so there is a universal error for all provid…

…ers to check

Signed-off-by: Mike Mason <mimason@equinix.com>

events/errors.go

@@ -26,4 +26,7 @@ var (
 	ErrMissingAuthRelationshipRequestRelationRelation = errors.New("auth relationship request message Relations Relation field required")
 	// ErrMissingAuthRelationshipRequestRelationSubjectID is returned when the event message Relations has the incorrect field SubjectID value.
 	ErrMissingAuthRelationshipRequestRelationSubjectID = errors.New("auth relationship request message Relations SubjectID field required")
+
+	// ErrRequestNoResponders is returned when a request is attempted but no responder is listening.
+	ErrRequestNoResponders = errors.New("no responders for request")
 )

events/nats_message.go

@@ -3,6 +3,8 @@ package events
 import (
 	"context"
 	"encoding/json"
+	"errors"
+	"fmt"
 	"strconv"
 	"time"
 
@@ -178,6 +180,11 @@ func (m *NatsMessage[T]) request(ctx context.Context) (Message[AuthRelationshipR
 
 	nMsg, err := m.conn.conn.RequestMsgWithContext(ctx, m.source)
 	if err != nil {
+		// ensure we wrap no responder errors with ErrRequestNoResponders.
+		if errors.Is(err, nats.ErrNoResponders) {
+			return nil, fmt.Errorf("%w: %w", ErrRequestNoResponders, err)
+		}
+
 		return nil, err
 	}
 

events/nats_test.go

@@ -7,6 +7,7 @@ import (
 	"time"
 
 	"github.com/brianvoe/gofakeit/v6"
+	nc "github.com/nats-io/nats.go"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
 
@@ -99,6 +100,12 @@ func TestNatsRequestReply(t *testing.T) {
 		TraceContext: map[string]string{},
 	}
 
+	resp, err := conn.PublishAuthRelationshipRequest(ctx, "test", authRequest)
+	require.Error(t, err)
+	require.ErrorIs(t, err, events.ErrRequestNoResponders)
+	require.ErrorIs(t, err, nc.ErrNoResponders)
+	require.Nil(t, resp)
+
 	reqGot := make(chan events.Message[events.AuthRelationshipRequest], 1)
 	respGot := make(chan events.Message[events.AuthRelationshipResponse], 1)