X-Git-Url: https://git.auder.net/?p=vchess.git;a=blobdiff_plain;f=server%2Fsockets.js;fp=server%2Fsockets.js;h=c2b41e88c3ede21b381593db92d819916988f8d3;hp=520b8b70753eac9aca1f301aab31d0aa79db4e0b;hb=bae751bc6bc548791772c3ff5883a03deeb77264;hpb=7a0c1b7e33a346195caebfdfa6489e7c6d0457e6 diff --git a/server/sockets.js b/server/sockets.js index 520b8b70..c2b41e88 100644 --- a/server/sockets.js +++ b/server/sockets.js @@ -18,12 +18,6 @@ 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, @@ -42,8 +36,6 @@ 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"]; @@ -376,15 +368,4 @@ 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)); }