fix: adjust promise on open DB

.github/workflows/test.yml

@@ -52,4 +52,4 @@ jobs:
           MONGO_INITDB_ROOT_PASSWORD: ${{secrets.MONGO_INITDB_ROOT_PASSWORD}}
           MONGO_INITDB_DATABASE: ${{vars.MONGO_INITDB_DATABASE}}
       - name:
-        run: docker-compose up -d
+        run: docker compose up -d

docker-compose.yml

@@ -18,6 +18,13 @@ services:
     hostname: mongodb7
     networks:
       - alpine_net
+    healthcheck:
+      test: echo 'db.runCommand("ping").ok' | mongosh 127.0.0.1:27017/test --quiet
+      start_period: 30s
+      start_interval: 30s
+      interval: 5s
+      timeout: 30s
+      retries: 50
     deploy:
       resources:
         limits:
@@ -31,7 +38,8 @@ services:
     ports:
       - 3000:3000
     depends_on:
-      - mongodb7
+      mongodb7:
+        condition: service_healthy
     networks:
       - alpine_net
 

src/client-connection.ts

@@ -16,13 +16,14 @@ export class ClientConnection {
     return (MConnClient: MongoClient) => MConnClient;
   }
 
-  async connectOpen(dbName: string) {
-    await this.client.connect();
-    this.dbInstance = await this.client.db(dbName);
-    return this.dbInstance;
+  async openConnect(dbName: string) {
+    return this.client.connect().then(() => {
+      this.dbInstance = this.client.db(dbName);
+      return this.dbInstance;
+    });
   }
 
-  async collection(collectionName: string) {
+  collection(collectionName: string) {
     return this.dbInstance.collection(collectionName);
   }
 }

src/index.ts

@@ -18,8 +18,11 @@ export class SimpleConnection extends ClientConnection {
     this.dbName = dbName;
   }
 
-  async open() {
+  open() {
     this.client = new MongoClient(this.connectionString);
-    await super.connectOpen(this.dbName);
+    return new Promise((resolve, reject) => {
+      super.openConnect(this.dbName)
+        .then((db) => resolve(db));
+    });
   }
 }

tests/unit/client-connection.test.ts

@@ -29,18 +29,18 @@ describe("Unit Test for ClientConnection", () => {
   });
 
   it("expect connectOpen calls client connect", async () => {
-    await db.connectOpen("test");
+    await db.openConnect('test');
     expect(dbMethodsStub.connect.called).to.be.true;
   });
 
   it("expect connectOpen calls client db", async () => {
-    await db.connectOpen("test");
+    await db.openConnect('test');
     expect(dbMethodsStub.db.called).to.be.true;
   });
 
   it("expect collection calls dbInstance collection", async () => {
-    await db.connectOpen("test");
-    await db.collection("test");
+    const dbInstance = await db.openConnect('test');
+    dbInstance.collection('test');
     expect(collectionStub.collection.called).to.be.true;
   });
 });