X-Git-Url: https://git.auder.net/?p=vchess.git;a=blobdiff_plain;f=server%2Fsockets.js;fp=server%2Fsockets.js;h=520b8b70753eac9aca1f301aab31d0aa79db4e0b;hp=c2b41e88c3ede21b381593db92d819916988f8d3;hb=16d06164d56332bd00fb22acc5b2b2997b942d73;hpb=be4b9421603ea763010b01b853363a1bda93ce36

diff --git a/server/sockets.js b/server/sockets.js
index c2b41e88..520b8b70 100644
--- a/server/sockets.js
+++ b/server/sockets.js
@@ -18,6 +18,12 @@ function send(socket, message) {
     socket.send(JSON.stringify(message));
 }
 
+// https://www.npmjs.com/package/ws - detect lost connections...
+function noop() {}
+function heartbeat() {
+  this.isAlive = true;
+}
+
 module.exports = function(wss) {
   // Associative array page --> sid --> tmpId --> socket
   // "page" is either "/" for hall or "/game/some_gid" for Game,
@@ -36,6 +42,8 @@ module.exports = function(wss) {
     });
   }
   wss.on("connection", (socket, req) => {
+    socket.isAlive = true;
+    socket.on('pong', heartbeat);
     const query = getJsonFromUrl(req.url);
     const sid = query["sid"];
     const id = query["id"];
@@ -368,4 +376,15 @@ module.exports = function(wss) {
     socket.on("message", messageListener);
     socket.on("close", closeListener);
   });
+  const interval = setInterval(
+    () => {
+      wss.clients.forEach(ws => {
+        if (ws.isAlive === false) return ws.terminate();
+        ws.isAlive = false;
+        ws.ping(noop);
+      });
+    },
+    30000
+  );
+  wss.on('close', () => clearInterval(interval));
 }