feat(cache): database connection cache

rxdi · Apr 23, 2024 · faf3b6c · faf3b6c
1 parent 4e9bcb3
commit faf3b6c
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 1 deletion.
diff --git a/src/injection.tokens.ts b/src/injection.tokens.ts
@@ -36,6 +36,7 @@ export interface BundlerConfig {
 
 export interface Config {
   database: {
+    _connection_cache?: MongoClient;
     connect?(): Promise<MongoClient>;
   };
   dateTimeFormat?: () => string;

diff --git a/src/services/migration/migration.service.ts b/src/services/migration/migration.service.ts
@@ -22,7 +22,13 @@ export class MigrationService {
   ) {}
 
   async connect() {
-    return this.configService.config.database.connect();
+    if (this.configService.config.database._connection_cache) {
+      return this.configService.config.database._connection_cache;
+    }
+
+    this.configService.config.database._connection_cache = await this.configService.config.database.connect();
+
+    return this.configService.config.database._connection_cache;
   }
 
   async up() {