zefie/minisrv
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

maybe fix ping

Browse Source
This commit is contained in:
zefie
2025-06-22 21:59:27 -04:00
parent 0a1c412df1
commit 8999a984a7
1 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
zefie_wtvp_minisrv/includes/classes/WTVIRC.js
View File

@@ -275,11 +275,11 @@ class WTVIRC {
socket.secure = secure; socket.secure = secure;
socket.upgrading_to_tls = false; socket.upgrading_to_tls = false;
socket.error_count = 0; socket.error_count = 0;
socket.lastseen = Date.now(); socket.lastseen = this.getDate();
await this.doInitialHandshake(socket); await this.doInitialHandshake(socket);
socket.on('data', async data => { socket.on('data', async data => {
socket.lastseen = Date.now(); socket.lastseen = this.getDate();
await this.processSocketData(socket, data); await this.processSocketData(socket, data);
}); });
@@ -301,18 +301,18 @@ class WTVIRC {
clearInterval(socket._idleInterval); clearInterval(socket._idleInterval);
return; return;
} }
const now = Date.now(); const now = this.getDate();
if ((now - socket.lastseen) > (this.socket_timeout * 1000) + 10000) { if ((now - socket.lastseen) > this.socket_timeout + 10) {
// Over 10 seconds has passed since we sent our PING, assume lost // Over 10 seconds has passed since we sent our PING, assume lost
this.debugLog('warn', `Socket ${socket.remoteAddress} has been idle for too long, terminating session`); this.debugLog('warn', `Socket ${socket.remoteAddress} has been idle for too long, terminating session`);
if (socket.nickname) { if (socket.nickname) {
await this.broadcastUser(socket.nickname, `:${socket.nickname}!${socket.username}@${socket.host} QUIT :Ping timeout (${Math.floor((now - socket.lastseen) / 1000)} seconds)\r\n`, socket); await this.broadcastUser(socket.nickname, `:${socket.nickname}!${socket.username}@${socket.host} QUIT :Ping timeout (${now - socket.lastseen} seconds)\r\n`, socket);
await this.broadcastToAllServers(`:${socket.uniqueId} QUIT :Ping timeout (${Math.floor((now - socket.lastseen) / 1000)} seconds)\r\n`, serverSocket); await this.broadcastToAllServers(`:${socket.uniqueId} QUIT :Ping timeout (${now - socket.lastseen} seconds)\r\n`, serverSocket);
} }
socket.signedoff = true; socket.signedoff = true;
this.terminateSession(socket, true); this.terminateSession(socket, true);
return; return;
} else if ((now - socket.lastseen) > (this.socket_timeout * 1000)) { } else if ((now - socket.lastseen) > this.socket_timeout) {
// Client has been idle for too long, send PING // Client has been idle for too long, send PING
if (socket.isserver) { if (socket.isserver) {
await this.safeWriteToSocket(socket, `:${this.serverId} PING ${this.serverId} ${this.servername}\r\n`); await this.safeWriteToSocket(socket, `:${this.serverId} PING ${this.serverId} ${this.servername}\r\n`);