feat: add some methods

sourcecode71 · sourcecode71 · commit 5a25de121acf · 2025-05-12T15:34:33.000+06:00
diff --git a/src/logger/domain/interfaces/log-repository.interface.ts b/src/logger/domain/interfaces/log-repository.interface.ts
@@ -9,6 +9,15 @@ export interface ILogRepository {
     context: string | undefined,
     page: number,
     limit: number,
-  ): Promise<{ logs: Logger[]; total: number }>;
+  ): Promise<{
+    length: number;
+    logs: Logger[];
+    total: number;
+  }>;
   saveLog(log: LogEntryDto): Promise<Logger>; // Fix: Return `Logger` and use camelCase param
+  deleteLogById(_id: string): Promise<void>; // Fix: Use camelCase param
+  getLogStats(
+    level: string | undefined,
+    context: string | undefined,
+  ): Promise<any>; // Fix: Return `any` and use camelCase params
 }
diff --git a/src/logger/infrastructure/repositories/log.repository.ts b/src/logger/infrastructure/repositories/log.repository.ts
@@ -11,7 +11,6 @@ export class LogRepository implements ILogRepository {
     @InjectModel(Logger.name)
     private readonly loggerModel: Model<Logger>,
   ) {}
-
   async findLogById(_id: string): Promise<Logger | null> {
     try {
       return await this.loggerModel.findById(_id).lean().exec();
@@ -20,37 +19,6 @@ export class LogRepository implements ILogRepository {
       throw new Error('Failed to retrieve log');
     }
   }
-
-  async findLogsByFilter(
-    level: string,
-    context: string | undefined,
-    page: number,
-    limit: number,
-  ): Promise<{ logs: Logger[]; total: number }> {
-    try {
-      const filter: { level: string; context?: string } = { level };
-
-      if (context) {
-        filter.context = context;
-      }
-
-      const [logs, total] = await Promise.all([
-        this.loggerModel
-          .find(filter)
-          .sort({ timestamp: -1 }) // Newest first
-          .skip((page - 1) * limit)
-          .limit(limit)
-          .lean()
-          .exec(),
-        this.loggerModel.countDocuments(filter).exec(),
-      ]);
-
-      return { logs, total };
-    } catch (error) {
-      console.error('Error finding logs by filter:', error);
-      throw new Error('Failed to retrieve logs');
-    }
-  }
   async saveLog(log: LogEntryDto): Promise<Logger> {
     try {
       const logEntry = new this.loggerModel(log);
@@ -61,4 +29,75 @@ export class LogRepository implements ILogRepository {
       throw new Error('Failed to save log');
     }
   }
+  findLogsByFilter(
+    _level: string,
+    _context: string | undefined,
+    _page: number,
+    _limit: number,
+  ): Promise<{ length: number; logs: Logger[]; total: number }> {
+    const filter: { [key: string]: string } = {};
+    if (_level) {
+      filter.level = _level;
+    }
+    if (_context) {
+      filter.context = _context;
+    }
+    const skip = (_page - 1) * _limit;
+    return this.loggerModel
+      .find(filter)
+      .skip(skip)
+      .limit(_limit)
+      .lean()
+      .exec()
+      .then(async (logs) => {
+        const total = await this.loggerModel.countDocuments(filter);
+        return {
+          length: logs.length,
+          logs,
+          total,
+        };
+      })
+      .catch((error) => {
+        console.error('Error finding logs by filter:', error);
+        throw new Error('Failed to retrieve logs');
+      });
+  }
+  async deleteLogById(_id: string): Promise<void> {
+    try {
+      await this.loggerModel.findByIdAndDelete(_id).exec();
+    } catch (error) {
+      console.error('Error deleting log by ID:', error);
+      throw new Error('Failed to delete log');
+    }
+  }
+  getLogStats(
+    _level: string | undefined,
+    _context: string | undefined,
+  ): Promise<any> {
+    const filter: { [key: string]: string } = {};
+    if (_level) {
+      filter.level = _level;
+    }
+    if (_context) {
+      filter.context = _context;
+    }
+    return this.loggerModel
+      .aggregate([
+        { $match: filter },
+        {
+          $group: {
+            _id: {
+              level: '$_level',
+              context: '$_context',
+            },
+            count: { $sum: 1 },
+          },
+        },
+      ])
+      .exec()
+      .catch((error) => {
+        console.error('Error getting log stats:', error);
+        throw new Error('Failed to retrieve log stats');
+      });
+  }
 }
diff --git a/src/logger/services/logger.service.db.ts b/src/logger/services/logger.service.db.ts
@@ -37,4 +37,19 @@ export class LoggerServiceDb {
     }
     return log;
   }
+
+  async deleteLogById(id: string) {
+    const log = await this.logRepository.findLogById(id);
+    if (!log) {
+      throw new Error(`Log with ID: ${id} not found`);
+    }
+    await this.logRepository.deleteLogById(id);
+  }
+
+  async getLogStats(
+    level: string | undefined,
+    context: string | undefined,
+  ): Promise<any> {
+    return await this.logRepository.getLogStats(level, context);
+  }
 }
diff --git a/src/notification/domain/interfaces/notification-repository.interface.ts b/src/notification/domain/interfaces/notification-repository.interface.ts
@@ -16,4 +16,6 @@ export interface INotificationRepository {
   findById(id: string): Promise<Notification | null>;
 
   findAll(skip: number, limit: number): Promise<Notification[]>;
+
+  deleteById(id: string): Promise<void>;
 }
diff --git a/src/notification/infrastructure/repositories/notification.repository.ts b/src/notification/infrastructure/repositories/notification.repository.ts
@@ -11,7 +11,6 @@ export class NotificationRepository implements INotificationRepository {
     @InjectModel('Notification')
     private readonly notificationModel: Model<NotificationDocument>,
   ) {}
-
   findById(id: string): Promise<Notification | null> {
     throw new Error(`Method not implemented. ID: ${id}`);
   }
@@ -30,6 +29,10 @@ export class NotificationRepository implements INotificationRepository {
     return this.toEntity(saved);
   }
 
+  async deleteById(id: string): Promise<void> {
+    await this.notificationModel.findByIdAndDelete(id).exec();
+  }
+
   private toEntity(doc: NotificationDocument): Notification {
     return new Notification(
       doc.recipient,
diff --git a/src/notification/presentation/controllers/log.controller.ts b/src/notification/presentation/controllers/log.controller.ts
@@ -1,6 +1,22 @@
-import { Controller, Get, HttpStatus, Param, Query } from '@nestjs/common';
+import {
+  Controller,
+  Get,
+  HttpStatus,
+  Param,
+  Query,
+  Delete,
+  HttpCode,
+  NotFoundException,
+  BadRequestException,
+} from '@nestjs/common';
+import {
+  ApiOperation,
+  ApiResponse,
+  ApiQuery,
+  ApiTags,
+  ApiParam,
+} from '@nestjs/swagger';
 import { LoggerServiceDb } from '../../../logger/services/logger.service.db';
-import { ApiOperation, ApiResponse, ApiQuery, ApiTags } from '@nestjs/swagger';
 
 @ApiTags('Logs')
 @Controller('api/logs')
@@ -35,14 +51,28 @@ export class LogController {
     type: Number,
     description: 'Items per page (default: 10)',
   })
-  getLogs(
+  async 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;
+    const logsResult = await this.logService.getLogsByFilter(
+      level,
+      context,
+      page,
+      limit,
+    );
+    const logs: unknown = logsResult;
+    if (!Array.isArray(logs)) {
+      throw new BadRequestException('Logs result is not an array');
+    }
+    return {
+      data: logs,
+      total: logs.length,
+      page,
+      totalPages: Math.ceil(logs.length / limit),
+    };
   }
 
   @Get(':id')
@@ -51,10 +81,92 @@ export class LogController {
     status: HttpStatus.OK,
     description: 'Log retrieved successfully',
   })
+  @ApiParam({
+    name: 'id',
+    type: String,
+    description: 'Log ID',
+  })
+  @ApiResponse({
+    status: 404,
+    description: 'Log not found',
+  })
   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
+    if (!log) {
+      throw new NotFoundException(`Log with ID ${id} not found`);
+    }
     return { data: log };
   }
+
+  @Delete(':id')
+  @HttpCode(HttpStatus.NO_CONTENT)
+  @ApiOperation({ summary: 'Delete a specific log by ID' })
+  @ApiParam({
+    name: 'id',
+    type: String,
+    description: 'Log ID',
+  })
+  @ApiResponse({
+    status: 204,
+    description: 'Log deleted successfully',
+  })
+  @ApiResponse({
+    status: 404,
+    description: 'Log not found',
+  })
+  async deleteLogById(@Param('id') id: string): Promise<void> {
+    const log = await this.logService.getLogById(id);
+    if (!log) {
+      throw new NotFoundException(`Log with ID ${id} not found`);
+    }
+    await this.logService.deleteLogById(id);
+  }
+
+  @Delete()
+  @HttpCode(HttpStatus.NO_CONTENT)
+  @ApiOperation({ summary: 'Delete logs by filter' })
+  @ApiQuery({
+    name: 'level',
+    required: true,
+    description: 'Log level (e.g., info, error)',
+  })
+  @ApiQuery({
+    name: 'context',
+    required: false,
+    description: 'Context (e.g., NotificationController)',
+  })
+  @ApiResponse({
+    status: 204,
+    description: 'Logs deleted successfully',
+  })
+  @ApiResponse({
+    status: 400,
+    description: 'No logs found for the given filter',
+  })
+  @Get('stats')
+  @ApiOperation({ summary: 'Get log statistics' })
+  @ApiResponse({
+    status: HttpStatus.OK,
+    description: 'Log statistics retrieved successfully',
+  })
+  @ApiQuery({
+    name: 'level',
+    required: false,
+    description: 'Filter by log level (e.g., info, error)',
+  })
+  @ApiQuery({
+    name: 'context',
+    required: false,
+    description: 'Filter by context (e.g., NotificationController)',
+  })
+  async getLogStats(
+    @Query('level') level?: string,
+    @Query('context') context?: string,
+  ): Promise<{ data: Record<string, unknown> }> {
+    const stats = (await this.logService.getLogStats(level, context)) as Record<
+      string,
+      unknown
+    >;
+    return { data: stats };
+  }
 }
diff --git a/src/notification/presentation/controllers/notification.controller.ts b/src/notification/presentation/controllers/notification.controller.ts

Original file line number	Diff line number	Diff line change
`@@ -16,4 +16,6 @@ export interface INotificationRepository {`
`16`	`16`	`findById(id: string): Promise<Notification \| null>;`
`17`	`17`
`18`	`18`	`findAll(skip: number, limit: number): Promise<Notification[]>;`
	`19`	`+`
	`20`	`+ deleteById(id: string): Promise<void>;`
`19`	`21`	`}`