feat(database): add more database feature

Author: mikemajesty

src/infra/database/mongo/config.ts

@@ -1,11 +1,11 @@
 import 'dotenv/config';
 
-import { green } from 'colorette';
 import { mongoMigrateCli } from 'mongo-migrate-ts';
 import path from 'path';
 
-// eslint-disable-next-line no-console
-console.log(green(`ENV: ${process.env['NODE_ENV']} mongo migration running.\n`));
+import { LoggerService } from '@/infra/logger';
+
+LoggerService.log(`ENV: ${process.env['NODE_ENV']} mongo migration running.\n`);
 
 mongoMigrateCli({
   uri: process.env['MONGO_URL'],

src/infra/database/mongo/module.ts

@@ -42,6 +42,12 @@ import { MongoService } from './service';
             return connection;
           },
           uri: connection.uri,
+          useNewUrlParser: true,
+          useUnifiedTopology: true,
+          minPoolSize: 10,
+          serverSelectionTimeoutMS: 5000,
+          socketTimeoutMS: 5000,
+          readPreference: 'secondaryPreferred', // Per
           appName: name
         };
       },

src/infra/database/postgres/module.ts

@@ -26,7 +26,10 @@ import { PostgresService } from './service';
           entities: [path.join(__dirname, '/schemas/*.{ts,js}')],
           applicationName: name,
           extra: {
-            connectionTimeoutMillis: 10000
+            connectionTimeoutMillis: 10000,
+            idleTimeoutMillis: 30000,
+            max: 90,
+            min: 10
           }
         };
       },

src/infra/logger/service.ts

@@ -11,11 +11,18 @@ import { DateUtils } from '@/utils/date';
 import { ApiBadRequestException, ApiInternalServerException, BaseException } from '@/utils/exception';
 import { UUIDUtils } from '@/utils/uuid';
 
+import { name } from '../../../package.json';
 import { ILoggerAdapter } from './adapter';
 import { ErrorType, MessageType } from './types';
 
 @Injectable({ scope: Scope.REQUEST })
 export class LoggerService implements ILoggerAdapter {
+  static log(message: string) {
+    const timestamp = DateUtils.getDateStringWithFormat();
+    // eslint-disable-next-line no-console
+    console.log(`${gray('TRACE')} [${timestamp}]: [${blue(name)}] ${green(message)}`);
+  }
+
   private app!: string;
 
   logger!: HttpLogger;
@@ -44,7 +51,7 @@ export class LoggerService implements ILoggerAdapter {
   }
 
   log(message: string): void {
-    this.logger.logger.trace(green(message));
+    LoggerService.log(message);
   }
 
   debug({ message, context, obj = {} }: MessageType): void {

src/utils/decorators/log-execution-time.decorator.ts

@@ -2,6 +2,8 @@ import { performance } from 'node:perf_hooks';
 
 import { yellow } from 'colorette';
 
+import { LoggerService } from '@/infra/logger';
+
 export function LogExecutionTime(target: object, propertyKey: string, descriptor: PropertyDescriptor): void {
   const originalMethod = descriptor.value;
 
@@ -11,7 +13,7 @@ export function LogExecutionTime(target: object, propertyKey: string, descriptor
     const className = target.constructor.name;
     const methodName = propertyKey;
     const end = performance.now();
-    console.log(yellow(`Function ${className}/${methodName} took ${(end - start).toFixed(3)}ms to execute.`)); // eslint-disable-line no-console
+    LoggerService.log(yellow(`Function ${className}/${methodName} took ${(end - start).toFixed(3)}ms to execute.`));
     return result;
   };
 }

src/utils/tracing.ts

@@ -11,7 +11,9 @@ import { RedisInstrumentation } from '@opentelemetry/instrumentation-redis-4';
 import { Resource } from '@opentelemetry/resources';
 import { PeriodicExportingMetricReader } from '@opentelemetry/sdk-metrics';
 import { NodeSDK } from '@opentelemetry/sdk-node';
-import { green, red } from 'colorette';
+import { red } from 'colorette';
+
+import { LoggerService } from '@/infra/logger';
 
 import { name, version } from '../../package.json';
 import { getPathWithoutUUID } from './request';
@@ -83,8 +85,7 @@ const sdk = new NodeSDK({
 const start = () => {
   try {
     sdk.start();
-    // eslint-disable-next-line no-console
-    console.log(green('Tracing started.'));
+    LoggerService.log('Tracing started.');
   } catch (error) {
     console.error(red('Tracing start error '), error);
   }

test/containers.ts

@@ -10,7 +10,7 @@ import { SnakeNamingStrategy } from 'typeorm-naming-strategies';
 import { RedisService } from '@/infra/cache/redis';
 import { ConnectionName } from '@/infra/database/enum';
 import { PostgresService } from '@/infra/database/postgres';
-import { ILoggerAdapter } from '@/infra/logger';
+import { ILoggerAdapter, LoggerService } from '@/infra/logger';
 
 export class TestMongoContainer {
   mongoContainer!: StartedMongoDBContainer;
@@ -73,7 +73,7 @@ export class TestRedisContainer {
   client!: RedisClientType;
 
   getTestRedis = async (): Promise<RedisService> => {
-    const logger: ILoggerAdapter = { error: console.error, log: console.log } as ILoggerAdapter;
+    const logger: ILoggerAdapter = { error: console.error, log: LoggerService.log } as ILoggerAdapter;
     this.redisContainer = await new RedisContainer().start();
     this.client = createClient({ url: this.redisContainer.getConnectionUrl() }) as RedisClientType;
     await this.client.connect();