Adding possibility to emit non-array objects (#51)

Fix jsonata object-array emit return

Author: denyshld

CHANGELOG.md

@@ -1,3 +1,6 @@
+## 1.1.4 (August 20, 2020)
+* `Split on JSONata Expression` action update: add possibility to emit non-array objects.
+
 ## 1.1.3 (August 11, 2020)
 * Update Sailor and dependencies.
 * Fix node version.

lib/actions/splitOnJsonata.js

@@ -9,7 +9,12 @@ async function processAction(msg, cfg) {
   const split = JsonataTransform.jsonataTransform(msg, cfg, this);
 
   if (!Array.isArray(split)) {
-    await this.emit('error', new Error('The evaluated expression must be an array.'));
+    this.logger.warn('The evaluated expression should be an array.');
+    if (!_.isObject(split)) {
+      await this.emit('error', new Error("Can't emit single primitive!"));
+      return;
+    }
+    await this.emit('data', messages.newMessageWithBody(split));
     return;
   }
 

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "@elasticio/splitter",
-  "version": "1.1.3",
+  "version": "1.1.4",
   "description": "elastic.io component for splitting incoming messages",
   "scripts": {
     "pretest": "eslint split.js lib spec --fix",

package.json

@@ -18,7 +18,7 @@ module.exports = {
   'should emit error for array of primitives usernames': arrayOfPrimitives,
   'should emit empty array': nothingToSplit,
   'should split array from an object constructor expression': objectConstructors,
-  'should emit error for non-array object': objectValue,
+  'should emit non-array object': objectValue,
   'should emit error for non-array primitive': primitiveValue,
   'should split array from a range query expression': rangeQuery,
   'should split root array': rootArray,

spec/splitOnJsonata/data/index.js

@@ -11,8 +11,10 @@
   },
   "results": [
     [
-      "error",
-      "The evaluated expression must be an array."
+      "data",
+      {
+        "name": "John"
+      }
     ]
   ]
 }

spec/splitOnJsonata/data/objectValue.json

@@ -10,7 +10,7 @@
   "results": [
     [
       "error",
-      "The evaluated expression must be an array."
+      "Can't emit single primitive!"
     ]
   ]
 }