fix: mog not connecting in the constructor (#8)

fdebijl · Jan 17, 2022 · 73c7d57 · 73c7d57
1 parent 7df46fb
commit 73c7d57
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 3 deletions.
diff --git a/src/domain/type/MogOptions.ts b/src/domain/type/MogOptions.ts
@@ -2,7 +2,9 @@ import { DbOptions, MongoClientOptions } from 'mongodb';
 
 export type MogOptions = {
   url: string;
+  /** Name of the DB to use */
   db: string;
+  /** Name of the connecting application, shown in the MongoDB logs and profiler */
   appName?: string;
   /** Default collection that is used for all operations. If not set, a collection must be passed with every operation */
   defaultCollection?: string;

diff --git a/src/index.ts b/src/index.ts
@@ -2,8 +2,7 @@ import { MongoClient, Db, Filter, Document, WithId, InsertManyResult, InsertOneR
 import { Clog, LOGLEVEL } from '@fdebijl/clog';
 import fs from 'fs';
 
-import { Attachment, InsertOptions, MogOptions, OperationOptions, GetOptions, Operation, UpdateOptions, ListOptions } from './domain';
-import { CountOptions } from './domain/type/CountOptions';
+import { Attachment, InsertOptions, MogOptions, OperationOptions, GetOptions, Operation, UpdateOptions, ListOptions, CountOptions } from './domain';
 
 const mogVersion = JSON.parse(fs.readFileSync('package.json', 'utf-8')).version as string;
 
@@ -28,7 +27,10 @@ export class Mog {
     });
 
     try {
-      this.db = this.client.db(options.db, options.dbOptions);
+      this.db = this.client.db();
+      this.client.connect().then(() => {
+        this.db = this.client.db(options.db, options.dbOptions);
+      });
     } catch (error) {
       throw error;
     }