demostf/sync
1
0
Fork 0
mirror of https://github.com/demostf/sync.git synced 2026-06-03 10:34:06 +02:00
Code Issues Projects Releases Packages Wiki Activity

send stop packets when the session owner disconnects

Browse source
This commit is contained in:
Robin Appelman 2017-04-17 19:16:53 +02:00
commit b65cad5f19
2 changed files with 41 additions and 27 deletions
Download patch file Download diff file Expand all files Collapse all files

39
sync.js
View file

@ -1,5 +1,5 @@
"use strict"; "use strict";
Object.defineProperty(exports, "__esModule", { value: true }); exports.__esModule = true;
var websocket_1 = require("websocket"); var websocket_1 = require("websocket");
var http_1 = require("http"); var http_1 = require("http");
var sessions = {}; var sessions = {};
@ -18,6 +18,12 @@ var wsServer = new websocket_1.server({
function originIsAllowed(origin) { function originIsAllowed(origin) {
return true; return true;
} }
function sendToSession(session, message) {
for (var _i = 0, _a = session.clients; _i < _a.length; _i++) {
var client = _a[_i];
client.sendUTF(JSON.stringify(message));
}
}
wsServer.on('request', function (request) { wsServer.on('request', function (request) {
if (!originIsAllowed(request.origin)) { if (!originIsAllowed(request.origin)) {
// Make sure we only accept requests from an allowed origin // Make sure we only accept requests from an allowed origin
@ -55,25 +61,19 @@ wsServer.on('request', function (request) {
case 'tick': case 'tick':
if (sessions[data.session]) { if (sessions[data.session]) {
sessions[data.session].tick = data.tick; sessions[data.session].tick = data.tick;
for (var _i = 0, _a = sessions[data.session].clients; _i < _a.length; _i++) { sendToSession(sessions[data.session], {
var client = _a[_i]; type: 'tick',
client.sendUTF(JSON.stringify({ tick: data.tick
type: 'tick', });
tick: data.tick
}));
}
} }
break; break;
case 'play': case 'play':
if (sessions[data.session]) { if (sessions[data.session]) {
sessions[data.session].playing = data.play; sessions[data.session].playing = data.play;
for (var _b = 0, _c = sessions[data.session].clients; _b < _c.length; _b++) { sendToSession(sessions[data.session], {
var client = _c[_b]; type: 'play',
client.sendUTF(JSON.stringify({ play: data.play
type: 'play', });
play: data.play
}));
}
} }
} }
} }
@ -88,6 +88,9 @@ wsServer.on('request', function (request) {
session.clients.splice(index, 1); session.clients.splice(index, 1);
} }
if (session.owner === connection) { if (session.owner === connection) {
sendToSession(sessions[session.name], {
type: 'stop'
});
sessions[session.name] = null; sessions[session.name] = null;
break; break;
} }
@ -96,3 +99,9 @@ wsServer.on('request', function (request) {
} }
}); });
}); });
process.on('SIGINT', function () {
process.exit();
});
process.on('SIGTERM', function () {
process.exit();
});

29
sync.ts
View file

@ -54,6 +54,12 @@ function originIsAllowed(origin) {
return true; return true;
} }
function sendToSession(session: Session, message) {
for (const client of session.clients) {
client.sendUTF(JSON.stringify(message));
}
}
wsServer.on('request', function (request) { wsServer.on('request', function (request) {
if (!originIsAllowed(request.origin)) { if (!originIsAllowed(request.origin)) {
// Make sure we only accept requests from an allowed origin // Make sure we only accept requests from an allowed origin
@ -92,23 +98,19 @@ wsServer.on('request', function (request) {
case 'tick': case 'tick':
if (sessions[data.session]) { if (sessions[data.session]) {
sessions[data.session].tick = data.tick; sessions[data.session].tick = data.tick;
for (const client of sessions[data.session].clients) { sendToSession(sessions[data.session], {
client.sendUTF(JSON.stringify({ type: 'tick',
type: 'tick', tick: data.tick
tick: data.tick });
}));
}
} }
break; break;
case 'play': case 'play':
if (sessions[data.session]) { if (sessions[data.session]) {
sessions[data.session].playing = data.play; sessions[data.session].playing = data.play;
for (const client of sessions[data.session].clients) { sendToSession(sessions[data.session], {
client.sendUTF(JSON.stringify({ type: 'play',
type: 'play', play: data.play
play: data.play });
}));
}
} }
} }
} }
@ -123,6 +125,9 @@ wsServer.on('request', function (request) {
session.clients.splice(index, 1); session.clients.splice(index, 1);
} }
if (session.owner === connection) { if (session.owner === connection) {
sendToSession(sessions[session.name], {
type: 'stop'
});
sessions[session.name] = null; sessions[session.name] = null;
break; break;
} }