chore: correct error returned on failure to parse JSON

sparetimecoders · Feb 10, 2024 · 0941f9b · 0941f9b
1 parent 9f2d061
commit 0941f9b
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/setup_consumer.go b/setup_consumer.go
@@ -56,7 +56,7 @@ func TypeMappingHandler(handler Handler) EventHandler[json.RawMessage] {
 			return ErrNoMessageTypeForRouteKey
 		}
 		if err := json.Unmarshal(event.Payload, &message); err != nil {
-			return err
+			return fmt.Errorf("%v: %w", err, ErrParseJSON)
 		}
 		msg := ConsumableEvent[any]{
 			Metadata:     event.Metadata,

diff --git a/setup_consumer_test.go b/setup_consumer_test.go
@@ -232,7 +232,7 @@ func Test_TypeMappingHandler(t *testing.T) {
 				},
 			},
 			wantErr: func(t assert.TestingT, err error, i ...interface{}) bool {
-				return assert.EqualError(t, err, "unexpected end of JSON input")
+				return assert.ErrorContains(t, err, "unexpected end of JSON input")
 			},
 		},
 		{
-Original file line number
+Diff line change
@@ Expand Up / @@ -232,7 +232,7 @@ func Test_TypeMappingHandler(t *testing.T) { @@
     				},
     			},
     			wantErr: func(t assert.TestingT, err error, i ...interface{}) bool {
-    				return assert.EqualError(t, err, "unexpected end of JSON input")
+    				return assert.ErrorContains(t, err, "unexpected end of JSON input")
     			},
     		},
     		{
@@ Expand Down @@