await emit in "receive" trigger (#27)

* Await emit in "receive" trigger

Author: pnedelko

CHANGELOG.md

@@ -1,3 +1,9 @@
+## 1.2.0 (February 13, 2020)
+
+* "Receive" trigger awaits the result of emit
+* Update sailor version to 2.6.3
+* Remove "q" dependency
+
 ## 1.1.2 (January 30, 2020)
 
 * Update sailor version to 2.6.1

lib/triggers/receive.js

@@ -1,7 +1,4 @@
-const Q = require('q');
-
-// eslint-disable-next-line func-names
-exports.process = function (msg) {
+exports.process = async function receive(msg) {
     const msgId = msg.id;
     this.logger.info('Received new message:\n', JSON.stringify(msg));
 
@@ -28,27 +25,8 @@ exports.process = function (msg) {
         this.logger.info('Updated body: \n', JSON.stringify(msg.body));
     }
 
-    // eslint-disable-next-line consistent-this
-    let self = this;
-
-    function emitData() {
-        self.logger.info('Emitting data of message: ', msgId);
-        self.emit('data', msg);
-    }
-
-    function onError(e) {
-        self.logger.info(e);
-        self.emit('error', e);
-    }
-
-    function onEnd() {
-        self.logger.info('Finished processing message: ', msgId);
-        self.emit('end');
-    }
-
-    Q()
-        .then(emitData)
-        .fail(onError)
-        .finally(onEnd);
+    this.logger.info('Emitting data of message: ', msgId);
+    await this.emit('data', msg);
+    this.logger.info('Data emitted');
 };
 

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "webhook",
-  "version": "1.1.2",
+  "version": "1.2.0",
   "description": "elastic.io webhook component",
   "scripts": {
     "pretest": "eslint spec lib verifyCredentials.js --fix",
@@ -12,11 +12,10 @@
   "author": "elastic.io GmbH",
   "license": "Apache License 2.0",
   "dependencies": {
-    "elasticio-sailor-nodejs": "2.6.1",
     "elasticio-node": "0.0.8",
+    "elasticio-sailor-nodejs": "2.6.3",
     "node-uuid": "1.4.8",
-    "request": "2.83.x",
-    "q": "1.5.1"
+    "request": "2.83.x"
   },
   "devDependencies": {
     "@elastic.io/component-logger": "0.0.1",