2.0.36

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pushrocks/smartlog",
-  "version": "2.0.28",
+  "version": "2.0.36",
   "private": false,
   "description": "minimalistic distributed and extensible logging tool",
   "keywords": [
@@ -22,17 +22,17 @@
   },
   "devDependencies": {
     "@gitzone/tsbuild": "^2.1.24",
+    "@gitzone/tsbundle": "^1.0.72",
     "@gitzone/tsrun": "^1.2.12",
-    "@gitzone/tstest": "^1.0.33",
+    "@gitzone/tstest": "^1.0.43",
-    "@pushrocks/tapbundle": "^3.2.1",
+    "@pushrocks/tapbundle": "^3.2.9",
-    "@types/node": "^14.0.11",
+    "@types/node": "^14.0.27",
-    "tslint": "^6.1.2",
+    "tslint": "^6.1.3",
     "tslint-config-prettier": "^1.18.0"
   },
   "dependencies": {
-    "@gitzone/tsbundle": "^1.0.69",
     "@pushrocks/isounique": "^1.0.4",
-    "@pushrocks/smartlog-interfaces": "^2.0.18"
+    "@pushrocks/smartlog-interfaces": "^2.0.20"
   },
   "files": [
     "ts/**/*",

test/test.ts

@@ -40,4 +40,9 @@ tap.test('should create a log group', async () => {
   logGroup.log('info', 'this is logged from a log group');
 });
 
+tap.test('should catch error', async () => {
+  console.error(new Error('hey'));
+  // throw new Error('hey');
+});
+
 tap.start();

ts/smartlog.classes.consolelog.ts

@@ -4,7 +4,12 @@ import * as plugins from './smartlog.plugins';
  * a console log optimized for smartlog
  */
 export class ConsoleLog {
-  public log(logLevelArg: plugins.smartlogInterfaces.TLogLevel, logMessageArg: string) {
+  public log(
+    logLevelArg: plugins.smartlogInterfaces.TLogLevel,
+    logMessageArg: string,
+    dataArg?: any,
+    correlationArg?: plugins.smartlogInterfaces.ILogCorrelation
+  ) {
     console.log(`__# ${logLevelArg}: ${logMessageArg}`);
   }
 }

ts/smartlog.classes.logrouter.ts

@@ -15,9 +15,9 @@ export class LogRouter {
   }
 
   // routes the log according to added logDestinations
-  routeLog(logPackageArg: ILogPackage) {
+  public async routeLog(logPackageArg: ILogPackage) {
     for (const logDestination of this.logDestinations) {
-      logDestination.handleLog(logPackageArg);
+      await logDestination.handleLog(logPackageArg);
     }
   }
 }

ts/smartlog.classes.smartlog.ts

@@ -37,19 +37,33 @@ export class Smartlog implements plugins.smartlogInterfaces.ILogDestination {
   public enableConsole(optionsArg?: { captureAll: boolean }) {
     if (process && optionsArg && optionsArg.captureAll) {
       const write = process.stdout.write;
-      /* import * as fs from 'fs';
+     
-      const fileStream = fs.createWriteStream(plugins.path.join(paths.nogitDir, 'output.txt'), {
-        flags: 'a+'
-      }); */
       process.stdout.write = (...args) => {
-        if (!args[0].startsWith('LOG')) {
+        const logString: string = args[0];
-          this.log('info', args[0]);
+        if (!logString.startsWith('LOG') && typeof logString === 'string') {
+          switch(true) {
+            case logString.substr(0, 20).includes('Error:'):
+              this.log('error', logString);
+              break;
+            default:
+              this.log('info', logString);
+          }
           return;
         }
         // fileStream.write(args[0]);
         write.apply(process.stdout, args);
         return true;
       };
+
+      process.stderr.write = (...args) => {
+        if (!args[0].startsWith('LOG')) {
+          this.log('error', args[0]);
+          return;
+        }
+        // fileStream.write(args[0]);
+        write.apply(process.stderr, args);
+        return true;
+      };
     }
     this.consoleEnabled = true;
   }
@@ -64,7 +78,7 @@ export class Smartlog implements plugins.smartlogInterfaces.ILogDestination {
    * @param logDataArg - any additional log data
    * @param correlationArg - info about corrleations
    */
-  public log(
+  public async log(
     logLevelArg: plugins.smartlogInterfaces.TLogLevel,
     logMessageArg: string,
     logDataArg?: any,
@@ -94,7 +108,7 @@ export class Smartlog implements plugins.smartlogInterfaces.ILogDestination {
     if (logDataArg) {
       logPackage.data = logDataArg;
     }
-    this.logRouter.routeLog(logPackage);
+    await this.logRouter.routeLog(logPackage);
   }
 
   public increment(
@@ -119,8 +133,8 @@ export class Smartlog implements plugins.smartlogInterfaces.ILogDestination {
     });
   }
 
-  public handleLog(logPackageArg: plugins.smartlogInterfaces.ILogPackage) {
+  public async handleLog(logPackageArg: plugins.smartlogInterfaces.ILogPackage) {
-    this.logRouter.routeLog(logPackageArg);
+    await this.logRouter.routeLog(logPackageArg);
   }
 
   private safeConsoleLog(logLine: string) {