feat: implement dual logging with LoggerServiceFile (Winston) for info and LoggerServiceDb (MongoDB) for errors

Author: sourcecode71

src/app.module.ts

@@ -1,28 +1,15 @@
 import { Module } from '@nestjs/common';
-import { MongooseModule, MongooseModuleOptions } from '@nestjs/mongoose';
+import { MongooseModule } from '@nestjs/mongoose';
 import { ConfigModule } from '@nestjs/config';
 import { NotificationModule } from './notification/notification.module';
 import { LoggerModule } from './logger/logger.module';
-import { LoggerService } from './logger/services/logger.service';
-import { Connection } from 'mongoose';
 
 @Module({
   imports: [
     ConfigModule.forRoot({ isGlobal: true }),
-    MongooseModule.forRootAsync({
-      imports: [LoggerModule],
-      useFactory: (logger: LoggerService) =>
-        ({
-          uri: 'mongodb://localhost:27017/smartedu',
-          connectionFactory: (connection: Connection) => {
-            connection.on('connected', () => {
-              logger.log('MongoDB connected successfully');
-            });
-            return connection;
-          },
-        }) as MongooseModuleOptions,
-      inject: [LoggerService],
-    }),
+    MongooseModule.forRoot(
+      process.env.MONGO_URI || 'mongodb://localhost:27017/smartedu',
+    ),
     NotificationModule,
     LoggerModule,
   ],

src/filters/all-exceptions.filter.ts

@@ -5,11 +5,11 @@ import {
   HttpException,
 } from '@nestjs/common';
 import { Request, Response } from 'express';
-import { LoggerService } from '../logger/services/logger.service';
+import { LoggerServiceFile } from '../logger/services/logger.service.file';
 
 @Catch()
 export class AllExceptionsFilter implements ExceptionFilter {
-  constructor(private readonly logger: LoggerService) {}
+  constructor(private readonly logger: LoggerServiceFile) {}
 
   catch(exception: unknown, host: ArgumentsHost) {
     const ctx = host.switchToHttp();

src/logger/logger.module.ts

@@ -1,6 +1,7 @@
 import { Module } from '@nestjs/common';
 import { MongooseModule } from '@nestjs/mongoose';
-import { LoggerService } from './services/logger.service';
+import { LoggerServiceFile } from './services/logger.service.file';
+import { LoggerServiceDb } from './services/logger.service.db';
 import { LogRepository } from './infrastructure/repositories/log.repository';
 import {
   Logger,
@@ -12,13 +13,14 @@ import {
     MongooseModule.forFeature([{ name: Logger.name, schema: LoggerSchema }]),
   ],
   providers: [
-    LoggerService,
+    LoggerServiceFile,
+    LoggerServiceDb,
     LogRepository,
     {
       provide: 'ILogRepository',
       useClass: LogRepository,
     },
   ],
-  exports: [LoggerService, 'ILogRepository', LogRepository],
+  exports: [LoggerServiceFile, LoggerServiceDb],
 })
 export class LoggerModule {}

src/logger/services/logger.service.db.ts

@@ -0,0 +1,28 @@
+import { Injectable, Inject } from '@nestjs/common';
+import { ILogRepository } from '../domain/interfaces/log-repository.interface';
+
+@Injectable()
+export class LoggerServiceDb {
+  constructor(
+    @Inject('ILogRepository') private readonly logRepository: ILogRepository,
+  ) {}
+
+  async error(
+    message: string,
+    trace?: string,
+    metadata?: {
+      recipient?: string;
+      notificationType?: string;
+      mediaType?: string;
+      context?: string;
+    },
+  ) {
+    await this.logRepository.saveLog({
+      level: 'error',
+      message,
+      trace,
+      metadata,
+      timestamp: new Date(),
+    });
+  }
+}

src/logger/services/logger.service.ts …c/logger/services/logger.service.file.tssrc/logger/services/logger.service.ts renamed to src/logger/services/logger.service.file.ts src/logger/services/logger.service.ts renamed to src/logger/services/logger.service.file.ts

@@ -3,7 +3,7 @@ import * as winston from 'winston';
 import 'winston-daily-rotate-file';
 
 @Injectable()
-export class LoggerService {
+export class LoggerServiceFile {
   private readonly logger: winston.Logger;
 
   constructor() {

src/main.ts

@@ -1,12 +1,14 @@
 import { NestFactory } from '@nestjs/core';
 import { AppModule } from './app.module';
 import { AllExceptionsFilter } from './filters/all-exceptions.filter';
-import { LoggerService } from './logger/services/logger.service';
+import { LoggerServiceFile } from './logger/services/logger.service.file';
+import { LoggerServiceDb } from './logger/services/logger.service.db';
 import { SwaggerModule, DocumentBuilder } from '@nestjs/swagger';
 
 async function bootstrap() {
   const app = await NestFactory.create(AppModule);
-  const logger = app.get(LoggerService);
+  const logger = app.get<LoggerServiceFile>(LoggerServiceFile);
+  //const loggerDb = app.get(LoggerServiceDb);
   app.useGlobalFilters(new AllExceptionsFilter(logger));
 
   // Configure Swagger
@@ -17,10 +19,19 @@ async function bootstrap() {
     .build();
   const document = SwaggerModule.createDocument(app, config);
   SwaggerModule.setup('api', app, document);
+  console.log('Running the application on port 3000');
 
   await app.listen(3000);
   logger.log('Application run successfully');
+  console.log('Swagger is running on: http://localhost:3000/api');
 }
-bootstrap().catch((error) => {
+
+bootstrap().catch(async (error: Error) => {
+  const app = await NestFactory.create(AppModule);
+  const loggerDb = app.get(LoggerServiceDb);
+  await loggerDb.error('Error during application bootstrap', error.stack, {
+    context: 'bootstrap',
+  });
   console.log('Error during application bootstrap:', error);
+  process.exit(1);
 });

src/notification/presentation/controllers/notification.controller.ts

@@ -13,7 +13,8 @@ import { SendNotificationDto } from '../dtos/send-notification.dto';
 import { Notification } from '../../domain/entities/notification.entity';
 import { INotificationStrategy } from '../../domain/interfaces/notification-strategy.interface';
 import { INotificationRepository } from '../../domain/interfaces/notification-repository.interface';
-import { LoggerService } from '../../../logger/services/logger.service';
+import { LoggerServiceFile } from '../../../logger/services/logger.service.file';
+import { LoggerServiceDb } from '../../../logger/services/logger.service.db';
 
 @ApiTags('Notifications')
 @Controller('api/notifications')
@@ -22,7 +23,8 @@ export class NotificationController {
     private readonly notificationFactory: NotificationFactory,
     @Inject('INotificationRepository')
     private readonly notificationRepository: INotificationRepository,
-    private readonly logger: LoggerService,
+    private readonly logger: LoggerServiceFile,
+    private readonly loggerDb: LoggerServiceDb,
   ) {}
 
   @Post()
@@ -61,15 +63,17 @@ export class NotificationController {
     // Send notification
     const strategy: INotificationStrategy =
       this.notificationFactory.createStrategy(dto.mediaType);
-    console.log('notification strategy is created');
     await strategy.send(notification);
 
+    console.log('notification strategy creation ended');
+
     // Save notification after successful send
     await this.notificationRepository.save(notification);
 
     // Log successful send
     this.logger.log(
       `Notification (${dto.notificationType}) sent to ${dto.recipient} via ${dto.mediaType}`,
     );
+    await this.loggerDb.error(`Exception occurred while sending notification`);
   }
 }