refactor: code

Author: snitin315

lib/Server.js

@@ -34,6 +34,7 @@ class Server {
     this.staticWatchers = [];
     // Keep track of websocket proxies for external websocket upgrade.
     this.webSocketProxies = [];
+    this.sockets = [];
     this.compiler = compiler;
   }
 
@@ -60,31 +61,6 @@ class Server {
     return /^[a-zA-Z][a-zA-Z\d+\-.]*:/.test(URL);
   }
 
-  static killable(server) {
-    let sockets = [];
-
-    server.on("connection", (socket) => {
-      // add socket to list
-      sockets.push(socket);
-
-      socket.once("close", () => {
-        // remove socket from list
-        sockets.splice(sockets.indexOf(socket), 1);
-      });
-    });
-
-    server.kill = (cb) => {
-      server.close(cb);
-      sockets.forEach((socket) => {
-        socket.destroy();
-      });
-      // reset so the server can be restarted
-      sockets = [];
-    };
-
-    return server;
-  }
-
   static async getHostname(hostname) {
     if (hostname === "local-ip") {
       return (await internalIp.v4()) || (await internalIp.v6()) || "0.0.0.0";
@@ -706,8 +682,6 @@ class Server {
     this.setupFeatures();
     this.createServer();
 
-    Server.killable(this.server);
-
     if (this.options.setupExitSignals) {
       const signals = ["SIGINT", "SIGTERM"];
 
@@ -1190,6 +1164,16 @@ class Server {
       this.server = http.createServer(this.app);
     }
 
+    this.server.on("connection", (socket) => {
+      // add socket to list
+      this.sockets.push(socket);
+
+      socket.once("close", () => {
+        // remove socket from list
+        this.sockets.splice(this.sockets.indexOf(socket), 1);
+      });
+    });
+
     this.server.on("error", (error) => {
       throw error;
     });
@@ -1811,9 +1795,15 @@ class Server {
 
     if (this.server) {
       await new Promise((resolve) => {
-        this.server.kill(() => {
+        this.server.kill = (cb) => {
+          this.server.stopCallback(cb);
+          this.sockets.forEach((socket) => {
+            socket.destroy();
+          });
+          // reset so the server can be restarted
+          this.sockets = [];
           resolve();
-        });
+        };
       });
 
       await new Promise((resolve, reject) => {