fix: added the logger controller

Author: sourcecode71

src/logger/domain/interfaces/log-repository.interface.ts

@@ -1,4 +1,11 @@
 export interface ILogRepository {
+  findLogById(_id: string): any;
+  findLogsByFilter(
+    level: string,
+    context: string | undefined,
+    page: number,
+    limit: number,
+  ): Promise<any[]>;
   saveLog(log: {
     level: string;
     message: string;

src/logger/infrastructure/repositories/log.repository.ts

@@ -10,6 +10,26 @@ export class LogRepository implements ILogRepository {
     @InjectModel(Logger.name)
     private readonly loggerModel: Model<Logger>,
   ) {}
+  async findLogById(_id: string): Promise<Logger | null> {
+    return await this.loggerModel.findById(_id).exec();
+  }
+  async findLogsByFilter(
+    level: string,
+    context: string | undefined,
+    page: number,
+    limit: number,
+  ): Promise<any[]> {
+    const filter: { level: string; context?: string } = { level };
+    if (context) {
+      filter.context = context;
+    }
+    const logs = await this.loggerModel
+      .find(filter)
+      .skip((page - 1) * limit)
+      .limit(limit)
+      .exec();
+    return logs;
+  }
 
   async saveLog(log: {
     level: string;

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

@@ -25,4 +25,31 @@ export class LoggerServiceDb {
       timestamp: new Date(),
     });
   }
+  async getLogsByFilter(
+    level: string,
+    context: string | undefined,
+    page: number,
+    limit: number,
+  ) {
+    const logs = await this.logRepository.findLogsByFilter(
+      level,
+      context,
+      page,
+      limit,
+    );
+    if (!logs || logs.length === 0) {
+      throw new Error(
+        `No logs found. Level: ${level}, Context: ${context}, Page: ${page}, Limit: ${limit}`,
+      );
+    }
+    // eslint-disable-next-line @typescript-eslint/no-unsafe-return
+    return logs;
+  }
+  async getLogById(id: string) {
+    const log = await this.logRepository.findLogById(id);
+    if (!log) {
+      throw new Error(`Log with ID: ${id} not found`);
+    }
+    return log;
+  }
 }

src/notification/notification.module.ts

@@ -1,6 +1,7 @@
 import { Module } from '@nestjs/common';
 import { MongooseModule } from '@nestjs/mongoose';
 import { NotificationController } from './presentation/controllers/notification.controller';
+import { LogController } from './presentation/controllers/log.controller';
 import { NotificationRepository } from './infrastructure/repositories/notification.repository';
 import { NotificationSchema } from './infrastructure/persistence/mongoose/notification.schema';
 import { NotificationFactory } from './application/factories/notification.factory';
@@ -15,7 +16,7 @@ import { LoggerModule } from '../logger/logger.module';
     ]),
     LoggerModule,
   ],
-  controllers: [NotificationController],
+  controllers: [NotificationController, LogController],
   providers: [
     {
       provide: 'INotificationRepository',

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

@@ -0,0 +1,60 @@
+import { Controller, Get, HttpStatus, Param, Query } from '@nestjs/common';
+import { LoggerServiceDb } from '../../../logger/services/logger.service.db';
+import { ApiOperation, ApiResponse, ApiQuery, ApiTags } from '@nestjs/swagger';
+
+@ApiTags('Logs')
+@Controller('api/logs')
+export class LogController {
+  constructor(private readonly logService: LoggerServiceDb) {}
+
+  @Get()
+  @ApiOperation({ summary: 'Get logs by filter' })
+  @ApiResponse({
+    status: HttpStatus.OK,
+    description: 'Logs retrieved successfully',
+  })
+  @ApiQuery({
+    name: 'level',
+    required: true,
+    description: 'Log level (e.g., info, error)',
+  })
+  @ApiQuery({
+    name: 'context',
+    required: false,
+    description: 'Context (e.g., NotificationController)',
+  })
+  @ApiQuery({
+    name: 'page',
+    required: false,
+    type: Number,
+    description: 'Page number (default: 1)',
+  })
+  @ApiQuery({
+    name: 'limit',
+    required: false,
+    type: Number,
+    description: 'Items per page (default: 10)',
+  })
+  getLogs(
+    @Query('level') level: string,
+    @Query('context') context?: string,
+    @Query('page') page = 1,
+    @Query('limit') limit = 10,
+  ) {
+    const logs = this.logService.getLogsByFilter(level, context, page, limit);
+    return logs;
+  }
+
+  @Get(':id')
+  @ApiOperation({ summary: 'Get log by ID' })
+  @ApiResponse({
+    status: HttpStatus.OK,
+    description: 'Log retrieved successfully',
+  })
+  async getLogById(@Param('id') id: string) {
+    // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment
+    const log = await this.logService.getLogById(id);
+    // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment
+    return { data: log };
+  }
+}

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

@@ -5,8 +5,16 @@ import {
   HttpCode,
   HttpStatus,
   Inject,
+  Get,
+  Query,
 } from '@nestjs/common';
-import { ApiTags, ApiOperation, ApiResponse, ApiBody } from '@nestjs/swagger';
+import {
+  ApiTags,
+  ApiOperation,
+  ApiResponse,
+  ApiBody,
+  ApiQuery,
+} from '@nestjs/swagger';
 import { NotificationFactory } from '../../application/factories/notification.factory';
 import { NotificationValidator } from '../../application/validators/notification.validator';
 import { SendNotificationDto } from '../dtos/send-notification.dto';
@@ -15,10 +23,12 @@ import { INotificationStrategy } from '../../domain/interfaces/notification-stra
 import { INotificationRepository } from '../../domain/interfaces/notification-repository.interface';
 import { LoggerServiceFile } from '../../../logger/services/logger.service.file';
 import { LoggerServiceDb } from '../../../logger/services/logger.service.db';
+import { number } from 'joi';
 
 @ApiTags('Notifications')
 @Controller('api/notifications')
 export class NotificationController {
+  notificationModel: import('mongoose').Model<Notification>;
   constructor(
     private readonly notificationFactory: NotificationFactory,
     @Inject('INotificationRepository')
@@ -76,4 +86,40 @@ export class NotificationController {
     );
     await this.loggerDb.error(`Exception occurred while sending notification`);
   }
+  @Get('history')
+  @ApiResponse({
+    status: HttpStatus.OK,
+    description: 'Notification history retrieved',
+  })
+  @ApiQuery({
+    name: 'page',
+    required: false,
+    type: Number,
+    description: 'Page number (default: 1)',
+  })
+  @ApiQuery({
+    name: 'limit',
+    required: false,
+    type: Number,
+    description: 'Items per page (default: 10)',
+  })
+  async getNotificationHistory(
+    @Query('page') page = 1,
+    @Query('limit') limit = 10,
+  ) {
+    const skip = (page - 1) * limit;
+    const notifications = await this.notificationModel
+      .find()
+      .sort({ createdAt: -1 })
+      .skip(skip)
+      .limit(limit)
+      .exec();
+    const total = await this.notificationModel.countDocuments().exec();
+    return {
+      data: notifications,
+      total: number,
+      page: number,
+      totalPages: Math.ceil(total / limit),
+    };
+  }
 }