Concurrency fixed. Cassandra/Cloudstorage WIP

Author: cristianrgreco

packages/modules/cassandra/src/cassandra-container.test.ts

@@ -5,7 +5,7 @@ import { CassandraContainer } from "./cassandra-container";
 
 const IMAGE = getImage(__dirname);
 
-describe("Cassandra", { timeout: 240_000 }, () => {
+describe.sequential("Cassandra", { timeout: 240_000 }, () => {
   // connectWithDefaultCredentials {
   it("should connect and execute a query with default credentials", async () => {
     const container = await new CassandraContainer(IMAGE).start();

packages/modules/gcloud/src/cloudstorage-emulator-container.test.ts

@@ -30,7 +30,7 @@ async function getRequestBodyFromReadableStream(stream: ReadableStream<Uint8Arra
   return fullString;
 }
 
-describe("CloudStorageEmulatorContainer", { timeout: 240_000 }, () => {
+describe.sequential("CloudStorageEmulatorContainer", { timeout: 240_000 }, () => {
   const server = setupServer();
 
   beforeAll(() => {

packages/modules/kurrentdb/src/kurrentdb-container.test.ts

@@ -42,6 +42,7 @@ describe("KurrentDbContainer", { timeout: 240_000 }, () => {
     ]);
 
     await container.stop();
+    await client.dispose();
   });
   // }
 
@@ -86,6 +87,7 @@ describe("KurrentDbContainer", { timeout: 240_000 }, () => {
     );
     await stream.unsubscribe();
     await container.stop();
+    await client.dispose();
   });
   // }
 });

packages/testcontainers/src/container-runtime/auth/get-auth-config.test.ts

@@ -1,6 +1,6 @@
-import { Mock } from "vitest";
+import type { Mock } from "vitest";
 
-describe("get auth config", () => {
+describe.sequential("get auth config", () => {
   let mockExistsSync: Mock;
   let mockReadFile: Mock;
 

packages/testcontainers/src/port-forwarder/port-forwarder.test.ts

@@ -1,24 +1,15 @@
-import { Server } from "http";
 import { GenericContainer } from "../generic-container/generic-container";
 import { Network } from "../network/network";
 import { TestContainers } from "../test-containers";
 import { RandomPortGenerator } from "../utils/port-generator";
 import { createTestServer } from "../utils/test-helper";
 
 describe("PortForwarder", { timeout: 180_000 }, () => {
-  let randomPort: number;
-  let server: Server;
-
-  beforeEach(async () => {
-    randomPort = await new RandomPortGenerator().generatePort();
-    server = await createTestServer(randomPort);
-  });
-
-  afterEach(async () => {
-    await new Promise((resolve) => server.close(resolve));
-  });
+  const portGen = new RandomPortGenerator();
 
   it("should expose host ports to the container", async () => {
+    const randomPort = await portGen.generatePort();
+    const server = await createTestServer(randomPort);
     await TestContainers.exposeHostPorts(randomPort);
 
     const container = await new GenericContainer("cristianrgreco/testcontainer:1.1.14").start();
@@ -27,9 +18,12 @@ describe("PortForwarder", { timeout: 180_000 }, () => {
     expect(output).toEqual(expect.stringContaining("hello world"));
 
     await container.stop();
+    server.close();
   });
 
   it("should expose host ports to the container with custom network", async () => {
+    const randomPort = await portGen.generatePort();
+    const server = await createTestServer(randomPort);
     await TestContainers.exposeHostPorts(randomPort);
 
     const network = await new Network().start();
@@ -40,9 +34,12 @@ describe("PortForwarder", { timeout: 180_000 }, () => {
 
     await container.stop();
     await network.stop();
+    server.close();
   });
 
   it("should expose host ports to the container with custom network and network alias", async () => {
+    const randomPort = await portGen.generatePort();
+    const server = await createTestServer(randomPort);
     await TestContainers.exposeHostPorts(randomPort);
 
     const network = await new Network().start();
@@ -56,5 +53,6 @@ describe("PortForwarder", { timeout: 180_000 }, () => {
 
     await container.stop();
     await network.stop();
+    server.close();
   });
 });