elasticio-2070 Support flow recipe vars in mapper

Author: Anton Kotenko

lib/executor.js

@@ -7,10 +7,12 @@ const { ComponentLogger } = log;
 
 exports.TaskExec = TaskExec;
 
-function TaskExec({ loggerOptions } = {}) {
+function TaskExec({ loggerOptions, variables } = {}) {
     EventEmitter.call(this);
     this.errorCount = 0;
     this.logger = new ComponentLogger(loggerOptions);
+    // copy variables to protect from outside changes;
+    this._variables = Object.assign({}, variables || {});
 }
 
 util.inherits(TaskExec, EventEmitter);
@@ -47,6 +49,13 @@ TaskExec.prototype.process = function process(triggerOrAction, payload, cfg, sna
     }
 };
 
+/**
+ * Returns flow variables or empty object
+ * @returns {Object<String, String>}
+ */
+TaskExec.prototype.getFlowVariables = function getFlowVariables() {
+    return this._variables;
+};
 const _emit = TaskExec.prototype.emit;
 
 TaskExec.emit = (name, data) => {

lib/sailor.js

@@ -286,7 +286,8 @@ class Sailor {
                     threadId,
                     messageId,
                     parentMessageId
-                }
+                },
+                variables: stepData.variables
             });
 
             taskExec

mocha_spec/unit/executor.spec.js

@@ -0,0 +1,31 @@
+const chai = require('chai');
+const { expect } = chai;
+
+const TaskExec = require('../../lib/executor.js').TaskExec;
+
+describe('Executor', () => {
+    describe('#constructor', () => {
+        it('should be constructable without arguments', () => {
+            const taskexec = new TaskExec();
+            expect(taskexec).to.be.instanceof(TaskExec);
+        });
+        it('should properly store variables', () => {
+            const vars = {
+                var1: 'val1',
+                var2: 'val2'
+            };
+            const taskexec = new TaskExec({ variables: vars });
+            expect(taskexec._variables).to.deep.equal(vars);
+        });
+    });
+    describe('getVariables', () => {
+        it('should return flow variables', () => {
+            const vars = {
+                var1: 'val1',
+                var2: 'val2'
+            };
+            const taskexec = new TaskExec({ variables: vars });
+            expect(taskexec.getFlowVariables()).to.deep.equal(vars);
+        });
+    });
+});