Bumped to 0.23.1-alpha.1

Author: oskardudycz

src/package-lock.json

@@ -1,7 +1,7 @@
 {
   "name": "@event-driven-io/core",
   "type": "module",
-  "version": "0.22.1",
+  "version": "0.23.0-alpha.1",
   "description": "Emmett - Event Sourcing development made simple",
   "engines": {
     "node": ">=20.11.1"

src/package.json

@@ -1,7 +1,7 @@
 {
   "name": "@event-driven-io/emmett-esdb",
   "type": "module",
-  "version": "0.22.1",
+  "version": "0.23.0-alpha.1",
   "description": "Emmett - EventStoreDB - Event Sourcing development made simple",
   "scripts": {
     "build": "tsup",
@@ -48,10 +48,10 @@
   ],
   "dependencies": {},
   "devDependencies": {
-    "@event-driven-io/emmett-testcontainers": "0.22.1"
+    "@event-driven-io/emmett-testcontainers": "0.23.0-alpha.1"
   },
   "peerDependencies": {
-    "@event-driven-io/emmett": "0.22.1",
+    "@event-driven-io/emmett": "0.23.0-alpha.1",
     "@eventstore/db-client": "^6.2.1"
   }
 }

src/packages/emmett-esdb/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@event-driven-io/emmett-expressjs",
-  "version": "0.22.1",
+  "version": "0.23.0-alpha.1",
   "type": "module",
   "description": "Emmett - Event Sourcing development made simple",
   "scripts": {
@@ -49,7 +49,7 @@
   "dependencies": {},
   "devDependencies": {},
   "peerDependencies": {
-    "@event-driven-io/emmett": "0.22.1",
+    "@event-driven-io/emmett": "0.23.0-alpha.1",
     "@types/express": "^4.17.21",
     "@types/supertest": "^6.0.2",
     "express": "^4.19.2",

src/packages/emmett-expressjs/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@event-driven-io/emmett-fastify",
-  "version": "0.22.1",
+  "version": "0.23.0-alpha.1",
   "type": "module",
   "description": "Emmett - Event Sourcing development made simple",
   "scripts": {
@@ -53,7 +53,7 @@
   "dependencies": {},
   "devDependencies": {},
   "peerDependencies": {
-    "@event-driven-io/emmett": "0.22.1",
+    "@event-driven-io/emmett": "0.23.0-alpha.1",
     "fastify": "^4.28.1",
     "@fastify/compress": "^7.0.3",
     "@fastify/etag": "^5.2.0",

src/packages/emmett-fastify/package.json

@@ -1,7 +1,7 @@
 {
   "name": "@event-driven-io/emmett-mongodb",
   "type": "module",
-  "version": "0.22.1",
+  "version": "0.23.0-alpha.1",
   "description": "Emmett - MongoDB - Event Sourcing development made simple",
   "scripts": {
     "build": "tsup",
@@ -47,11 +47,11 @@
     "dist"
   ],
   "devDependencies": {
-    "@event-driven-io/emmett-testcontainers": "0.22.1",
+    "@event-driven-io/emmett-testcontainers": "0.23.0-alpha.1",
     "@testcontainers/mongodb": "^10.13.2"
   },
   "peerDependencies": {
-    "@event-driven-io/emmett": "0.22.1",
+    "@event-driven-io/emmett": "0.23.0-alpha.1",
     "mongodb": "^6.10.0"
   }
 }

src/packages/emmett-mongodb/package.json

@@ -325,15 +325,6 @@ class MongoDBEventStoreImplementation implements MongoDBEventStore {
     return this.client.close();
   }
 
-  private getDB = async (): Promise<Db> => {
-    if (!this.db) {
-      if (!this.isClosed) await this.client.connect();
-
-      this.db = this.client.db(this.defaultOptions.database);
-    }
-    return this.db;
-  };
-
   private collectionFor = async <EventType extends Event>(
     streamType: StreamType,
   ): Promise<Collection<EventStream<EventType>>> => {
@@ -356,6 +347,20 @@ class MongoDBEventStoreImplementation implements MongoDBEventStore {
 
     return collection;
   };
+
+  private getDB = async (): Promise<Db> => {
+    if (!this.db) {
+      const connectedClient = await this.getConnectedClient();
+
+      this.db = connectedClient.db(this.defaultOptions.database);
+    }
+    return this.db;
+  };
+
+  private getConnectedClient = async (): Promise<MongoClient> => {
+    if (!this.isClosed) await this.client.connect();
+    return this.client;
+  };
 }
 
 export const getMongoDBEventStore = (

src/packages/emmett-mongodb/src/eventStore/mongoDBEventStore.ts

@@ -1,6 +1,6 @@
 {
   "name": "@event-driven-io/emmett-postgresql",
-  "version": "0.22.1",
+  "version": "0.23.0-alpha.1",
   "type": "module",
   "description": "Emmett - PostgreSQL - Event Sourcing development made simple",
   "scripts": {
@@ -70,10 +70,10 @@
   ],
   "devDependencies": {
     "@testcontainers/postgresql": "^10.12.0",
-    "@event-driven-io/emmett-testcontainers": "0.22.1"
+    "@event-driven-io/emmett-testcontainers": "0.23.0-alpha.1"
   },
   "peerDependencies": {
-    "@event-driven-io/emmett": "0.22.1",
+    "@event-driven-io/emmett": "0.23.0-alpha.1",
     "@event-driven-io/pongo": "0.16.4"
   }
 }

src/packages/emmett-postgresql/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@event-driven-io/emmett-shims",
-  "version": "0.22.1",
+  "version": "0.23.0-alpha.1",
   "type": "module",
   "description": "Emmett - Event Sourcing development made simple",
   "scripts": {

src/packages/emmett-shims/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@event-driven-io/emmett-testcontainers",
-  "version": "0.22.1",
+  "version": "0.23.0-alpha.1",
   "type": "module",
   "description": "Emmett - TestContainers - Event Sourcing development made simple",
   "scripts": {
@@ -47,7 +47,7 @@
     "dist"
   ],
   "dependencies": {
-    "@event-driven-io/emmett": "0.22.1",
+    "@event-driven-io/emmett": "0.23.0-alpha.1",
     "testcontainers": "^10.12.0"
   },
   "devDependencies": {