feat(logging): human-readable console logs and cleaner plugin errors

api/utils/log.js

@@ -1,5 +1,14 @@
 const pino = require('pino');
 
+// Optional pino-pretty import for human-readable console output
+let pinoPretty;
+try {
+    pinoPretty = require('pino-pretty');
+}
+catch (e) {
+    // pino-pretty not available, will use JSON output
+}
+
 // Optional OpenTelemetry imports
 let trace;
 let context;
@@ -207,7 +216,12 @@ class LogManager {
         this.#prefs = loadLoggingConfig();
         this.#prefs.default = this.#prefs.default || 'warn';
         this.#deflt = this.#prefs.default || 'error';
-        this.#prettyPrint = this.#prefs.prettyPrint || false;
+        // Output format determined by: explicit config > environment detection
+        // - prettyPrint: true  → always pretty (human-readable)
+        // - prettyPrint: false → always JSON (for log aggregation)
+        // - prettyPrint: unset → auto-detect (pretty in terminal/CI, JSON in Docker/PM2/pipes)
+        const isInteractive = process.stdout.isTTY || !!process.env.CI;
+        this.#prettyPrint = this.#prefs.prettyPrint ?? isInteractive;
 
         // Initialize OpenTelemetry metrics if available
         if (metrics) {
@@ -306,22 +320,19 @@ class LogManager {
     }
 
     /**
-     * Gets or creates the pretty transport singleton
-     * @returns {Object|null} The pretty transport or null
+     * Gets or creates the pretty stream singleton
+     * @returns {Object|null} The pretty stream or null
      */
     getPrettyTransport() {
-        if (!this.#prettyPrint) {
+        if (!this.#prettyPrint || !pinoPretty) {
             return null;
         }
 
         if (!this.#prettyTransport) {
-            this.#prettyTransport = pino.transport({
-                target: 'pino-pretty',
-                options: {
-                    colorize: true,
-                    translateTime: 'SYS:standard',
-                    ignore: 'pid,hostname'
-                }
+            this.#prettyTransport = pinoPretty({
+                colorize: true,
+                translateTime: 'SYS:HH:MM:ss.l',
+                ignore: 'pid,hostname'
             });
         }
         return this.#prettyTransport;

package.json

@@ -54,6 +54,7 @@
     "@types/underscore": "^1.13.0",
     "@typescript-eslint/eslint-plugin": "^8.54.0",
     "@typescript-eslint/parser": "^8.54.0",
+    "debug": "^4.4.3",
     "docdash": "^2.0.1",
     "env-cmd": "^10.1.0",
     "eslint": "^8.56.0",

plugins/pluginManager.ts

@@ -191,6 +191,7 @@ const async: any = require('async');
 const _: any = require('underscore');
 const crypto: typeof import('crypto') = require('crypto');
 const BluebirdPromise: any = require('bluebird');
+const debug: any = require('debug');
 const log: LogModule = require('../api/utils/log.js');
 const logDbRead: Logger = log('db:read');
 const logDbWrite: Logger = log('db:write');
@@ -199,6 +200,7 @@ const exec: typeof cp.exec = cp.exec;
 const spawn: typeof cp.spawn = cp.spawn;
 const configextender: ConfigExtenderFn = require('../api/configextender');
 
+const d = debug('countly:pluginManager');
 // ============================================================
 // INTERNAL INTERFACES (used within this module only)
 // ============================================================
@@ -436,9 +438,9 @@ class PluginManager {
                 }
             }
             catch (ex: any) {
-                console.log('Skipping plugin ' + pluginNames[i] + ' as we could not load it because of errors.');
-                console.error(ex.stack);
-                console.log('Saving this plugin as disabled in db');
+                const errorLine = (ex.message || '').split('\n')[0];
+                console.log('Skipping plugin ' + pluginNames[i] + ': ' + errorLine);
+                d('Plugin %s load error:\n%s', pluginNames[i], ex.stack);
             }
         }
     }
@@ -1272,8 +1274,9 @@ class PluginManager {
                 }
             }
             catch (ex: any) {
-                console.log('skipping plugin because of errors:' + pluginNames[i]);
-                console.error(ex.stack);
+                const errorLine = (ex.message || '').split('\n')[0];
+                console.log('Skipping plugin ' + pluginNames[i] + ': ' + errorLine);
+                d('Plugin %s load error:\n%s', pluginNames[i], ex.stack);
             }
         }
     }