chore: remove unused test utils for docker

Author: david-luna

packages/contrib-test-utils/src/index.ts

@@ -34,10 +34,8 @@ export type { TestSpan, RunTestFixtureOptions } from './test-fixtures';
 export {
   assertPropagation,
   assertSpan,
-  cleanUpDocker,
   getPackageVersion,
   initMeterProvider,
-  startDocker,
   TestMetricReader,
 } from './test-utils';
 export type { TimedEvent } from './test-utils';

packages/contrib-test-utils/src/test-utils.ts

@@ -14,7 +14,6 @@
  * limitations under the License.
  */
 
-import * as childProcess from 'child_process';
 import {
   HrTime,
   Span,
@@ -33,62 +32,6 @@ import * as path from 'path';
 import * as fs from 'fs';
 import { InstrumentationBase } from '@opentelemetry/instrumentation';
 
-const dockerRunCmds = {
-  cassandra:
-    'docker run --rm -d --name otel-cassandra -p 9042:9042 bitnami/cassandra:3',
-  memcached:
-    'docker run --rm -d --name otel-memcached -p 11211:11211 memcached:1.6.9-alpine',
-  mssql:
-    'docker run --rm -d --name otel-mssql -p 1433:1433 -e MSSQL_SA_PASSWORD=mssql_passw0rd -e ACCEPT_EULA=Y mcr.microsoft.com/mssql/server:2022-latest',
-  mysql:
-    'docker run --rm -d --name otel-mysql -p 33306:3306 -e MYSQL_ROOT_PASSWORD=rootpw -e MYSQL_DATABASE=test_db -e MYSQL_USER=otel -e MYSQL_PASSWORD=secret mysql:5.7 --log_output=TABLE --general_log=ON',
-  oracledb:
-    'docker run --rm -d --name otel-oracledb -p 1521:1521 -e ORACLE_PASSWORD=oracle -e APP_USER=otel -e APP_USER_PASSWORD=secret gvenzl/oracle-free:slim',
-  postgres:
-    'docker run --rm -d --name otel-postgres -p 54320:5432 -e POSTGRES_PASSWORD=postgres -e POSTGRES_DB=otel_pg_database postgres:16-alpine',
-  redis: 'docker run --rm -d --name otel-redis -p 63790:6379 redis:alpine',
-};
-
-export function startDocker(db: keyof typeof dockerRunCmds) {
-  const tasks = [run(dockerRunCmds[db])];
-
-  for (let i = 0; i < tasks.length; i++) {
-    const task = tasks[i];
-    if (task && task.code !== 0) {
-      console.error('Failed to start container!');
-      console.error(task.output);
-      return false;
-    }
-  }
-  return true;
-}
-
-export function cleanUpDocker(db: keyof typeof dockerRunCmds) {
-  run(`docker stop otel-${db}`);
-}
-
-function run(cmd: string) {
-  try {
-    const proc = childProcess.spawnSync(cmd, {
-      shell: true,
-    });
-    const output = Buffer.concat(
-      proc.output.filter(c => c) as Buffer[]
-    ).toString('utf8');
-    if (proc.status !== 0) {
-      console.error('Failed run command:', cmd);
-      console.error(output);
-    }
-    return {
-      code: proc.status,
-      output,
-    };
-  } catch (e) {
-    console.log(e);
-    return;
-  }
-}
-
 export const assertSpan = (
   span: ReadableSpan,
   kind: SpanKind,

packages/instrumentation-cassandra-driver/test/cassandra-driver.test.ts

@@ -57,7 +57,6 @@ context.setGlobalContextManager(new AsyncLocalStorageContextManager());
 
 const testCassandra = process.env.RUN_CASSANDRA_TESTS;
 const shouldTest = testCassandra;
-const cassandraTimeoutMs = 60000;
 const cassandraContactPoint = process.env.CASSANDRA_HOST
   ? '127.0.0.1'
   : 'cassandra';

packages/instrumentation-memcached/test/index.test.ts

@@ -23,7 +23,6 @@ import {
 } from '@opentelemetry/api';
 import { NodeTracerProvider } from '@opentelemetry/sdk-trace-node';
 import { AsyncLocalStorageContextManager } from '@opentelemetry/context-async-hooks';
-import * as testUtils from '@opentelemetry/contrib-test-utils';
 import {
   InMemorySpanExporter,
   SimpleSpanProcessor,

packages/instrumentation-pg/test/pg.test.ts

@@ -123,9 +123,8 @@ describe('pg', () => {
   });
   const tracer = provider.getTracer('external');
 
-  const testPostgres = process.env.RUN_POSTGRES_TESTS; // For CI: assumes local postgres db is already available
-  const testPostgresLocally = process.env.RUN_POSTGRES_TESTS_LOCAL; // For local: spins up local postgres db via docker
-  const shouldTest = testPostgres || testPostgresLocally; // Skips these tests if false (default)
+  const testPostgres = process.env.RUN_POSTGRES_TESTS;
+  const shouldTest = testPostgres; // Skips these tests if false (default)
 
   function getExecutedQueries() {
     return (client as any).queryQueue.push.args.flat() as (pg.Query & {
@@ -145,10 +144,6 @@ describe('pg', () => {
       skip();
     }
 
-    if (testPostgresLocally) {
-      testUtils.startDocker('postgres');
-    }
-
     instrumentation = new PgInstrumentation();
 
     contextManager = new AsyncLocalStorageContextManager().enable();
@@ -162,10 +157,6 @@ describe('pg', () => {
   });
 
   after(async () => {
-    if (testPostgresLocally) {
-      testUtils.cleanUpDocker('postgres');
-    }
-
     await client.end();
   });
 

packages/instrumentation-redis/test/v4/redis.test.ts

@@ -24,7 +24,6 @@ import type { MultiErrorReply } from '../../src/v4/internal-types';
 import * as assert from 'assert';
 
 import { redisTestConfig, redisTestUrl, shouldTest } from './utils';
-import * as testUtils from '@opentelemetry/contrib-test-utils';
 
 const instrumentation = registerInstrumentationTesting(
   new RedisInstrumentation()