1.0.8

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "@pushrocks/smartexit",
-  "version": "1.0.4",
+  "version": "1.0.8",
   "lockfileVersion": 1,
   "requires": true,
   "dependencies": {

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pushrocks/smartexit",
-  "version": "1.0.4",
+  "version": "1.0.8",
   "private": false,
   "description": "do things before one exists a process",
   "main": "dist/index.js",
@@ -21,6 +21,7 @@
     "tslint-config-prettier": "^1.15.0"
   },
   "dependencies": {
-    "@pushrocks/lik": "^3.0.5"
+    "@pushrocks/lik": "^3.0.5",
+    "@pushrocks/smartdelay": "^2.0.3"
   }
 }

test/test.ts

@@ -1,8 +1,10 @@
 import { expect, tap } from '@pushrocks/tapbundle';
 import * as smartexit from '../ts/index';
 
+let testSmartexit: smartexit.SmartExit;
+
 tap.test('first test', async () => {
-  smartexit;
+  testSmartexit = new smartexit.SmartExit();
 });
 
 tap.test('should end processes upon SIGINT', async tools => {

ts/index.ts

@@ -1,40 +1,61 @@
 import * as plugins from './smartexit.plugins';
 
 export class SmartExit {
-  public static processesToEnd = new plugins.lik.Objectmap<plugins.childProcess.ChildProcess>();
-  public static async addProcess(childProcessArg: plugins.childProcess.ChildProcess) {
-    SmartExit.processesToEnd.add(childProcessArg);
+  public processesToEnd = new plugins.lik.Objectmap<plugins.childProcess.ChildProcess>();
+
+  /**
+   * adds a process to be exited
+   * @param childProcessArg
+   */
+  public addProcess(childProcessArg: plugins.childProcess.ChildProcess) {
+    this.processesToEnd.add(childProcessArg);
   }
 
-  public static async killAll() {
+  /**
+   * removes a process to be exited
+   */
+  public removeProcess(childProcessArg: plugins.childProcess.ChildProcess) {
+    this.processesToEnd.remove(childProcessArg);
+  }
+
+  public async killAll() {
     console.log('Checking for remaining child processes before exit...');
     if (this.processesToEnd.getArray().length > 0) {
       console.log('found remaining child processes');
       let counter = 1;
-      SmartExit.processesToEnd.forEach(async childProcessArg => {
+      this.processesToEnd.forEach(async childProcessArg => {
         console.log(`killing process #${counter}`);
+        plugins.smartdelay.delayFor(10000).then(() => {
+          if (childProcessArg.killed) {
+            return;
+          }
+          childProcessArg.kill('SIGKILL');
+        })
         childProcessArg.kill('SIGINT');
+        
         counter++;
       });
     } else {
       console.log(`Everything looks clean. Ready to exit!`);
     }
   }
+
+  constructor() {
+    // do app specific cleaning before exiting
+    process.on('exit', async () => {
+      await this.killAll();
+    });
+
+    // catch ctrl+c event and exit normally
+    process.on('SIGINT', async () => {
+      console.log('Ctrl-C...');
+      await this.killAll();
+    });
+
+    //catch uncaught exceptions, trace, then exit normally
+    process.on('uncaughtException', async err => {
+      console.log('Ctrl-C...');
+      await this.killAll();
+    });
+  }
 }
-
-// do app specific cleaning before exiting
-process.on('exit', async () => {
-  await SmartExit.killAll();
-});
-
-// catch ctrl+c event and exit normally
-process.on('SIGINT', async () => {
-  console.log('Ctrl-C...');
-  await SmartExit.killAll();
-});
-
-//catch uncaught exceptions, trace, then exit normally
-process.on('uncaughtException', async err => {
-  console.log('Ctrl-C...');
-  await SmartExit.killAll();
-});

ts/smartexit.plugins.ts

@@ -5,5 +5,6 @@ export { childProcess };
 
 // pushrocks scope
 import * as lik from '@pushrocks/lik';
+import * as smartdelay from '@pushrocks/smartdelay';
 
-export { lik };
+export { lik, smartdelay };