fix possible discrepancy in possible attachment publish and emitting message (#73)

* Minor asynchronicity improvement

Author: umkaline

CHANGELOG.md

@@ -1,3 +1,7 @@
+## 2.1.4 (August 21, 2020)
+
+Minor asynchronicity improvement.
+
 ## 2.1.3 (June 5, 2020)
 
 * Fix `timeout is not a function` bug

component.json

@@ -165,6 +165,7 @@
           "properties": {
             "inputArray": {
               "type": "array",
+              "required": true,
               "items": {}
             }
           }

lib/actions/writeFromArray.js

@@ -56,6 +56,7 @@ async function init(cfg) {
   ax = axios.create();
   util.addRetryCountInterceptorToAxios(ax);
 }
+
 async function ProcessAction(msg) {
   // eslint-disable-next-line consistent-this
   const self = this;
@@ -94,14 +95,15 @@ async function ProcessAction(msg) {
     throw Error(`Inbound message should be a plain Object. At least one of entries is not a primitive type: ${JSON.stringify(errorValue)}`);
   }
 
-  ax.put(putUrl, stringifier, {
+  await stringifier.end();
+
+  await ax.put(putUrl, stringifier, {
     method: 'PUT',
     timeout: REQUEST_TIMEOUT,
     retry: REQUEST_MAX_RETRY,
     delay: REQUEST_RETRY_DELAY,
     maxContentLength: REQUEST_MAX_CONTENT_LENGTH,
   });
-  stringifier.end();
 
   const messageToEmit = messages.newMessageWithBody({
     rowCount,

package.json

@@ -1,6 +1,6 @@
 {
   "name": "csv-component",
-  "version": "2.1.3",
+  "version": "2.1.4",
   "description": "CSV Component for elastic.io platform",
   "main": "index.js",
   "scripts": {