Skip to content

Commit a363946

Browse files
committed
Reuse messageId from processConsumerSpanData instead of recomputing it
1 parent 611a647 commit a363946

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

packages/core/src/integrations/supabase.ts

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -790,7 +790,7 @@ function processConsumerSpanData(
790790
span: { setAttribute: (key: string, value: SpanAttributeValue | undefined) => void },
791791
queueName: string | undefined,
792792
cleanedData: SupabaseQueueMessage[],
793-
): void {
793+
): string | undefined {
794794
const firstItem = cleanedData.length > 0 ? cleanedData[0] : undefined;
795795
const isBatch = cleanedData.length > 1;
796796

@@ -847,6 +847,8 @@ function processConsumerSpanData(
847847
message: `queue.process(${queueName || 'unknown'})`,
848848
...(Object.keys(breadcrumbData).length > 0 && { data: breadcrumbData }),
849849
});
850+
851+
return messageId;
850852
}
851853

852854
/** Removes _sentry metadata from consumer response messages. Returns a shallow copy if metadata was found. */
@@ -982,10 +984,9 @@ function instrumentRpcConsumer(
982984
return cleanedRes;
983985
}
984986

985-
processConsumerSpanData(span, queueName, cleanedData as SupabaseQueueMessage[]);
987+
const messageId = processConsumerSpanData(span, queueName, cleanedData as SupabaseQueueMessage[]);
986988

987989
if (cleanedRes.error) {
988-
const messageId = extractMessageIds(cleanedData);
989990
captureQueueError(cleanedRes.error, queueName, 'auto.db.supabase.queue.consumer', messageId);
990991
}
991992

0 commit comments

Comments
 (0)