iampeter/pixelplanet
1
Fork 0
forked from ppfun/pixelplanet
Code Pull Requests Activity

promisify terminating dead websockets

Browse Source
This commit is contained in:
HF 2022-07-04 00:52:17 +02:00
parent 14aaa3211d
commit 09ba826b33
1 changed files with 13 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/socket/SocketServer.js
View File

@ -338,15 +338,21 @@ class SocketServer {
checkHealth() { checkHealth() {
const ts = Date.now() - 60 * 1000; const ts = Date.now() - 60 * 1000;
const promises = [];
this.wss.clients.forEach((ws) => { this.wss.clients.forEach((ws) => {
if ( promises.push(new Promise((resolve) => {
ws.readyState === WebSocket.OPEN if (
&& ts > ws.timeLastMsg ws.readyState === WebSocket.OPEN
) { && ts > ws.timeLastMsg
logger.info(`Killing dead websocket from ${ws.user.ip}`); ) {
ws.terminate(); logger.info(`Killing dead websocket from ${ws.user.ip}`);
} ws.terminate();
resolve();
}
}),
);
}); });
return promises;
} }
onlineCounterBroadcast() { onlineCounterBroadcast() {