Added: Feature For load OpenAPIValidator Cache on app boot

beckn · Jun 18, 2024 · 049acd4 · 049acd4
1 parent 6d1f612
commit 049acd4
Showing 1 changed file with 43 additions and 32 deletions.
diff --git a/src/utils/mongo.utils.ts b/src/utils/mongo.utils.ts
@@ -2,41 +2,52 @@ import { Db, MongoClient } from "mongodb";
 import { Exception, ExceptionType } from "../models/exception.model";
 import logger from "./logger.utils";
 
-export class DBClient{
-    private db: Db;
-    private client: MongoClient;
-    public isConnected: boolean = false;
-
-    constructor(dbURL: string){
-        this.client = new MongoClient(dbURL, {
-            minPoolSize: 10,
-            maxPoolSize: 15,
-        });
-
-        this.db = this.client.db();
+export class DBClient {
+  private db: Db;
+  private client: MongoClient;
+  public isConnected: boolean = false;
+
+  constructor(dbURL: string) {
+    this.client = new MongoClient(dbURL, {
+      minPoolSize: 10,
+      maxPoolSize: 15
+    });
+
+    this.db = this.client.db();
+  }
+
+  public async connect(): Promise<void> {
+    try {
+      this.client = await this.client.connect();
+      this.db = this.client.db();
+      this.isConnected = true;
+      logger.info(`Mongo Client Connected For DB: ${this.db.databaseName}`);
+    } catch (error: any) {
+      console.log(error);
     }
-
-    public async connect(): Promise<void> {
-        this.client = await this.client.connect();
-        this.db = this.client.db();
-        this.isConnected = true;
-        logger.info(`Mongo Client Connected For DB: ${this.db.databaseName}`);
-    }
-
-    public getDB(): Db{
-        if(!this.isConnected){
-            throw new Exception(ExceptionType.Mongo_ClientNotInitialized, "Mongo client is not connected.", 500);
-        }
-
-        return this.db;
+  }
+
+  public getDB(): Db {
+    if (!this.isConnected) {
+      throw new Exception(
+        ExceptionType.Mongo_ClientNotInitialized,
+        "Mongo client is not connected.",
+        500
+      );
     }
 
-    public getClient(): MongoClient{
-        if(!this.isConnected){
-            throw new Exception(ExceptionType.Mongo_ClientNotInitialized, "Mongo client is not connected.", 500);
-        }
+    return this.db;
+  }
 
-        return this.client;
+  public getClient(): MongoClient {
+    if (!this.isConnected) {
+      throw new Exception(
+        ExceptionType.Mongo_ClientNotInitialized,
+        "Mongo client is not connected.",
+        500
+      );
     }
 
-}
+    return this.client;
+  }
+}