feat: enable a way to disable amqp tests that require a server running (

open-telemetry#1002)

.github/workflows/unit-test.yml

@@ -98,6 +98,7 @@ jobs:
       RUN_MSSQL_TESTS: 1
       RUN_POSTGRES_TESTS: 1
       RUN_REDIS_TESTS: 1
+      RUN_RABBIT_TESTS: 1
       CASSANDRA_HOST: localhost
       MONGODB_DB: opentelemetry-tests
       MONGODB_HOST: 127.0.0.1

plugins/node/instrumentation-amqplib/test/amqplib-callbacks.test.ts

@@ -29,7 +29,7 @@ import {
   SemanticAttributes,
 } from '@opentelemetry/semantic-conventions';
 import { context, SpanKind } from '@opentelemetry/api';
-import { asyncConfirmSend, asyncConsume } from './utils';
+import { asyncConfirmSend, asyncConsume, shouldTest } from './utils';
 import {
   censoredUrl,
   rabbitMqUrl,
@@ -42,14 +42,22 @@ const queueName = 'queue-name-from-unittest';
 
 describe('amqplib instrumentation callback model', () => {
   let conn: amqpCallback.Connection;
-  before(done => {
-    amqpCallback.connect(rabbitMqUrl, (err, connection) => {
-      conn = connection;
-      done(err);
-    });
+  before(function (done) {
+    if (!shouldTest) {
+      this.skip();
+    } else {
+      amqpCallback.connect(rabbitMqUrl, (err, connection) => {
+        conn = connection;
+        done(err);
+      });
+    }
   });
   after(done => {
-    conn.close(() => done());
+    if (!shouldTest) {
+      done();
+    } else {
+      conn.close(() => done());
+    }
   });
 
   describe('channel', () => {

plugins/node/instrumentation-amqplib/test/amqplib-connection.test.ts

@@ -15,6 +15,7 @@
  */
 import 'mocha';
 import * as expect from 'expect';
+import { shouldTest } from './utils';
 import {
   censoredUrl,
   rabbitMqUrl,
@@ -34,6 +35,12 @@ import * as amqp from 'amqplib';
 import { SemanticAttributes } from '@opentelemetry/semantic-conventions';
 
 describe('amqplib instrumentation connection', () => {
+  before(function () {
+    if (!shouldTest) {
+      this.skip();
+    }
+  });
+
   describe('connect with url object', () => {
     it('should extract connection attributes form url options', async function () {
       const testName = this.test!.title;

plugins/node/instrumentation-amqplib/test/amqplib-promise.test.ts

@@ -41,6 +41,7 @@ import {
 } from '@opentelemetry/semantic-conventions';
 import { Span, SpanKind, SpanStatusCode } from '@opentelemetry/api';
 import { asyncConfirmPublish, asyncConfirmSend, asyncConsume } from './utils';
+import { shouldTest } from './utils';
 import {
   censoredUrl,
   rabbitMqUrl,
@@ -60,11 +61,17 @@ const CHANNEL_CLOSED_IN_TEST = Symbol(
 
 describe('amqplib instrumentation promise model', () => {
   let conn: amqp.Connection;
-  before(async () => {
-    conn = await amqp.connect(rabbitMqUrl);
+  before(async function () {
+    if (!shouldTest) {
+      this.skip();
+    } else {
+      conn = await amqp.connect(rabbitMqUrl);
+    }
   });
   after(async () => {
-    await conn.close();
+    if (shouldTest) {
+      await conn.close();
+    }
   });
 
   let endHookSpy: SinonSpy;

plugins/node/instrumentation-amqplib/test/utils.test.ts

@@ -21,16 +21,23 @@ import {
 } from '../src/utils';
 import { SemanticAttributes } from '@opentelemetry/semantic-conventions';
 import * as amqp from 'amqplib';
+import { shouldTest } from './utils';
 import { rabbitMqUrl } from './config';
 
 describe('utils', () => {
   describe('getConnectionAttributesFromServer', () => {
     let conn: amqp.Connection;
-    before(async () => {
-      conn = await amqp.connect(rabbitMqUrl);
+    before(async function () {
+      if (!shouldTest) {
+        this.skip();
+      } else {
+        conn = await amqp.connect(rabbitMqUrl);
+      }
     });
     after(async () => {
-      await conn.close();
+      if (shouldTest) {
+        await conn.close();
+      }
     });
 
     it('messaging system attribute', () => {

plugins/node/instrumentation-amqplib/test/utils.ts

@@ -100,3 +100,5 @@ export const asyncConsume = (
     )
   );
 };
+
+export const shouldTest = !!process.env.RUN_RABBIT_TESTS;