feat: add ability to have sync close

* Add syncClose boolean option

Issue: #27

Author: gquittet

README.md

@@ -319,7 +319,8 @@ where `State` is an enum that contains, `STARTING`, `READY`, `SHUTTING_DOWN` and
 All of the below options are optional.
 
 | Name              |            Type            | Default |                                                      Description |
-| ----------------- | :------------------------: | :-----: | ---------------------------------------------------------------: |
+|-------------------|:--------------------------:|:-------:|-----------------------------------------------------------------:|
+| syncClose         |          boolean           |  false  |                               Run the closePromises in a series. |
 | closePromises     | (() => Promise<unknown>)[] |   []    |                    The functions to run when the API is stopping |
 | timeout           |           number           |  1000   | The time in milliseconds to wait before shutting down the server |
 | healthCheck       |          boolean           |  true   |    Enable/Disable the default endpoints (liveness and readiness) |

src/config/index.ts

@@ -2,6 +2,7 @@ import type { IGracefulServerOptions } from "#interface/gracefulServerOptions";
 import type { IOptions } from "#interface/options";
 
 const options: IOptions = {
+  syncClose: false,
   closePromises: [],
   timeout: 1000,
   healthCheck: true,

src/core/improvedServer.ts

@@ -74,7 +74,7 @@ const improvedServer = <TServer extends Server>(server: TServer, serverStatus: I
 
     stopping = true;
 
-    const { timeout, closePromises } = config;
+    const { timeout, closePromises, syncClose } = config;
 
     let error: Error | undefined;
     if (args.body && args.body.message) {
@@ -87,14 +87,20 @@ const improvedServer = <TServer extends Server>(server: TServer, serverStatus: I
 
     await sleep(timeout);
 
-    await Promise.all(closePromises.map((closePromise) => closePromise()));
+    if (syncClose) {
+      for (const closePromise of closePromises) {
+        await closePromise();
+      }
+    } else {
+      await Promise.allSettled(closePromises.map((closePromise) => closePromise()));
+    }
 
     server.removeAllListeners("request");
     server.on("request", (_: http.IncomingMessage, res: http.ServerResponse) => {
       if (!res.headersSent) res.setHeader("connection", "close");
     });
 
-    await Promise.all([socketsPool.closeAll(), secureSocketsPool.closeAll()]);
+    await Promise.allSettled([socketsPool.closeAll(), secureSocketsPool.closeAll()]);
 
     await new Promise((resolve, reject) => {
       server.close((err) => {

src/interface/gracefulServerOptions.ts

@@ -1,4 +1,5 @@
 export type IGracefulServerOptions = {
+  syncClose?: boolean;
   closePromises?: (() => Promise<unknown>)[];
   timeout?: number;
   healthCheck?: boolean;

src/interface/options.ts

@@ -1,4 +1,5 @@
 export type IOptions = {
+  syncClose: boolean;
   closePromises: (() => Promise<unknown>)[];
   timeout: number;
   healthCheck: boolean;