Merge pull request #62 from call-0f-code/monitoring/logger

Add logger utility and integrate with error handling and request logging

Author: i-am-that-guy

bun.lock

@@ -52,6 +52,7 @@
     "@supabase/supabase-js": "^2.50.5",
     "@types/cors": "^2.8.19",
     "@types/express": "^5.0.3",
+    "@types/morgan": "^1.9.10",
     "@types/multer": "^2.0.0",
     "@types/node": "^24.0.13",
     "@types/uuid": "^10.0.0",
@@ -62,10 +63,12 @@
     "express": "^5.1.0",
     "husky": "^9.1.7",
     "jest": "^30.0.4",
+    "morgan": "^1.10.1",
     "multer": "^2.0.1",
     "ts-jest": "^29.4.0",
     "ts-node": "^10.9.2",
-    "uuid": "^11.1.0"
+    "uuid": "^11.1.0",
+    "winston": "^3.19.0"
   },
   "private": true
 }

package.json

@@ -7,16 +7,21 @@ import { errorHandler } from "./utils/apiError";
 import { createClient } from "@supabase/supabase-js";
 import config from "./config";
 import path from "path";
-
+import { logger } from "./utils/logger";
+import morgan from "morgan";
 // Initialize Supabase client for storage operations
 export const supabase = createClient(
   config.SUPABASE_URL,
   config.SUPABASE_SERVICE_ROLE_KEY,
 );
 
 const app = express();
-
-
+class LoggerStream {
+    write(message: string) {
+        logger.info(message.substring(0, message.lastIndexOf('\n')));
+    }
+}
+app.use(morgan('combined', { stream: new LoggerStream()}));
 app.use(
   cors({
     origin: config.ALLOWED_ORIGINS || "*",

src/app.ts

@@ -1,5 +1,5 @@
 import { Request, Response, NextFunction } from "express";
-
+import { logger } from "./logger";
 /**
  * A custom error type that carries an HTTP status code.
  */
@@ -40,7 +40,7 @@ export function errorHandler(
     error: true,
     message,
   };
-
+  logger.error('ERROR 🔥', err);
   // Include stack trace in development for debugging
   if (process.env.NODE_ENV === "development" && err instanceof Error) {
     responseBody.stack = err.stack;

src/utils/apiError.ts

@@ -0,0 +1,25 @@
+import winston from 'winston';
+
+ const logger = winston.createLogger({
+  level: "http",
+  format: winston.format.combine(
+    winston.format.timestamp(),
+    winston.format.json()
+  ),
+  transports: [
+    new winston.transports.Console({
+      format: winston.format.combine(
+        winston.format.colorize(),
+        winston.format.simple()
+      )
+    })
+  ]
+});
+
+logger.stream = {
+  write: (message: any) => {
+    logger.info(message.trim());
+  }
+} as any;
+
+export { logger };