Autoformat files

Author: dvd-z

lib/actions/splitOnJsonata.js

@@ -1,9 +1,7 @@
-'use strict';
-
 const debug = require('debug')('splitter');
 const _ = require('lodash');
 const { JsonataTransform } = require('@elastic.io/component-commons-library');
-const messages = require('elasticio-node').messages;
+const { messages } = require('elasticio-node');
 
 /**
  * @this processAction
@@ -16,15 +14,15 @@ async function processAction(msg, cfg) {
         return;
     }
 
-    if (_.find(split, elem => !_.isObject(elem))) {
+    if (_.find(split, (elem) => !_.isObject(elem))) {
         await this.emit('error', new Error('Splitting arrays of objects only!'));
         return;
     }
 
     const results = [];
-    split.forEach(elem => results.push(elem));
+    split.forEach((elem) => results.push(elem));
     debug('%s parts to emit found', results.length);
-    for (let value of results) {
+    for (const value of results) {
         if (value) {
             await this.emit('data', messages.newMessageWithBody(value));
         }

spec/split/data/index.js

@@ -1,5 +1,3 @@
-'use strict';
-
 module.exports = {
     'should split array of objects users': require('./splitArrayOfObjects.json'),
     'should split array of arrays users.friends': require('./splitArrayOfArrays.json'),
@@ -10,5 +8,5 @@ module.exports = {
     'should emit error no such property users.emails': require('./noSuchPropertySplitting.json'),
     'should emit error for array of primitives userNames': require('./arrayOfPrimitives.json'),
     'should emit error when users is primitive': require('./primitiveValue.json'),
-    'should emit object when users is object': require('./objectValue.json')
+    'should emit object when users is object': require('./objectValue.json'),
 };

spec/split/split.spec.js

@@ -1,5 +1,4 @@
-'use strict';
-const expect = require('chai').expect;
+const { expect } = require('chai');
 const sinon = require('sinon');
 const splitter = require('../../split.js');
 const data = require('./data');
@@ -9,7 +8,7 @@ describe('Splitter ', () => {
 
     beforeEach(() => {
         self = {
-            emit: sinon.spy()
+            emit: sinon.spy(),
         };
     });
 
@@ -18,7 +17,7 @@ describe('Splitter ', () => {
             const { message, config, results } = data[key];
             await splitter.process.call(self, message, config);
             for (let i = 0; i < results.length; i++) {
-                const args = self.emit.getCall(i).args;
+                const { args } = self.emit.getCall(i);
 
                 const expectedEventType = results[i][0];
                 const actualEventType = args[0];

spec/splitOnJsonata/data/index.js

@@ -1,5 +1,3 @@
-'use strict';
-
 module.exports = {
     'should split array from an array constructor expression': require('./arrayConstructors.json'),
     'should split array of arrays of objects users.friends': require('./arrayOfArraysOfObjects.json'),
@@ -12,5 +10,5 @@ module.exports = {
     'should split array from a range query expression': require('./objectConstructors.json'),
     'should split root array': require('./rootArray.json'),
     'should split array of arrays': require('./splitArrayOfArrays.json'),
-    'should split array of objects users': require('./splitArrayOfObjects.json')
+    'should split array of objects users': require('./splitArrayOfObjects.json'),
 };

spec/splitOnJsonata/splitOnJsonata.spec.js

@@ -1,5 +1,4 @@
-'use strict';
-const expect = require('chai').expect;
+const { expect } = require('chai');
 const sinon = require('sinon');
 const splitter = require('../../lib/actions/splitOnJsonata');
 const data = require('./data');
@@ -9,7 +8,7 @@ describe('Split on JSONata ', () => {
 
     beforeEach(() => {
         self = {
-            emit: sinon.spy()
+            emit: sinon.spy(),
         };
     });
 
@@ -18,7 +17,7 @@ describe('Split on JSONata ', () => {
             const { message, config, results } = data[key];
             await splitter.process.call(self, message, config);
             for (let i = 0; i < results.length; i++) {
-                const args = self.emit.getCall(i).args;
+                const { args } = self.emit.getCall(i);
 
                 const expectedEventType = results[i][0];
                 const actualEventType = args[0];

split.js

@@ -1,12 +1,11 @@
-'use strict';
 const debug = require('debug')('splitter');
 const _ = require('lodash');
-const messages = require('elasticio-node').messages;
+const { messages } = require('elasticio-node');
 
 /** @this processAction */
 async function processAction(msg, conf) {
     const splitting = conf.splitter || {};
-    let body = msg.body || {};
+    const body = msg.body || {};
 
     debug('Received new message with body: %j', body);
     debug('Config: %j', conf);
@@ -23,22 +22,22 @@ async function processAction(msg, conf) {
         return;
     }
 
-    if (_.isArray(split) && _.find(split, elem => !_.isObject(elem))) {
+    if (_.isArray(split) && _.find(split, (elem) => !_.isObject(elem))) {
         await this.emit('error', new Error('Splitting arrays of objects only!'));
         return;
     }
 
     const result = [];
 
     if (_.isArray(split)) {
-        split.forEach(elem => result.push(elem));
+        split.forEach((elem) => result.push(elem));
     } else if (_.isObject(split)) {
         debug(`"${splitting}" is not an array. Returning the original object`);
         result.push(split);
     }
 
     debug('%s parts to emit found', result.length);
-    for (let value of result) {
+    for (const value of result) {
         if (value) {
             await this.emit('data', messages.newMessageWithBody(value));
         }