Use Kurrent image and lib

Author: cristianrgreco

package-lock.json

@@ -3,7 +3,6 @@
   "version": "10.28.0",
   "license": "MIT",
   "keywords": [
-    "eventstoredb",
     "kurrent",
     "testing",
     "docker",
@@ -30,7 +29,7 @@
     "build": "tsc --project tsconfig.build.json"
   },
   "devDependencies": {
-    "@eventstore/db-client": "^6.2.1"
+    "@kurrent/kurrentdb-client": "^1.0.1"
   },
   "dependencies": {
     "testcontainers": "^10.28.0"

packages/modules/kurrent/package.json

@@ -1,12 +1,12 @@
-import { EventStoreDBClient, StreamingRead, StreamSubscription } from "@eventstore/db-client";
+import { KurrentDBClient, StreamSubscription } from "@kurrent/kurrentdb-client";
 import { KurrentContainer } from "./kurrent-container";
 
 describe("KurrentContainer", { timeout: 240_000 }, () => {
   // startContainer {
   it("should execute write and read", async () => {
     const container = await new KurrentContainer().start();
 
-    const client = EventStoreDBClient.connectionString(container.getConnectionString());
+    const client = KurrentDBClient.connectionString(container.getConnectionString());
 
     await client.appendToStream("User-1", [
       {
@@ -31,7 +31,7 @@ describe("KurrentContainer", { timeout: 240_000 }, () => {
           metadata: {
             someMetadata: "bar",
           },
-          revision: 0n,
+          revision: 0,
           streamId: "User-1",
           type: "UserCreated",
         }),
@@ -45,7 +45,7 @@ describe("KurrentContainer", { timeout: 240_000 }, () => {
   // usingStandardProjections {
   it("should use built-in projections", async () => {
     const container = await new KurrentContainer().start();
-    const client = EventStoreDBClient.connectionString(container.getConnectionString());
+    const client = KurrentDBClient.connectionString(container.getConnectionString());
 
     await client.appendToStream("Todo-1", [
       {
@@ -87,7 +87,7 @@ describe("KurrentContainer", { timeout: 240_000 }, () => {
   // }
 });
 
-async function consumeSteamingRead(read: StreamingRead<unknown>): Promise<unknown[]> {
+async function consumeSteamingRead(read: AsyncIterableIterator<unknown>): Promise<unknown[]> {
   const events = [];
 
   for await (const event of read) {

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

@@ -6,18 +6,16 @@ export class StartedKurrentContainer extends AbstractStartedContainer {
   }
 }
 
-const EVENT_STORE_DB_PORT = 2113;
-
 export class KurrentContainer extends GenericContainer {
-  constructor(image = "eventstore/eventstore:24.10") {
+  constructor(image = "kurrentplatform/kurrentdb:25.0") {
     super(image);
 
-    this.withExposedPorts(EVENT_STORE_DB_PORT)
+    this.withExposedPorts(2113)
       .withEnvironment({
-        EVENTSTORE_CLUSTER_SIZE: "1",
-        EVENTSTORE_RUN_PROJECTIONS: "All",
-        EVENTSTORE_START_STANDARD_PROJECTIONS: "true",
-        EVENTSTORE_INSECURE: "true",
+        KURRENTDB_CLUSTER_SIZE: "1",
+        KURRENTDB_RUN_PROJECTIONS: "All",
+        KURRENTDB_START_STANDARD_PROJECTIONS: "true",
+        KURRENTDB_INSECURE: "true",
       })
       .withStartupTimeout(120_000)
       .withWaitStrategy(Wait.forHealthCheck());