Fixes

Author: cristianrgreco

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

@@ -4,8 +4,6 @@ import { BucketDefinition } from "./bucket-definition";
 import { CouchbaseContainer, StartedCouchbaseContainer } from "./couchbase-container";
 import { CouchbaseService } from "./couchbase-service";
 
-const IMAGE = "couchbase/server:6.5.1";
-
 describe("CouchbaseContainer", { timeout: 180_000 }, () => {
   // upsertAndGet {
   const upsertAndGet = async (

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

@@ -4,7 +4,7 @@ import * as path from "path";
 import { GenericContainer, Network, StartedTestContainer } from "testcontainers";
 import { KafkaContainer } from "./kafka-container";
 
-const IMAGE="confluentinc/cp-kafka:7.2.2"
+const IMAGE = "confluentinc/cp-kafka:7.2.2";
 
 describe("KafkaContainer", { timeout: 240_000 }, () => {
   // connectBuiltInZK {
@@ -207,78 +207,22 @@ describe("KafkaContainer", { timeout: 240_000 }, () => {
 
   it("should connect using kraft and custom network", async () => {
     const network = await new Network().start();
-    const kafkaContainer = await new KafkaContainer(IMAGE).withKraft().withNetwork(network).withExposedPorts(9093).start();
-
-    await testPubSub(kafkaContainer);
-
-    await kafkaContainer.stop();
-    await network.stop();
-  });
-
-  it("should throw an error when using kraft wit sasl and confluence platfom below 7.5.0", async () => {
-    const kafkaContainer = new KafkaContainer("confluentinc/cp-kafka:7.4.0")
-      .withKraft()
-      .withExposedPorts(9093)
-      .withSaslSslListener({
-        port: 9094,
-        sasl: {
-          mechanism: "SCRAM-SHA-512",
-          user: {
-            name: "app-user",
-            password: "userPassword",
-          },
-        },
-        keystore: {
-          content: "fake",
-          passphrase: "serverKeystorePassword",
-        },
-        truststore: {
-          content: "fake",
-          passphrase: "serverTruststorePassword",
-        },
-      });
-    await expect(() => kafkaContainer.start()).rejects.toThrow(
-      "Provided Confluent Platform's version 7.4.0 is not supported in Kraft mode with sasl (must be 7.5.0 or above)"
-    );
-  });
-
-  it("should connect using ZooKeeper", async () => {
-    const network = await new Network().start();
-
-    const zookeeperContainer = await new GenericContainer("confluentinc/cp-zookeeper:7.2.2")
-      .withExposedPorts(2181)
-      .withNetwork(network)
-      .withNetworkAliases("zookeeper")
-      .withEnvironment({
-        ZOOKEEPER_CLIENT_PORT: "2181",
-      })
-      .start();
-
     const kafkaContainer = await new KafkaContainer(IMAGE)
-      .withZooKeeper("zookeeper", 2181)
+      .withKraft()
       .withNetwork(network)
       .withExposedPorts(9093)
       .start();
 
     await testPubSub(kafkaContainer);
 
-    await zookeeperContainer.stop();
     await kafkaContainer.stop();
     await network.stop();
   });
 
-  it("should connect using KRaft", async () => {
-    const kafkaContainer = await new KafkaContainer(IMAGE).withKraft().withExposedPorts(9093).start();
-
-    await testPubSub(kafkaContainer);
-
-    await kafkaContainer.stop();
-  });
-
-  it("should connect with KRaft and SASL_SSL", async () => {
-    const kafkaContainer = await new KafkaContainer(IMAGE)
+  it("should throw an error when using kraft wit sasl and confluence platfom below 7.5.0", async () => {
+    const kafkaContainer = new KafkaContainer("confluentinc/cp-kafka:7.4.0")
       .withKraft()
-      .withExposedPorts(9093, 9099)
+      .withExposedPorts(9093)
       .withSaslSslListener({
         port: 9094,
         sasl: {

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

@@ -85,9 +85,7 @@ describe("LocalStackContainer", { timeout: 180_000 }, () => {
   });
 
   it("should override LOCALSTACK_HOST with last network alias", async () => {
-    const container = await new LocalstackContainer(IMAGE)
-      .withNetworkAliases("other", "myalias")
-      .start();
+    const container = await new LocalstackContainer(IMAGE).withNetworkAliases("other", "myalias").start();
 
     const { output, exitCode } = await container.exec(["printenv", "LOCALSTACK_HOST"]);
     expect(exitCode).toBe(0);

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

@@ -144,59 +144,4 @@ describe("MariaDb", { timeout: 240_000 }, () => {
     await client.end();
     await container.stop();
   });
-
-  it("should set custom root password", async () => {
-    const rootPassword = "rootPassword";
-    const container = await new MariaDbContainer(IMAGE).withRootPassword(rootPassword).start();
-
-    const client = await mariadb.createConnection({
-      host: container.getHost(),
-      port: container.getPort(),
-      database: container.getDatabase(),
-      user: container.getUsername(),
-      password: container.getUserPassword(),
-    });
-
-    const rows = await client.query("SELECT 1 as res");
-    expect(rows).toEqual([{ res: 1 }]);
-
-    await client.end();
-    await container.stop();
-  });
-
-  it("should allow connecting with root user", async () => {
-    const container = await new MariaDbContainer(IMAGE).start();
-
-    const client = await mariadb.createConnection({
-      host: container.getHost(),
-      port: container.getPort(),
-      database: container.getDatabase(),
-      user: container.getUsername(),
-      password: container.getUserPassword(),
-    });
-
-    const rows = await client.query("SELECT 1 as res");
-    expect(rows).toEqual([{ res: 1 }]);
-
-    await client.end();
-    await container.stop();
-  });
-
-  it("should convert database URI to root URI and use it", async () => {
-    const container = await new MariaDbContainer(IMAGE).start();
-
-    const client = await mariadb.createConnection({
-      host: container.getHost(),
-      port: container.getPort(),
-      database: container.getDatabase(),
-      user: container.getUsername(),
-      password: container.getUserPassword(),
-    });
-
-    const rows = await client.query("SELECT 1 as res");
-    expect(rows).toEqual([{ res: 1 }]);
-
-    await client.end();
-    await container.stop();
-  });
 });

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

@@ -85,4 +85,4 @@ describe("Neo4jContainer", { timeout: 180_000 }, () => {
     await container.stop();
   });
   // }
-});
+});