Add array check for messages from params

onurtemizkan · onurtemizkan · commit c652ca0a01f9 · 2025-12-08T13:29:54.000Z
diff --git a/packages/core/src/integrations/supabase.ts b/packages/core/src/integrations/supabase.ts
@@ -1055,7 +1055,7 @@ function _instrumentRpcProducer(target: unknown, thisArg: unknown, argumentsList
               'Skipping trace propagation for non-object message payload. PGMQ supports primitives and arrays, but trace context can only be injected into plain objects.',
             );
         }
-      } else if (originalParams?.messages) {
+      } else if (Array.isArray(originalParams?.messages)) {
         paramsWithTrace.messages = originalParams.messages.map(message => {
           if (isPlainObject(message)) {
             return {

Original file line number	Diff line number	Diff line change
`@@ -1055,7 +1055,7 @@ function _instrumentRpcProducer(target: unknown, thisArg: unknown, argumentsList`
`1055`	`1055`	`'Skipping trace propagation for non-object message payload. PGMQ supports primitives and arrays, but trace context can only be injected into plain objects.',`
`1056`	`1056`	`);`
`1057`	`1057`	`}`
`1058`		`- } else if (originalParams?.messages) {`
	`1058`	`+ } else if (Array.isArray(originalParams?.messages)) {`
`1059`	`1059`	`paramsWithTrace.messages = originalParams.messages.map(message => {`
`1060`	`1060`	`if (isPlainObject(message)) {`
`1061`	`1061`	`return {`