fix: close open http server sockets immediatly

Author: ngfelixl

package.json

@@ -19,7 +19,7 @@
   "scripts": {
     "build": "npm run clean && webpack && npm run build-copy-files",
     "clean": "shx rm -rf dist",
-    "test": "jest --config jest.config.json --coverage --detectOpenHandles",
+    "test": "jest --config jest.config.json --coverage --maxWorkers=15",
     "format": "prettier --write \"src/**/*.ts\" \"src/**/*.js\"",
     "lint": "tslint --project ./tsconfig.json",
     "coverage": "cat coverage/lcov.info | coveralls",

src/server.ts

@@ -1,5 +1,6 @@
 import { readFile } from 'fs';
 import { createServer, IncomingMessage, Server as HttpServer, ServerResponse } from 'http';
+import { Socket } from 'net';
 import opn from 'opn';
 import { join } from 'path';
 import { IPlotsContainer } from './models';
@@ -8,10 +9,21 @@ export class Server {
   private instance: HttpServer;
   private plotsContainer: IPlotsContainer = {};
   private port: number;
+  private sockets: {[id: number]: Socket} = {};
+  private nextSocketID = 0;
 
   constructor(port: number) {
     this.port = port;
     this.instance = this.createServer();
+
+    this.instance.on('connection', (socket: Socket) => {
+      const id = this.nextSocketID++;
+      this.sockets[id] = socket;
+
+      socket.on('close', () => {
+        delete this.sockets[id];
+      });
+    });
   }
 
   /**
@@ -30,12 +42,18 @@ export class Server {
   }
 
   /**
-   * Closes the webserver and clears the plots container.
+   * Closes the webserver, destroys all connected sockets
+   * and clears the plots container.
    */
   public clean() {
     if (this.instance.address()) {
       this.instance.close();
     }
+
+    for (const socket of Object.values(this.sockets)) {
+      socket.destroy();
+    }
+
     this.plotsContainer = {};
   }
 
@@ -86,7 +104,7 @@ export class Server {
   }
 
   /**
-   * 
+   * Serves the website at http://localhost:PORT/plots/:id/index.html
    * @param req 
    * @param res 
    */

test/server.spec.ts

@@ -116,4 +116,9 @@ describe('Server', () => {
     server.clean();
     server = null;
   });
+
+  // afterAll(() => {
+  //   console.log((process as any)._getActiveRequests());
+  //   console.log((process as any)._getActiveHandles()[0]);
+  // });
 });

test/server.www.spec.ts

@@ -77,4 +77,4 @@ describe('Server', () => {
     server.clean();
     server = null;
   });
-});
+});