Send Connection: close header on shut down

bin/genieacs-fs

@@ -80,6 +80,8 @@ if (!cluster.worker) {
     cert: config.get("FS_SSL_CERT")
   };
 
+  let stopping = false;
+
   process.on("uncaughtException", err => {
     if ((err as NodeJS.ErrnoException).code === "ERR_IPC_DISCONNECTED") return;
     logger.error({
@@ -87,15 +89,21 @@ if (!cluster.worker) {
       exception: err,
       pid: process.pid
     });
+    stopping = true;
     server
       .stop()
       .then(exitWorkerGracefully)
       .catch(exitWorkerUngracefully);
   });
 
+  const _listener = (req, res): void => {
+    if (stopping) res.setHeader("Connection", "close");
+    listener(req, res);
+  };
+
   const initPromise = Promise.all([db.connect(), cache.connect()])
     .then(() => {
-      server.start(SERVICE_PORT, SERVICE_ADDRESS, ssl, listener);
+      server.start(SERVICE_PORT, SERVICE_ADDRESS, ssl, _listener);
     })
     .catch(err => {
       setTimeout(() => {
@@ -104,6 +112,7 @@ if (!cluster.worker) {
     });
 
   process.on("SIGINT", () => {
+    stopping = true;
     initPromise.finally(() => {
       server
         .stop()
@@ -113,6 +122,7 @@ if (!cluster.worker) {
   });
 
   process.on("SIGTERM", () => {
+    stopping = true;
     initPromise.finally(() => {
       server
         .stop()

bin/genieacs-nbi

@@ -84,6 +84,8 @@ if (!cluster.worker) {
     cert: config.get("NBI_SSL_CERT")
   };
 
+  let stopping = false;
+
   process.on("uncaughtException", err => {
     if ((err as NodeJS.ErrnoException).code === "ERR_IPC_DISCONNECTED") return;
     logger.error({
@@ -91,15 +93,21 @@ if (!cluster.worker) {
       exception: err,
       pid: process.pid
     });
+    stopping = true;
     server
       .stop()
       .then(exitWorkerGracefully)
       .catch(exitWorkerUngracefully);
   });
 
+  const _listener = (req, res): void => {
+    if (stopping) res.setHeader("Connection", "close");
+    listener(req, res);
+  };
+
   const initPromise = Promise.all([db.connect(), cache.connect()])
     .then(() => {
-      server.start(SERVICE_PORT, SERVICE_ADDRESS, ssl, listener);
+      server.start(SERVICE_PORT, SERVICE_ADDRESS, ssl, _listener);
     })
     .catch(err => {
       setTimeout(() => {
@@ -108,6 +116,7 @@ if (!cluster.worker) {
     });
 
   process.on("SIGINT", () => {
+    stopping = true;
     initPromise.finally(() => {
       server
         .stop()
@@ -117,6 +126,7 @@ if (!cluster.worker) {
   });
 
   process.on("SIGTERM", () => {
+    stopping = true;
     initPromise.finally(() => {
       server
         .stop()