send nats error message for api error

unusualcodeorg · Jul 1, 2024 · 5415a69 · 5415a69
1 parent 754b336
commit 5415a69
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/arch/micro/sender.go b/arch/micro/sender.go
@@ -1,5 +1,12 @@
 package micro
 
+import (
+	"errors"
+	"fmt"
+
+	"github.com/unusualcodeorg/goserve/arch/network"
+)
+
 type sender struct{}
 
 func NewMessageSender() MessageSender {
@@ -21,5 +28,10 @@ func (s *send) Message(data any) {
 }
 
 func (s *send) Error(err error) {
+	if apiError, ok := err.(network.ApiError); ok {
+		msg := fmt.Sprintf("%d:%s", apiError.GetCode(), apiError.GetMessage())
+		s.natsRequest.RespondJSON(NewAnyMessage(nil, errors.New(msg)))
+		return
+	}
 	s.natsRequest.RespondJSON(NewAnyMessage(nil, err))
 }