Updates: Removed Pino, Added Winston (#605)

* Updates: Removed logs + queuedAt indexed

* Updates: Removed Pino, Added Winston

* updates add stack trace to console

Author: farhanW3

package.json

@@ -64,13 +64,12 @@
     "mnemonist": "^0.39.8",
     "node-cron": "^3.0.2",
     "pg": "^8.11.3",
-    "pino": "^8.15.1",
-    "pino-pretty": "^10.0.0",
     "prisma": "^5.14.0",
     "superjson": "^2.2.1",
     "thirdweb": "^5.45.1",
     "uuid": "^9.0.1",
     "viem": "^1.14.0",
+    "winston": "^3.14.1",
     "zod": "^3.23.8"
   },
   "devDependencies": {

src/utils/logger.ts

@@ -1,20 +1,57 @@
-import Pino, { LoggerOptions } from "pino";
+import { createLogger, format, transports } from "winston";
 import { env } from "./env";
 
-const defaultOptions: LoggerOptions = {
-  redact: ["headers.authorization"],
-  transport: {
-    target: "pino-pretty",
-    options: {
-      translateTime: "HH:MM:ss Z",
-      ignore: "pid,hostname,reqId",
-      singleLine: true,
-    },
-  },
-  level: env.LOG_LEVEL,
+// Custom filter for stdout transport
+const filterOnlyInfoAndWarn = format((info) => {
+  if (info.level === "error") {
+    return false; // Exclude 'error' level logs
+  }
+  return info;
+});
+
+// Custom filter for stderr transport
+const filterOnlyErrors = format((info) => {
+  if (info.level !== "error") {
+    return false; // Exclude non-error level logs
+  }
+  return info;
+});
+
+const colorizeFormat = () => {
+  if (env.NODE_ENV === "development") {
+    return format.colorize();
+  } else {
+    return format.uncolorize();
+  }
 };
 
-const pino = Pino(defaultOptions);
+const winstonLogger = createLogger({
+  level: env.LOG_LEVEL,
+  format: format.combine(
+    format.timestamp(),
+    format.errors({ stack: true }),
+    format.splat(),
+    colorizeFormat(),
+    format.printf(({ level, message, timestamp, error }) => {
+      if (error) {
+        return `[${timestamp}] ${level}: ${message} - ${error.stack}`;
+      }
+      return `[${timestamp}] ${level}: ${message}`;
+    }),
+  ),
+  transports: [
+    // Transport for stdout
+    new transports.Console({
+      format: format.combine(filterOnlyInfoAndWarn()),
+      stderrLevels: [], // Don't log "error" to stdout
+    }),
+    // Transport for stderr
+    new transports.Console({
+      format: format.combine(filterOnlyErrors()),
+      stderrLevels: ["error"], // Ensure errors go to stderr
+    }),
+  ],
+});
 
 interface LoggerParams {
   service: (typeof env)["LOG_SERVICES"][0];
@@ -46,9 +83,10 @@ export const logger = ({
   if (data) {
     suffix += ` - ${JSON.stringify(data)}`;
   }
+
   if (error) {
-    suffix += ` - ${error?.message || error}`;
+    winstonLogger.error(`${prefix}${message}${suffix}`, { error });
+  } else {
+    winstonLogger.log(level, `${prefix}${message}${suffix}`);
   }
-
-  return pino[level](`${prefix}${message}${suffix}`);
 };