fix(bin/attach, utils/guardian): identifies triggered exit via enviro…

…nment variable to account for d

src/bin/attach.ts

@@ -2,6 +2,8 @@ import { attach as _attach, options, resolver, add } from 'exits';
 import terminate from '~/utils/terminate-children';
 import logger from '~/utils/logger';
 import { wait, status } from 'promist';
+import { KPO_EXIT_ENV } from '~/constants';
+import EnvManager from '~/utils/env-manager';
 
 export default function attach(): void {
   _attach();
@@ -23,6 +25,8 @@ export default function attach(): void {
     }
   });
   add(async () => {
+    new EnvManager(process.env).set(KPO_EXIT_ENV, 'triggered');
+
     const term = status(terminate(process.pid, 'SIGTERM', 150));
     await Promise.race([term, wait(3000)]);
     if (term.status !== 'pending') return;

src/constants.ts

@@ -16,3 +16,4 @@ export const CONCURRENTLY_PATH = require.resolve(
 );
 /* Shared between instances: changes might imply a major version release */
 export const KPO_LOG_ENV = 'kpo_log';
+export const KPO_EXIT_ENV = 'kpo_exit';

src/utils/guardian.ts

@@ -1,5 +1,7 @@
-import { state } from 'exits';
+import EnvManager from './env-manager';
+import { KPO_EXIT_ENV } from '~/constants';
 
+const manager = new EnvManager(process.env);
 export default function guardian(): void {
-  if (state().triggered) throw Error(`Process is terminating`);
+  if (manager.get(KPO_EXIT_ENV)) throw Error(`Process is terminating`);
 }