test(node): Streamline amqplib tests (#21723)

Combine this into a single test to ensure this does not run out of sync.
Now, we simply use different docker files, leverage
additionalDependencies, and otherwise use the same tests.

Closes #21692
Closes #21693
(possibly, but let's see..)

Author: mydea

dev-packages/node-integration-tests/suites/tracing/amqplib-v1/docker-compose.yml

@@ -1,9 +1,6 @@
-version: '3'
-
 services:
   rabbitmq:
     image: rabbitmq:management
-    container_name: rabbitmq
     environment:
       - RABBITMQ_DEFAULT_USER=sentry
       - RABBITMQ_DEFAULT_PASS=sentry

dev-packages/node-integration-tests/suites/tracing/amqplib-v1/instrument.mjs

@@ -29,39 +29,50 @@ describe('amqplib auto-instrumentation', () => {
     cleanupChildProcesses();
   });
 
-  createEsmAndCjsTests(__dirname, 'scenario.mjs', 'instrument.mjs', (createTestRunner, test) => {
-    test('should be able to send and receive messages', { timeout: 60_000 }, async () => {
-      // The producer ('root span') and consumer ('queue1 process') transactions can
-      // arrive in any order, so we collect them and assert after both are received.
-      const receivedTransactions: TransactionEvent[] = [];
+  describe.each([
+    ['v1', { amqplib: '^1.0.0' }],
+    ['v2', {}],
+  ])('%s', (version, additionalDependencies) => {
+    createEsmAndCjsTests(
+      __dirname,
+      'scenario.mjs',
+      'instrument.mjs',
+      (createTestRunner, test) => {
+        test('should be able to send and receive messages', { timeout: 60_000 }, async () => {
+          // The producer ('root span') and consumer ('queue1 process') transactions can
+          // arrive in any order, so we collect them and assert after both are received.
+          const receivedTransactions: TransactionEvent[] = [];
 
-      await createTestRunner()
-        .withDockerCompose({
-          workingDirectory: [__dirname],
-        })
-        .expect({
-          transaction: (transaction: TransactionEvent) => {
-            receivedTransactions.push(transaction);
-          },
-        })
-        .expect({
-          transaction: (transaction: TransactionEvent) => {
-            receivedTransactions.push(transaction);
+          await createTestRunner()
+            .withDockerCompose({
+              workingDirectory: [__dirname],
+            })
+            .expect({
+              transaction: (transaction: TransactionEvent) => {
+                receivedTransactions.push(transaction);
+              },
+            })
+            .expect({
+              transaction: (transaction: TransactionEvent) => {
+                receivedTransactions.push(transaction);
 
-            const producer = receivedTransactions.find(t => t.transaction === 'root span');
-            const consumer = receivedTransactions.find(t => t.transaction === 'queue1 process');
+                const producer = receivedTransactions.find(t => t.transaction === 'root span');
+                const consumer = receivedTransactions.find(t => t.transaction === 'queue1 process');
 
-            expect(producer).toBeDefined();
-            expect(consumer).toBeDefined();
+                expect(producer).toBeDefined();
+                expect(consumer).toBeDefined();
 
-            expect(producer!.spans?.length).toEqual(1);
-            expect(producer!.spans![0]).toMatchObject(EXPECTED_MESSAGE_SPAN_PRODUCER);
+                expect(producer!.spans?.length).toEqual(1);
+                expect(producer!.spans![0]).toMatchObject(EXPECTED_MESSAGE_SPAN_PRODUCER);
 
-            expect(consumer!.contexts?.trace).toMatchObject(EXPECTED_MESSAGE_SPAN_CONSUMER);
-          },
-        })
-        .start()
-        .completed();
-    });
+                expect(consumer!.contexts?.trace).toMatchObject(EXPECTED_MESSAGE_SPAN_CONSUMER);
+              },
+            })
+            .start()
+            .completed();
+        });
+      },
+      { additionalDependencies },
+    );
   });
 });