Fix Node Workers (#150)

Author: akshay288

ingestors/node/package.json

@@ -1,6 +1,6 @@
 {
   "name": "metlo",
-  "version": "0.0.12",
+  "version": "0.0.13",
   "license": "MIT",
   "description": "The node agent for Metlo API Security.",
   "main": "dist/index.js",

ingestors/node/src/pool/index.js

@@ -13,7 +13,9 @@ class WorkerPoolTaskInfo extends AsyncResource {
     }
 
     done(err, result) {
-        this.runInAsyncScope(this.callback, null, err, result);
+        if (this.callback) {
+            this.runInAsyncScope(this.callback, null, err, result);
+        }
         this.emitDestroy();  // `TaskInfo`s are used only once.
     }
 }

ingestors/node/src/pool/workerTarget.js

@@ -14,5 +14,7 @@ parentPort.on('message', ({ data: postData, host, key }) => {
         data: postData
     }).catch((error) => {
         console.warn("Encountered an error with metlo ingestor.\nError: ", error.message);
+    }).finally(() => {
+        parentPort.postMessage("done")
     });
 });