litruv/DAdmin
1
0
Fork 0
mirror of https://github.com/litruv/DAdmin.git synced 2026-07-24 02:36:11 +10:00
Code Issues Packages Projects Releases Wiki Activity

more wss stuff

Browse Source
This commit is contained in:
Litruv
2019-04-26 06:55:12 +10:00
parent 063dd42dab
commit b20cf372c4
1 changed files with 16 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
plugins/wss.js
View File

@@ -15,6 +15,8 @@ module.exports = {
const wss = new WebSocket.Server({ server }); const wss = new WebSocket.Server({ server });
wss.on('connection', function connection(ws) { wss.on('connection', function connection(ws) {
ws.isAlive = true;
ws.on('message', function incoming(message) { ws.on('message', function incoming(message) {
if (message == "name") if (message == "name")
ws.send(stringify( ws.send(stringify(
@@ -43,6 +45,8 @@ module.exports = {
}); });
ws.on('pong', heartbeat);
dclient.on('message', (message) => { dclient.on('message', (message) => {
wss.clients.forEach(function each(client) { wss.clients.forEach(function each(client) {
if (client !== ws && client.readyState === WebSocket.OPEN) { if (client !== ws && client.readyState === WebSocket.OPEN) {
@@ -54,8 +58,20 @@ module.exports = {
// ws.send('something'); // ws.send('something');
}); });
function noop() { }
function heartbeat() {
this.isAlive = true;
}
const interval = setInterval(function ping() {
wss.clients.forEach(function each(ws) {
if (ws.isAlive === false) return ws.terminate();
ws.isAlive = false;
ws.ping(noop);
});
}, 5000);
server.listen(8080); server.listen(8080);