feat(be): logger module

Author: krystxf

apps/backend/src/enums/log.enum.ts

@@ -9,5 +9,9 @@ export enum LogMessage {
     IMPORT_STOPS = "Import stops",
     REST = "REST",
     GRAPHQL = "GraphQL",
-    GRAPHQL_INTROSPECTION = "GraphQL - Introspection Query",
+}
+
+export enum RestLogStatus {
+    SUCCESS = "SUCCESS",
+    INVALID_REQUEST = "INVALID_REQUEST",
 }

apps/backend/src/modules/logger/logger.module.ts

@@ -0,0 +1,11 @@
+import { Global, Module } from "@nestjs/common";
+
+import { LoggerService } from "src/modules/logger/logger.service";
+
+@Global()
+@Module({
+    controllers: [],
+    providers: [LoggerService],
+    exports: [LoggerService],
+})
+export class LoggerModule {}

apps/backend/src/modules/logger/logger.service.ts

@@ -0,0 +1,74 @@
+import { ConsoleLogger, Injectable, Scope } from "@nestjs/common";
+import { Prisma } from "@prisma/client";
+
+import { LogMessage, LogType, RestLogStatus } from "src/enums/log.enum";
+import { PrismaService } from "src/modules/prisma/prisma.service";
+
+@Injectable({ scope: Scope.TRANSIENT })
+export class LoggerService extends ConsoleLogger {
+    private prisma = new PrismaService();
+
+    constructor() {
+        super();
+    }
+
+    async error(message: string, trace: string): Promise<void> {
+        try {
+            await this.prisma.log.create({
+                data: {
+                    type: LogType.ERROR,
+                    message,
+                    trace,
+                },
+            });
+        } catch (error) {
+            super.error("Failed to log error", error);
+        }
+
+        super.error(message, trace);
+    }
+
+    async createLog(
+        type: LogType,
+        message: LogMessage,
+        trace:
+            | Prisma.NullableJsonNullValueInput
+            | Prisma.InputJsonValue = Prisma.JsonNull,
+    ): Promise<void> {
+        try {
+            await this.prisma.log.create({
+                data: {
+                    type,
+                    message,
+                    trace,
+                },
+            });
+        } catch (error) {
+            super.error("Failed to log error", error);
+        }
+    }
+
+    async createRestLog(
+        endpoint: string,
+        duration: number,
+        querySearch: Record<string, string | string[]> | null = null,
+    ): Promise<void> {
+        await this.createLog(LogType.INFO, LogMessage.REST, {
+            endpoint,
+            duration,
+            status: RestLogStatus.SUCCESS,
+            querySearch,
+        });
+    }
+
+    async createRestErrorLog(
+        endpoint,
+        querySearch: Record<string, string | string[]> | null = null,
+    ): Promise<void> {
+        await this.createLog(LogType.INFO, LogMessage.REST, {
+            endpoint,
+            status: RestLogStatus.INVALID_REQUEST,
+            querySearch,
+        });
+    }
+}