Merge pull request #837 from Sanofi-IADC/feature/WEB-2246

fix: WEB-2246 added pool size option mongoose to handle memory

example.env

@@ -8,6 +8,7 @@ MONGOOSE_HOST = mongo1
 MONGOOSE_PORT = 27017
 MONGOOSE_USERNAME
 MONGOOSE_PASSWORD
+MONGOOSE_POOL_SIZE = 10
 
 REDIS_HOST = redis
 REDIS_PORT = 6379

example.rep.env

@@ -11,6 +11,7 @@ MONGOOSE_HOST_READ = mongo2
 MONGOOSE_PORT_READ = 27017
 MONGOOSE_USERNAME
 MONGOOSE_PASSWORD
+MONGOOSE_POOL_SIZE = 10
 
 REDIS_HOST = redis
 REDIS_PORT = 6379

src/app.module.ts

@@ -23,6 +23,7 @@ import { TagModule } from './tag/tag.module';
 import { HealthController } from './health/health.controller';
 import { AuthModule } from './auth/auth.module';
 import { GqlContext } from './auth/gql-context';
+import { DatabaseService } from './common/DatabaseService';
 
 @Module({
   imports: [
@@ -91,7 +92,7 @@ import { GqlContext } from './auth/gql-context';
     WebhookModule,
     AuthModule,
   ],
-  providers: [AppService],
+  providers: [AppService, DatabaseService],
   controllers: [AppController, HealthController],
 })
 export class AppModule {}

src/common/DatabaseService.ts

@@ -0,0 +1,13 @@
+import { Injectable, OnModuleDestroy } from '@nestjs/common';
+import { InjectConnection } from '@nestjs/mongoose';
+import { Connection } from 'mongoose';
+
+@Injectable()
+export class DatabaseService implements OnModuleDestroy {
+  constructor(@InjectConnection() private readonly connection: Connection) {}
+
+  async onModuleDestroy() {
+    await this.connection.close();
+    console.log('Mongoose connection closed');
+  }
+}

src/config/config.service.ts

@@ -73,6 +73,12 @@ export class ConfigService {
       readPreference: this.get('REPLICASET') !== undefined ? readPreference : null,
       user: this.get('MONGOOSE_USERNAME'),
       pass: this.get('MONGOOSE_PASSWORD'),
+      maxPoolSize: this.get('MONGOOSE_POOL_SIZE') || 20,
+      retryAttempts: 2,
+      connectTimeoutMS: 60000,
+      useUnifiedTopology: true,
+      useNewUrlParser: true,
+      socketTimeoutMS: 60000,
     };
     if (this.get('SSL_VALIDATE') === true) {
       options = {