Added ping.
This commit is contained in:
parent
c9b985f768
commit
73e60b81f1
24
src/schat.js
24
src/schat.js
|
@ -149,7 +149,14 @@ async function connect(bot, games) {
|
|||
},
|
||||
});
|
||||
|
||||
socket.ws.on('message', async (msg) => {
|
||||
socket.ws.on('message', async (msgData) => {
|
||||
const msg = msgData.toString();
|
||||
|
||||
if (typeof msg === 'string' && msg.includes('pong')) {
|
||||
logger.debug(`Received pong ${msg.split(':')[1]}`);
|
||||
return;
|
||||
}
|
||||
|
||||
const [domain, data] = JSON.parse(msg);
|
||||
|
||||
logger.debug(`Received ${domain}: ${JSON.stringify(data)}`);
|
||||
|
@ -187,6 +194,21 @@ async function connect(bot, games) {
|
|||
socket.ws.send(JSON.stringify([domain, data]));
|
||||
};
|
||||
|
||||
function ping() {
|
||||
setTimeout(() => {
|
||||
if (socket.ws && socket.ws?.readyState === socket.ws?.OPEN) {
|
||||
const now = Date.now();
|
||||
|
||||
socket.ws.send(`ping:${now}`);
|
||||
logger.debug(`Sent ping ${now}`);
|
||||
}
|
||||
|
||||
ping();
|
||||
}, 10000);
|
||||
}
|
||||
|
||||
ping();
|
||||
|
||||
socket.connect();
|
||||
|
||||
return socket;
|
||||
|
|
Loading…
Reference in New Issue