Update playwright tests

Author: onurtemizkan

dev-packages/browser-integration-tests/suites/integrations/supabase/queues-rpc/init.js

@@ -18,12 +18,12 @@ Sentry.init({
 // Simulate queue operations
 async function performQueueOperations() {
   try {
-    await supabaseClient.rpc('enqueue', {
+    await supabaseClient.rpc('send', {
       queue_name: 'todos',
       msg: { title: 'Test Todo' },
     });
 
-    await supabaseClient.rpc('dequeue', {
+    await supabaseClient.rpc('pop', {
       queue_name: 'todos',
     });
   } catch (error) {

dev-packages/browser-integration-tests/suites/integrations/supabase/queues-rpc/test.ts

@@ -5,12 +5,24 @@ import { sentryTest } from '../../../../utils/fixtures';
 import { getFirstSentryEnvelopeRequest, shouldSkipTracingTest } from '../../../../utils/helpers';
 
 async function mockSupabaseRoute(page: Page) {
-  await page.route('**/rest/v1/rpc**', route => {
+  await page.route('**/rpc/**/send', route => {
     return route.fulfill({
       status: 200,
-      body: JSON.stringify({
-        foo: ['bar', 'baz'],
-      }),
+      body: JSON.stringify([0]),
+      headers: {
+        'Content-Type': 'application/json',
+      },
+    });
+  });
+
+  await page.route('**/rpc/**/pop', route => {
+    return route.fulfill({
+      status: 200,
+      body: JSON.stringify([
+        {
+          msg_id: 0,
+        },
+      ]),
       headers: {
         'Content-Type': 'application/json',
       },
@@ -25,16 +37,16 @@ if (bundle.startsWith('bundle')) {
 }
 
 sentryTest('should capture Supabase queue spans from client.rpc', async ({ getLocalTestUrl, page }) => {
-  await mockSupabaseRoute(page);
-
   if (shouldSkipTracingTest()) {
     return;
   }
 
+  await mockSupabaseRoute(page);
+
   const url = await getLocalTestUrl({ testDir: __dirname });
 
   const event = await getFirstSentryEnvelopeRequest<Event>(page, url);
-  const queueSpans = event.spans?.filter(({ op }) => op?.startsWith('queue'));
+  const queueSpans = event.spans?.filter(({ op }) => op?.startsWith('queue.'));
 
   expect(queueSpans).toHaveLength(2);
 
@@ -49,7 +61,7 @@ sentryTest('should capture Supabase queue spans from client.rpc', async ({ getLo
       'sentry.op': 'queue.publish',
       'sentry.origin': 'auto.db.supabase',
       'messaging.destination.name': 'todos',
-      'messaging.message.id': 'Test Todo',
+      'messaging.message.id': '0',
     }),
   });
 
@@ -64,6 +76,7 @@ sentryTest('should capture Supabase queue spans from client.rpc', async ({ getLo
       'sentry.op': 'queue.process',
       'sentry.origin': 'auto.db.supabase',
       'messaging.destination.name': 'todos',
+      'messaging.message.id': '0',
     }),
   });
 });

dev-packages/browser-integration-tests/suites/integrations/supabase/queues-schema/init.js

@@ -18,12 +18,12 @@ Sentry.init({
 // Simulate queue operations
 async function performQueueOperations() {
   try {
-    await supabaseClient.schema('pgmq_public').rpc('enqueue', {
+    await supabaseClient.schema('pgmq_public').rpc('send', {
       queue_name: 'todos',
       msg: { title: 'Test Todo' },
     });
 
-    await supabaseClient.schema('pgmq_public').rpc('dequeue', {
+    await supabaseClient.schema('pgmq_public').rpc('pop', {
       queue_name: 'todos',
     });
   } catch (error) {

dev-packages/browser-integration-tests/suites/integrations/supabase/queues-schema/test.ts

@@ -4,12 +4,24 @@ import { sentryTest } from '../../../../utils/fixtures';
 import { getFirstSentryEnvelopeRequest, shouldSkipTracingTest } from '../../../../utils/helpers';
 
 async function mockSupabaseRoute(page: Page) {
-  await page.route('**/rest/v1/rpc**', route => {
+  await page.route('**/rpc/**/send', route => {
     return route.fulfill({
       status: 200,
-      body: JSON.stringify({
-        foo: ['bar', 'baz'],
-      }),
+      body: JSON.stringify([0]),
+      headers: {
+        'Content-Type': 'application/json',
+      },
+    });
+  });
+
+  await page.route('**/rpc/**/pop', route => {
+    return route.fulfill({
+      status: 200,
+      body: JSON.stringify([
+        {
+          msg_id: 0,
+        },
+      ]),
       headers: {
         'Content-Type': 'application/json',
       },
@@ -24,16 +36,17 @@ if (bundle.startsWith('bundle')) {
 }
 
 sentryTest('should capture Supabase queue spans from client.schema(...).rpc', async ({ getLocalTestUrl, page }) => {
-  await mockSupabaseRoute(page);
-
   if (shouldSkipTracingTest()) {
     return;
   }
 
+  await mockSupabaseRoute(page);
+
   const url = await getLocalTestUrl({ testDir: __dirname });
 
   const event = await getFirstSentryEnvelopeRequest<Event>(page, url);
-  const queueSpans = event.spans?.filter(({ op }) => op?.startsWith('queue'));
+
+  const queueSpans = event.spans?.filter(({ op }) => op?.startsWith('queue.'));
 
   expect(queueSpans).toHaveLength(2);
 
@@ -48,7 +61,7 @@ sentryTest('should capture Supabase queue spans from client.schema(...).rpc', as
       'sentry.op': 'queue.publish',
       'sentry.origin': 'auto.db.supabase',
       'messaging.destination.name': 'todos',
-      'messaging.message.id': 'Test Todo',
+      'messaging.message.id': '0',
     }),
   });
 
@@ -63,6 +76,7 @@ sentryTest('should capture Supabase queue spans from client.schema(...).rpc', as
       'sentry.op': 'queue.process',
       'sentry.origin': 'auto.db.supabase',
       'messaging.destination.name': 'todos',
+      'messaging.message.id': '0',
     }),
   });
 });