Merge pull request #33 from elasticio/thread-logs

Using logger

Author: Igor Drobiazko

lib/actions/splitOnJsonata.js

@@ -20,7 +20,7 @@ async function processAction(msg, cfg) {
 
     const results = [];
     split.forEach((elem) => results.push(elem));
-    this.logger.debug('%s parts to emit found', results.length);
+    this.logger.info('Splitting the incoming message into %s messages', results.length);
     results.forEach(async (result) => {
         if (result) {
             await this.emit('data', messages.newMessageWithBody(result));

package-lock.json

@@ -17,7 +17,6 @@
   },
   "dependencies": {
     "@elastic.io/component-commons-library": "0.0.4",
-    "debug": "2.6.3",
     "elasticio-node": "0.0.9",
     "elasticio-sailor-nodejs": "2.5.1",
     "lodash": "4.17.4"

package.json

@@ -1,4 +1,3 @@
-const debug = require('debug')('splitter');
 const _ = require('lodash');
 const { messages } = require('elasticio-node');
 
@@ -7,8 +6,8 @@ async function processAction(msg, conf) {
     const splitting = conf.splitter || {};
     const body = msg.body || {};
 
-    debug('Received new message with body: %j', body);
-    debug('Config: %j', conf);
+    this.logger.debug('Received new message with body: %j', body);
+    this.logger.debug('Config: %j', conf);
 
     const split = splitting === '$' ? body : _.get(body, splitting);
 
@@ -32,11 +31,11 @@ async function processAction(msg, conf) {
     if (_.isArray(split)) {
         split.forEach((elem) => results.push(elem));
     } else if (_.isObject(split)) {
-        debug(`"${splitting}" is not an array. Returning the original object`);
+        this.logger.debug(`"${splitting}" is not an array. Returning the original object`);
         results.push(split);
     }
 
-    debug('%s parts to emit found', results.length);
+    this.logger.info('Splitting the incoming message into %s messages', results.length);
     results.forEach(async (result) => {
         if (result) {
             await this.emit('data', messages.newMessageWithBody(result));