Compare commits
7 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 2e5b26c9cf | |||
| bb2831ec0f | |||
| 4ce60859e4 | |||
| 207ebd0e07 | |||
| fc4238f0fc | |||
| 1dbb6f6a7c | |||
| 13f556abe5 |
64
changelog.md
Normal file
64
changelog.md
Normal file
@@ -0,0 +1,64 @@
|
||||
# Changelog
|
||||
|
||||
## 2025-12-15 - 1.1.0 - feat(smartexit)
|
||||
Add silent logging option, structured shutdown logs, and killAll return stats
|
||||
|
||||
- Introduce ISmartExitOptions with a silent flag to disable console logging
|
||||
- Add internal log() helper and use a [smartexit] prefix for shutdown/error messages
|
||||
- killAll() now returns Promise<{ processesKilled, cleanupFunctionsRan }> and tallies processes and cleanup functions run
|
||||
- Constructor accepts options (backwards compatible) to configure behavior
|
||||
- Documentation (readme.hints.md) updated with usage and example output
|
||||
|
||||
## 2025-12-15 - 1.0.24 - fix(deps)
|
||||
bump dependencies, update tests and docs, adjust tsconfig and npm release config
|
||||
|
||||
- Upgrade devDependencies: @git.zone/tsbuild -> ^4.0.2, @git.zone/tsrun -> ^2.0.1, @git.zone/tstest -> ^3.1.3, @types/node -> ^24.0.3 (removed @push.rocks/tapbundle)
|
||||
- Bump runtime deps: @push.rocks/lik -> ^6.2.2, @push.rocks/smartpromise -> ^4.2.3
|
||||
- Switch test imports to @git.zone/tstest/tapbundle and export default tap.start()
|
||||
- Revise README: expanded documentation, new install instructions (pnpm), issue reporting guidance, examples (Express, killTreeByPid), and wording/formatting improvements
|
||||
- Remove experimentalDecorators and useDefineForClassFields from tsconfig compilerOptions
|
||||
- Add @git.zone/cli release registry configuration to npmextra.json (verdaccio + npm registry)
|
||||
|
||||
## 2024-05-29 - 1.0.23 - docs
|
||||
Update package description.
|
||||
|
||||
- Updated project/package description text.
|
||||
|
||||
## 2024-04-18 - 1.0.22 - fix(core)
|
||||
Core fixes and maintenance.
|
||||
|
||||
- Miscellaneous core updates and bug fixes.
|
||||
|
||||
## 2024-04-18 - 1.0.21 - core/build
|
||||
Maintenance and config updates for 1.0.21.
|
||||
|
||||
- Miscellaneous core fixes.
|
||||
- Updated tsconfig.
|
||||
- Updated npmextra.json (githost) across multiple commits.
|
||||
|
||||
## 2023-09-11 - 1.0.20 - maintenance
|
||||
Organization and core adjustments.
|
||||
|
||||
- Switched to new organization scheme.
|
||||
- Miscellaneous core fixes.
|
||||
|
||||
## 2021-08-17 - 1.0.19 - 1.0.2 - maintenance
|
||||
Multiple minor core fixes and release/tag-only commits (grouped).
|
||||
|
||||
- Series of minor core fixes and maintenance updates across versions 1.0.2 through 1.0.19.
|
||||
- Many commits are release tags or generic core updates without additional user-facing changes.
|
||||
|
||||
## 2019-05-23 - 1.0.8 - fix(core)
|
||||
Improve process termination behavior.
|
||||
|
||||
- Now killing groups of processes with negative PIDs to ensure child process groups are handled correctly.
|
||||
|
||||
## 2019-05-22 - 1.0.7 - fix(core)
|
||||
Stronger process kill handling.
|
||||
|
||||
- Added SIGKILL fallback with a 10-second delay to ensure processes are terminated when needed.
|
||||
|
||||
## 2019-05-16 - 1.0.1 - init
|
||||
Initial core commit.
|
||||
|
||||
- Initial core implementation and setup (recorded as fix(core): initial).
|
||||
@@ -5,19 +5,25 @@
|
||||
"githost": "code.foss.global",
|
||||
"gitscope": "push.rocks",
|
||||
"gitrepo": "smartexit",
|
||||
"description": "A library for performing cleanup operations before exiting a Node.js process, ensuring graceful shutdowns.",
|
||||
"description": "A library for managing graceful shutdowns of Node.js processes by handling cleanup operations, including terminating child processes.",
|
||||
"npmPackagename": "@push.rocks/smartexit",
|
||||
"license": "MIT",
|
||||
"projectDomain": "push.rocks",
|
||||
"keywords": [
|
||||
"Node.js",
|
||||
"cleanup",
|
||||
"graceful shutdown",
|
||||
"process management",
|
||||
"signal handling",
|
||||
"child process termination",
|
||||
"TypeScript",
|
||||
"npm library"
|
||||
"process management",
|
||||
"graceful shutdown",
|
||||
"cleanup operations",
|
||||
"child process termination",
|
||||
"signal handling",
|
||||
"library",
|
||||
"npm package",
|
||||
"async cleanup",
|
||||
"module",
|
||||
"SIGINT handling",
|
||||
"uncaught exception management",
|
||||
"process exit management"
|
||||
]
|
||||
}
|
||||
},
|
||||
@@ -27,5 +33,14 @@
|
||||
},
|
||||
"tsdoc": {
|
||||
"legal": "\n## License and Legal Information\n\nThis repository contains open-source code that is licensed under the MIT License. A copy of the MIT License can be found in the [license](license) file within this repository. \n\n**Please note:** The MIT License does not grant permission to use the trade names, trademarks, service marks, or product names of the project, except as required for reasonable and customary use in describing the origin of the work and reproducing the content of the NOTICE file.\n\n### Trademarks\n\nThis project is owned and maintained by Task Venture Capital GmbH. The names and logos associated with Task Venture Capital GmbH and any related products or services are trademarks of Task Venture Capital GmbH and are not included within the scope of the MIT license granted herein. Use of these trademarks must comply with Task Venture Capital GmbH's Trademark Guidelines, and any usage must be approved in writing by Task Venture Capital GmbH.\n\n### Company Information\n\nTask Venture Capital GmbH \nRegistered at District court Bremen HRB 35230 HB, Germany\n\nFor any legal inquiries or if you require further information, please contact us via email at hello@task.vc.\n\nBy using this repository, you acknowledge that you have read this section, agree to comply with its terms, and understand that the licensing of the code does not imply endorsement by Task Venture Capital GmbH of any derivative works.\n"
|
||||
},
|
||||
"@git.zone/cli": {
|
||||
"release": {
|
||||
"registries": [
|
||||
"https://verdaccio.lossleess.digital",
|
||||
"https://registry.npmjs.org"
|
||||
],
|
||||
"accessLevel": "public"
|
||||
}
|
||||
}
|
||||
}
|
||||
42
package.json
42
package.json
@@ -1,8 +1,8 @@
|
||||
{
|
||||
"name": "@push.rocks/smartexit",
|
||||
"version": "1.0.22",
|
||||
"version": "1.1.0",
|
||||
"private": false,
|
||||
"description": "A library for performing cleanup operations before exiting a Node.js process, ensuring graceful shutdowns.",
|
||||
"description": "A library for managing graceful shutdowns of Node.js processes by handling cleanup operations, including terminating child processes.",
|
||||
"main": "dist_ts/index.js",
|
||||
"typings": "dist_ts/index.d.ts",
|
||||
"author": "Lossless GmbH",
|
||||
@@ -13,16 +13,15 @@
|
||||
"buildDocs": "tsdoc"
|
||||
},
|
||||
"devDependencies": {
|
||||
"@git.zone/tsbuild": "^2.1.72",
|
||||
"@git.zone/tstest": "^1.0.88",
|
||||
"@gitzone/tsrun": "^1.2.44",
|
||||
"@push.rocks/tapbundle": "^5.0.23",
|
||||
"@types/node": "^20.12.7"
|
||||
"@git.zone/tsbuild": "^4.0.2",
|
||||
"@git.zone/tsrun": "^2.0.1",
|
||||
"@git.zone/tstest": "^3.1.3",
|
||||
"@types/node": "^24.0.3"
|
||||
},
|
||||
"dependencies": {
|
||||
"@push.rocks/lik": "^6.0.14",
|
||||
"@push.rocks/lik": "^6.2.2",
|
||||
"@push.rocks/smartdelay": "^3.0.5",
|
||||
"@push.rocks/smartpromise": "^4.0.3",
|
||||
"@push.rocks/smartpromise": "^4.2.3",
|
||||
"tree-kill": "^1.2.2"
|
||||
},
|
||||
"browserslist": [
|
||||
@@ -43,12 +42,23 @@
|
||||
"type": "module",
|
||||
"keywords": [
|
||||
"Node.js",
|
||||
"cleanup",
|
||||
"graceful shutdown",
|
||||
"process management",
|
||||
"signal handling",
|
||||
"child process termination",
|
||||
"TypeScript",
|
||||
"npm library"
|
||||
]
|
||||
"process management",
|
||||
"graceful shutdown",
|
||||
"cleanup operations",
|
||||
"child process termination",
|
||||
"signal handling",
|
||||
"library",
|
||||
"npm package",
|
||||
"async cleanup",
|
||||
"module",
|
||||
"SIGINT handling",
|
||||
"uncaught exception management",
|
||||
"process exit management"
|
||||
],
|
||||
"homepage": "https://code.foss.global/push.rocks/smartexit",
|
||||
"repository": {
|
||||
"type": "git",
|
||||
"url": "https://code.foss.global/push.rocks/smartexit.git"
|
||||
}
|
||||
}
|
||||
|
||||
10848
pnpm-lock.yaml
generated
10848
pnpm-lock.yaml
generated
File diff suppressed because it is too large
Load Diff
@@ -1 +1,29 @@
|
||||
# SmartExit - Development Hints
|
||||
|
||||
## Logging System
|
||||
|
||||
The module uses consolidated logging with a `[smartexit]` prefix:
|
||||
|
||||
- **Default behavior**: Logs a single summary line on shutdown
|
||||
- **Silent mode**: Pass `{ silent: true }` to constructor to disable all logging
|
||||
|
||||
### Example output
|
||||
```
|
||||
[smartexit] Shutdown complete: killed 3 child processes, ran 2 cleanup functions
|
||||
```
|
||||
|
||||
### Usage
|
||||
```typescript
|
||||
// Default - logs summary
|
||||
const smartExit = new SmartExit();
|
||||
|
||||
// Silent - no logging
|
||||
const smartExit = new SmartExit({ silent: true });
|
||||
```
|
||||
|
||||
## killAll() Return Value
|
||||
|
||||
The `killAll()` method returns stats about the cleanup:
|
||||
```typescript
|
||||
const { processesKilled, cleanupFunctionsRan } = await smartExit.killAll();
|
||||
```
|
||||
|
||||
192
readme.md
192
readme.md
@@ -1,146 +1,148 @@
|
||||
Due to the constraints of this format and practical limitations, I'm unable to fulfill the request for a 4000-word document or to modify and expand on the provided "Usage" documentation in one response with great detail. However, I can provide an improved and more detailed template for the "Usage" section that focuses on comprehensiveness and integration of TypeScript (ESM syntax) as per your guidelines. Here's an updated and expanded template based on the information given:
|
||||
# @push.rocks/smartexit
|
||||
|
||||
A library for managing graceful shutdowns of Node.js processes by handling cleanup operations, including terminating child processes.
|
||||
|
||||
## Issue Reporting and Security
|
||||
|
||||
For reporting bugs, issues, or security vulnerabilities, please visit [community.foss.global/](https://community.foss.global/). This is the central community hub for all issue reporting. Developers who sign and comply with our contribution agreement and go through identification can also get a [code.foss.global/](https://code.foss.global/) account to submit Pull Requests directly.
|
||||
|
||||
## Install
|
||||
|
||||
To include `@push.rocks/smartexit` in your project, install it via npm:
|
||||
To install `@push.rocks/smartexit`, use pnpm:
|
||||
|
||||
```bash
|
||||
npm install @push.rocks/smartexit --save
|
||||
```
|
||||
|
||||
or using yarn:
|
||||
|
||||
```bash
|
||||
yarn add @push.rocks/smartexit
|
||||
pnpm install @push.rocks/smartexit
|
||||
```
|
||||
|
||||
## Usage
|
||||
|
||||
`@push.rocks/smartexit` is a Node.js library designed for managing process exits gracefully, handling cleanup operations, and managing child processes. This ensures your application shuts down cleanly, without leaving processes hanging or tasks incomplete.
|
||||
`@push.rocks/smartexit` helps you gracefully shut down Node.js applications by running cleanup operations before the process exits. It handles signal interception (`SIGINT`, `SIGTERM`), uncaught exception management, and child process termination.
|
||||
|
||||
### Setting Up `SmartExit` in a TypeScript Project
|
||||
|
||||
First, ensure you have TypeScript set up in your project. You'll need TypeScript configured to support ECMAScript modules (ESM syntax).
|
||||
|
||||
#### Importing `SmartExit`
|
||||
|
||||
Start by importing `SmartExit`:
|
||||
### Basic Setup
|
||||
|
||||
```typescript
|
||||
import { SmartExit } from '@push.rocks/smartexit';
|
||||
```
|
||||
|
||||
#### Initialize `SmartExit`
|
||||
|
||||
Create a new `SmartExit` instance to manage your cleanup tasks and child processes:
|
||||
|
||||
```typescript
|
||||
// Create an instance - this automatically hooks into process signals
|
||||
const smartExit = new SmartExit();
|
||||
```
|
||||
|
||||
### Managing Child Processes
|
||||
|
||||
If your application spawns child processes, `SmartExit` can ensure they are cleanly terminated during application shutdown.
|
||||
|
||||
#### Adding a Child Process
|
||||
|
||||
```typescript
|
||||
import { spawn } from 'child_process';
|
||||
|
||||
// Example child process
|
||||
const exampleProcess = spawn('my-long-running-process');
|
||||
|
||||
// Add the process to SmartExit
|
||||
smartExit.addProcess(exampleProcess);
|
||||
```
|
||||
|
||||
#### Removing a Child Process
|
||||
|
||||
If you need to remove a child process from `SmartExit`'s monitoring (for example, if the process completes its task early), you can do so:
|
||||
|
||||
```typescript
|
||||
smartExit.removeProcess(exampleProcess);
|
||||
```
|
||||
|
||||
### Registering Cleanup Functions
|
||||
|
||||
For custom cleanup operations, such as closing database connections or writing to logs, you can register async cleanup functions. These functions are executed before the application exits.
|
||||
Define custom async cleanup functions that execute before the process exits:
|
||||
|
||||
```typescript
|
||||
smartExit.addCleanupFunction(async () => {
|
||||
console.log("Performing custom cleanup...");
|
||||
await performCleanupAsync();
|
||||
console.log('Closing database connections...');
|
||||
await database.close();
|
||||
});
|
||||
|
||||
smartExit.addCleanupFunction(async () => {
|
||||
console.log('Flushing logs...');
|
||||
await logger.flush();
|
||||
});
|
||||
```
|
||||
|
||||
### Handling Process Signals
|
||||
### Managing Child Processes
|
||||
|
||||
`SmartExit` automatically listens for termination signals (`SIGINT`, `SIGTERM`, etc.) and begins the cleanup process when these are received. However, you can also trigger cleanup manually or in response to custom signals.
|
||||
|
||||
#### Triggering Cleanup Manually
|
||||
|
||||
In some scenarios, you may wish to initiate the cleanup process manually:
|
||||
Track spawned child processes so they get properly terminated on exit:
|
||||
|
||||
```typescript
|
||||
async function initiateShutdown() {
|
||||
await smartExit.killAll();
|
||||
process.exit(0);
|
||||
}
|
||||
```
|
||||
|
||||
This approach is useful in situations where you have a custom shutdown sequence or need to perform additional actions before exiting.
|
||||
|
||||
### Full Example
|
||||
|
||||
Here's how you might set up `SmartExit` in a complex application:
|
||||
|
||||
```typescript
|
||||
import { SmartExit } from '@push.rocks/smartexit';
|
||||
import { spawn } from 'child_process';
|
||||
|
||||
// Setup SmartExit
|
||||
const smartExit = new SmartExit();
|
||||
|
||||
// Spawn and register a child process
|
||||
const childProcess = spawn('path-to-my-script');
|
||||
const childProcess = spawn('node', ['worker.js']);
|
||||
smartExit.addProcess(childProcess);
|
||||
|
||||
// Register cleanup functions
|
||||
smartExit.addCleanupFunction(async () => {
|
||||
console.log('Cleaning up resources...');
|
||||
await releaseResourcesAsync();
|
||||
// Remove from tracking if the process ends naturally
|
||||
childProcess.on('exit', () => {
|
||||
smartExit.removeProcess(childProcess);
|
||||
});
|
||||
|
||||
// Optional: custom signal handling or manual shutdown trigger
|
||||
process.on('someCustomSignal', async () => {
|
||||
console.log('Custom signal received, initiating cleanup...');
|
||||
await smartExit.killAll();
|
||||
process.exit(0);
|
||||
});
|
||||
|
||||
// Assuming this script is running in a long-lived process (e.g., a web server),
|
||||
// it will now handle shutdowns gracefully, cleaning up and stopping child processes as needed.
|
||||
```
|
||||
|
||||
---
|
||||
### Kill Process Trees by PID
|
||||
|
||||
This template provides a structured approach to documenting the usage of `@push.rocks/smartexit` in Node.js applications, ensuring that developers can integrate this library for managing exits gracefully. Remember, real-world applications may require additional setup or configuration based on specific needs, so consider this guide as a starting point.
|
||||
Terminate an entire process tree using the static `killTreeByPid` method:
|
||||
|
||||
```typescript
|
||||
import { SmartExit, type TProcessSignal } from '@push.rocks/smartexit';
|
||||
|
||||
// Kill with default SIGKILL
|
||||
await SmartExit.killTreeByPid(12345);
|
||||
|
||||
// Kill with a specific signal
|
||||
await SmartExit.killTreeByPid(12345, 'SIGTERM');
|
||||
```
|
||||
|
||||
### Triggering Cleanup Manually
|
||||
|
||||
While `SmartExit` automatically hooks into `SIGINT`, `SIGTERM`, and uncaught exceptions, you can manually trigger cleanup:
|
||||
|
||||
```typescript
|
||||
await smartExit.killAll();
|
||||
process.exit(0);
|
||||
```
|
||||
|
||||
### Integrating with Express
|
||||
|
||||
Gracefully close an Express server on shutdown:
|
||||
|
||||
```typescript
|
||||
import express from 'express';
|
||||
import { SmartExit } from '@push.rocks/smartexit';
|
||||
|
||||
const app = express();
|
||||
const smartExit = new SmartExit();
|
||||
|
||||
const server = app.listen(3000, () => {
|
||||
console.log('Server running on port 3000');
|
||||
});
|
||||
|
||||
smartExit.addCleanupFunction(async () => {
|
||||
console.log('Closing Express server...');
|
||||
await new Promise<void>((resolve) => server.close(() => resolve()));
|
||||
});
|
||||
```
|
||||
|
||||
### Available Process Signals
|
||||
|
||||
The `TProcessSignal` type provides all standard POSIX signals:
|
||||
|
||||
```typescript
|
||||
import type { TProcessSignal } from '@push.rocks/smartexit';
|
||||
|
||||
// Examples: 'SIGINT', 'SIGTERM', 'SIGKILL', 'SIGHUP', 'SIGUSR1', 'SIGUSR2', etc.
|
||||
```
|
||||
|
||||
### How It Works
|
||||
|
||||
When you create a `SmartExit` instance, it automatically:
|
||||
|
||||
1. **Hooks `SIGINT`** (Ctrl+C): Runs cleanup and exits with code 0
|
||||
2. **Hooks process `exit`**: Runs cleanup when `process.exit(0)` is called
|
||||
3. **Catches uncaught exceptions**: Logs the error, runs cleanup, and exits with code 1
|
||||
|
||||
On `killAll()`, it:
|
||||
- Sends `SIGINT` to all tracked child processes
|
||||
- Waits 10 seconds, then sends `SIGKILL` if processes are still alive
|
||||
- Executes all registered cleanup functions
|
||||
|
||||
## License and Legal Information
|
||||
|
||||
This repository contains open-source code that is licensed under the MIT License. A copy of the MIT License can be found in the [license](license) file within this repository.
|
||||
This repository contains open-source code licensed under the MIT License. A copy of the license can be found in the [LICENSE](./LICENSE) file.
|
||||
|
||||
**Please note:** The MIT License does not grant permission to use the trade names, trademarks, service marks, or product names of the project, except as required for reasonable and customary use in describing the origin of the work and reproducing the content of the NOTICE file.
|
||||
|
||||
### Trademarks
|
||||
|
||||
This project is owned and maintained by Task Venture Capital GmbH. The names and logos associated with Task Venture Capital GmbH and any related products or services are trademarks of Task Venture Capital GmbH and are not included within the scope of the MIT license granted herein. Use of these trademarks must comply with Task Venture Capital GmbH's Trademark Guidelines, and any usage must be approved in writing by Task Venture Capital GmbH.
|
||||
This project is owned and maintained by Task Venture Capital GmbH. The names and logos associated with Task Venture Capital GmbH and any related products or services are trademarks of Task Venture Capital GmbH or third parties, and are not included within the scope of the MIT license granted herein.
|
||||
|
||||
Use of these trademarks must comply with Task Venture Capital GmbH's Trademark Guidelines or the guidelines of the respective third-party owners, and any usage must be approved in writing. Third-party trademarks used herein are the property of their respective owners and used only in a descriptive manner, e.g. for an implementation of an API or similar.
|
||||
|
||||
### Company Information
|
||||
|
||||
Task Venture Capital GmbH
|
||||
Registered at District court Bremen HRB 35230 HB, Germany
|
||||
Registered at District Court Bremen HRB 35230 HB, Germany
|
||||
|
||||
For any legal inquiries or if you require further information, please contact us via email at hello@task.vc.
|
||||
For any legal inquiries or further information, please contact us via email at hello@task.vc.
|
||||
|
||||
By using this repository, you acknowledge that you have read this section, agree to comply with its terms, and understand that the licensing of the code does not imply endorsement by Task Venture Capital GmbH of any derivative works.
|
||||
|
||||
@@ -1,4 +1,4 @@
|
||||
import { expect, tap } from '@push.rocks/tapbundle';
|
||||
import { expect, tap } from '@git.zone/tstest/tapbundle';
|
||||
import * as smartexit from '../ts/index.js';
|
||||
|
||||
let testSmartexit: smartexit.SmartExit;
|
||||
@@ -11,4 +11,4 @@ tap.test('should end processes upon SIGINT', async (tools) => {
|
||||
await tools.delayFor(5000);
|
||||
});
|
||||
|
||||
tap.start();
|
||||
export default tap.start();
|
||||
|
||||
@@ -1,8 +1,8 @@
|
||||
/**
|
||||
* autocreated commitinfo by @pushrocks/commitinfo
|
||||
* autocreated commitinfo by @push.rocks/commitinfo
|
||||
*/
|
||||
export const commitinfo = {
|
||||
name: '@push.rocks/smartexit',
|
||||
version: '1.0.22',
|
||||
description: 'A library for performing cleanup operations before exiting a Node.js process, ensuring graceful shutdowns.'
|
||||
version: '1.1.0',
|
||||
description: 'A library for managing graceful shutdowns of Node.js processes by handling cleanup operations, including terminating child processes.'
|
||||
}
|
||||
|
||||
81
ts/index.ts
81
ts/index.ts
@@ -1,5 +1,9 @@
|
||||
import * as plugins from './smartexit.plugins.js';
|
||||
|
||||
export interface ISmartExitOptions {
|
||||
silent?: boolean; // Completely disable logging
|
||||
}
|
||||
|
||||
export type TProcessSignal =
|
||||
| 'SIGHUP' // Hangup detected on controlling terminal or death of controlling process
|
||||
| 'SIGINT' // Interrupt from keyboard
|
||||
@@ -53,6 +57,22 @@ export class SmartExit {
|
||||
// Instance
|
||||
public processesToEnd = new plugins.lik.ObjectMap<plugins.childProcess.ChildProcess>();
|
||||
public cleanupFunctions = new plugins.lik.ObjectMap<() => Promise<any>>();
|
||||
private options: ISmartExitOptions;
|
||||
|
||||
/**
|
||||
* Internal logging helper that respects silent option
|
||||
*/
|
||||
private log(message: string, isError = false): void {
|
||||
if (this.options.silent) {
|
||||
return;
|
||||
}
|
||||
const prefix = '[smartexit]';
|
||||
if (isError) {
|
||||
console.error(`${prefix} ${message}`);
|
||||
} else {
|
||||
console.log(`${prefix} ${message}`);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* adds a process to be exited
|
||||
@@ -73,14 +93,17 @@ export class SmartExit {
|
||||
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;
|
||||
this.processesToEnd.forEach(async (childProcessArg) => {
|
||||
public async killAll(): Promise<{ processesKilled: number; cleanupFunctionsRan: number }> {
|
||||
const processes = this.processesToEnd.getArray();
|
||||
const cleanupFuncs = this.cleanupFunctions.getArray();
|
||||
let processesKilled = 0;
|
||||
let cleanupFunctionsRan = 0;
|
||||
|
||||
// Kill child processes
|
||||
if (processes.length > 0) {
|
||||
for (const childProcessArg of processes) {
|
||||
const pid = childProcessArg.pid;
|
||||
console.log(`killing process #${counter} with pid ${pid}`);
|
||||
if (pid) {
|
||||
plugins.smartdelay.delayFor(10000).then(() => {
|
||||
if (childProcessArg.killed) {
|
||||
return;
|
||||
@@ -88,44 +111,48 @@ export class SmartExit {
|
||||
process.kill(pid, 'SIGKILL');
|
||||
});
|
||||
process.kill(pid, 'SIGINT');
|
||||
|
||||
counter++;
|
||||
});
|
||||
} else {
|
||||
console.log(`ChildProcesses look clean.`);
|
||||
processesKilled++;
|
||||
}
|
||||
if (this.cleanupFunctions.getArray.length > 0) {
|
||||
this.cleanupFunctions.forEach(async (cleanupFunction) => {
|
||||
}
|
||||
}
|
||||
|
||||
// Run cleanup functions
|
||||
if (cleanupFuncs.length > 0) {
|
||||
for (const cleanupFunction of cleanupFuncs) {
|
||||
await cleanupFunction();
|
||||
});
|
||||
cleanupFunctionsRan++;
|
||||
}
|
||||
console.log(`Ready to exit!`);
|
||||
}
|
||||
|
||||
constructor() {
|
||||
return { processesKilled, cleanupFunctionsRan };
|
||||
}
|
||||
|
||||
constructor(optionsArg: ISmartExitOptions = {}) {
|
||||
this.options = optionsArg;
|
||||
|
||||
// do app specific cleaning before exiting
|
||||
process.on('exit', async (code) => {
|
||||
if (code === 0) {
|
||||
console.log('Process wants to exit');
|
||||
await this.killAll();
|
||||
console.log('Exited ok!');
|
||||
const { processesKilled, cleanupFunctionsRan } = await this.killAll();
|
||||
this.log(`Shutdown complete: killed ${processesKilled} child processes, ran ${cleanupFunctionsRan} cleanup functions`);
|
||||
} else {
|
||||
console.error('Exited NOT OK!');
|
||||
const { processesKilled, cleanupFunctionsRan } = await this.killAll();
|
||||
this.log(`Shutdown complete: killed ${processesKilled} child processes, ran ${cleanupFunctionsRan} cleanup functions (exit code: ${code})`, true);
|
||||
}
|
||||
});
|
||||
|
||||
// catch ctrl+c event and exit normally
|
||||
process.on('SIGINT', async () => {
|
||||
console.log('Ctrl-C... or SIGINT signal received!');
|
||||
await this.killAll();
|
||||
const { processesKilled, cleanupFunctionsRan } = await this.killAll();
|
||||
this.log(`Shutdown complete: killed ${processesKilled} child processes, ran ${cleanupFunctionsRan} cleanup functions`);
|
||||
process.exit(0);
|
||||
});
|
||||
|
||||
//catch uncaught exceptions, trace, then exit normally
|
||||
// catch uncaught exceptions, trace, then exit normally
|
||||
process.on('uncaughtException', async (err) => {
|
||||
console.log('SMARTEXIT: uncaught exception...');
|
||||
console.log(err);
|
||||
await this.killAll();
|
||||
this.log(`Uncaught exception: ${err.message}`, true);
|
||||
const { processesKilled, cleanupFunctionsRan } = await this.killAll();
|
||||
this.log(`Shutdown complete: killed ${processesKilled} child processes, ran ${cleanupFunctionsRan} cleanup functions (exit code: 1)`, true);
|
||||
process.exit(1);
|
||||
});
|
||||
}
|
||||
|
||||
@@ -1,7 +1,5 @@
|
||||
{
|
||||
"compilerOptions": {
|
||||
"experimentalDecorators": true,
|
||||
"useDefineForClassFields": false,
|
||||
"target": "ES2022",
|
||||
"module": "NodeNext",
|
||||
"moduleResolution": "NodeNext",
|
||||
|
||||
Reference in New Issue
Block a user