Replace Winston Logger with Pino

packages/usdk/cli.js

@@ -116,6 +116,16 @@ const logger = LoggerFactory.getLogger();
   };
 });
 
+// Set up global error handling
+['uncaughtException', 'unhandledRejection'].forEach(event =>
+  process.on(event, (err, err2) => {
+    console.error('cli uncaught exception', err, err2);
+    console.log("A complete log of this run can be found in: \n", logger.getLogFilePath());
+    process.exit(1);
+  })
+);
+
+
 //
 
 const makeSupabase = (jwt) => makeAnonymousClient(env, jwt);
@@ -1373,7 +1383,8 @@ const handleError = async (fn) => {
     return await fn();
   } catch (err) {
     console.warn(err.stack);
-    process.exit(1);
+    console.log("A complete log of this run can be found in: \n", logger.getLogFilePath());
+    // process.exit(1);
   }
 };
 export const main = async () => {

packages/usdk/package.json

@@ -72,6 +72,8 @@
     "openai": "^4.56.0",
     "ora": "^8.1.1",
     "picocolors": "^1.0.1",
+    "pino": "^9.5.0",
+    "pino-pretty": "^13.0.0",
     "pretty-bytes": "^6.1.1",
     "queue-manager": "file:./packages/upstreet-agent/packages/queue-manager",
     "react-agents-wrangler": "file:./packages/upstreet-agent/packages/react-agents-wrangler",

packages/usdk/usdk.js

@@ -1,14 +1,6 @@
 #!/usr/bin/env -S node --no-warnings --experimental-wasm-modules
 import { main } from './cli.js';
 
-// Set up global error handling
-['uncaughtException', 'unhandledRejection'].forEach(event =>
-  process.on(event, (err, err2) => {
-    console.log('cli uncaught exception', err, err2);
-    process.exit(1);
-  })
-);
-
 // Execute CLI
 (async () => {
   try {

packages/usdk/util/logger/logger-factory.mjs

@@ -1,9 +1,10 @@
+import PinoLogger from "./logger-pino.mjs";
 import WinstonLogger
  from "./logger-winston.mjs";
 
 class LoggerFactory {
     static getLogger() {
-      return new WinstonLogger();
+      return new PinoLogger();
     }
   }
 

packages/usdk/util/logger/logger-pino.mjs

@@ -0,0 +1,76 @@
+// pino-logger.mjs
+import pino from 'pino';
+import { getLogDirectory } from '../path/index.mjs';
+import path from 'path';
+import { Logger } from './logger-interface.mjs';
+
+
+class PinoLogger extends Logger{
+    static instance = null;
+
+    constructor() {
+        super();
+        if (PinoLogger.instance) {
+            return PinoLogger.instance;
+        }
+        const currentDateTime = new Date().toISOString().replace(/[:.]/g, '-');
+        const currentModuleDir = getLogDirectory();
+        this.logFilePath = path.join(currentModuleDir, `log-${currentDateTime}.log`);
+
+        const transport = pino.transport({
+            targets: [
+                {
+                    target: 'pino-pretty',
+                    options: {
+                        destination: this.logFilePath,
+                        colorize: false,
+                        translateTime: 'SYS:standard',
+                        ignore: 'pid,hostname',
+                        singleLine: false,
+                    }
+                }
+            ],
+        });
+
+        this.logger = pino({
+            level: process.env.LOG_LEVEL || 'info',
+            timestamp: pino.stdTimeFunctions.isoTime,
+            formatters: {
+                level: (label) => {
+                    return { level: label.toUpperCase() };
+                }
+            },
+        }, transport);
+        PinoLogger.instance = this;
+    }
+
+    info(message, ...args) {
+        this.logger.info(message, ...args);
+    }
+
+    error(message, error = null) {
+        if (error) {
+            this.logger.error({ err: error }, message);
+        } else {
+            this.logger.error(message);
+        }
+    }
+
+    warn(message, ...args) {
+        this.logger.warn(message, ...args);
+    }
+
+    debug(message, ...args) {
+        this.logger.debug(message, ...args);
+    }
+
+    getChildLogger(bindings) {
+        return this.logger.child(bindings);
+    }
+
+    getLogFilePath() {
+        return this.logFilePath;
+    }
+}
+
+export default PinoLogger;

packages/usdk/util/logger/logger-winston.mjs

@@ -8,7 +8,7 @@ class WinstonLogger extends Logger {
     super();
     const currentDateTime = new Date().toISOString().replace(/[:.]/g, '-');
     const currentModuleDir = getLogDirectory();
-    const logFilePath = path.join(currentModuleDir, `log-${currentDateTime}.log`);
+    this.logFilePath = path.join(currentModuleDir, `log-${currentDateTime}.log`);
 
     this.logger = winston.createLogger({
       level: 'error',
@@ -19,7 +19,7 @@ class WinstonLogger extends Logger {
         })
       ),
       transports: [
-        new winston.transports.File({ filename: logFilePath, name: 'error-file', level: 'info'}),
+        new winston.transports.File({ filename: this.logFilePath, name: 'error-file', level: 'info'}),
         new winston.transports.Console()
       ]
     });
@@ -38,6 +38,10 @@ class WinstonLogger extends Logger {
   error(...args) {
     this.logger.error(...args);
   }
+
+  getLogFilePath() {
+    return this.logFilePath;
+  }
 }
 
 export default WinstonLogger;