fix(sqs): fix unresolved promise blocking further serverless processes

fixes #171

Author: larrybotha

packages/serverless-offline-sqs/src/index.js

@@ -45,7 +45,7 @@ class ServerlessOfflineSQS {
     this.hooks = {
       'offline:start:init': this.start.bind(this),
       'offline:start:ready': this.ready.bind(this),
-      'offline:start': this._startWithExplicitEnd.bind(this),
+      'offline:start': this._startWithReady.bind(this),
       'offline:start:end': this.end.bind(this)
     };
   }
@@ -72,24 +72,27 @@ class ServerlessOfflineSQS {
     );
   }
 
-  async ready() {
+  ready() {
     if (process.env.NODE_ENV !== 'test') {
-      await this._listenForTermination();
+      this._listenForTermination();
     }
   }
 
-  async _listenForTermination() {
-    const command = await new Promise(resolve => {
-      process.on('SIGINT', () => resolve('SIGINT')).on('SIGTERM', () => resolve('SIGTERM'));
-    });
+  _listenForTermination() {
+    const signals = ['SIGINT', 'SIGTERM'];
+
+    signals.map(signal =>
+      process.on(signal, async () => {
+        this.serverless.cli.log(`Got ${signal} signal. Offline Halting...`);
 
-    this.serverless.cli.log(`Got ${command} signal. Offline Halting...`);
+        await this.end();
+      })
+    );
   }
 
-  async _startWithExplicitEnd() {
+  async _startWithReady() {
     await this.start();
-    await this.ready();
-    this.end();
+    this.ready();
   }
 
   async end(skipExit) {