feat:add dto

Author: sourcecode71

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

@@ -1,21 +1,14 @@
+// src/domain/interfaces/log-repository.interface.ts
+import { LogEntryDto } from '../../infrastructure/persistence/dto/log-entry-dto';
+import { Logger } from '../../infrastructure/persistence/mongoose/logger.schema';
+
 export interface ILogRepository {
-  findLogById(_id: string): any;
+  findLogById(_id: string): Promise<Logger | null>;
   findLogsByFilter(
     level: string,
     context: string | undefined,
     page: number,
     limit: number,
-  ): Promise<any[]>;
-  saveLog(log: {
-    level: string;
-    message: string;
-    trace?: string;
-    metadata?: {
-      recipient?: string;
-      notificationType?: string;
-      mediaType?: string;
-      context?: string;
-    };
-    timestamp: Date;
-  }): Promise<void>;
+  ): Promise<{ logs: Logger[]; total: number }>;
+  saveLog(log: LogEntryDto): Promise<Logger>; // Fix: Return `Logger` and use camelCase param
 }

src/logger/infrastructure/persistence/dto/log-entry-dto.ts

@@ -0,0 +1,12 @@
+export interface LogEntryDto {
+  level: string;
+  message: string;
+  trace?: string;
+  metadata?: {
+    recipient?: string;
+    notificationType?: string;
+    mediaType?: string;
+    context?: string;
+  };
+  timestamp: Date;
+}

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

@@ -1,49 +1,64 @@
+import { Model } from 'mongoose';
 import { Injectable } from '@nestjs/common';
 import { InjectModel } from '@nestjs/mongoose';
-import { Model } from 'mongoose';
 import { ILogRepository } from '../../domain/interfaces/log-repository.interface';
 import { Logger } from '../persistence/mongoose/logger.schema';
+import { LogEntryDto } from '../persistence/dto/log-entry-dto';
 
 @Injectable()
 export class LogRepository implements ILogRepository {
   constructor(
     @InjectModel(Logger.name)
     private readonly loggerModel: Model<Logger>,
   ) {}
+
   async findLogById(_id: string): Promise<Logger | null> {
-    return await this.loggerModel.findById(_id).exec();
+    try {
+      return await this.loggerModel.findById(_id).lean().exec();
+    } catch (error) {
+      console.error('Error finding log by ID:', error);
+      throw new Error('Failed to retrieve log');
+    }
   }
+
   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;
+  ): 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');
     }
-    const logs = await this.loggerModel
-      .find(filter)
-      .skip((page - 1) * limit)
-      .limit(limit)
-      .exec();
-    return logs;
   }
-
-  async saveLog(log: {
-    level: string;
-    message: string;
-    trace?: string;
-    metadata?: {
-      recipient?: string;
-      notificationType?: string;
-      mediaType?: string;
-      context?: string;
-    };
-    timestamp: Date;
-  }): Promise<void> {
-    const logEntry = new this.loggerModel(log);
-    await logEntry.save();
+  async saveLog(log: LogEntryDto): Promise<Logger> {
+    try {
+      const logEntry = new this.loggerModel(log);
+      await logEntry.save();
+      return logEntry.toObject();
+    } catch (error) {
+      console.error('Error saving log:', error);
+      throw new Error('Failed to save log');
+    }
   }
 }

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

@@ -37,7 +37,7 @@ export class LoggerServiceDb {
       page,
       limit,
     );
-    if (!logs || logs.length === 0) {
+    if (!logs || logs.logs.length === 0) {
       throw new Error(
         `No logs found. Level: ${level}, Context: ${context}, Page: ${page}, Limit: ${limit}`,
       );