X-Git-Url: https://git.auder.net/?a=blobdiff_plain;f=server%2Fsockets.js;h=fcda981624f00650a8174dd5b8b79b5f0d15b090;hb=2cc10cdbc230f82202bdddb7a244c903c05ab351;hp=d92778c00e435c6b4ddb76be2ae3190383b4dcab;hpb=d4036efea5b57656478affd7d71f53dcea0f8017;p=vchess.git diff --git a/server/sockets.js b/server/sockets.js index d92778c0..fcda9816 100644 --- a/server/sockets.js +++ b/server/sockets.js @@ -12,27 +12,12 @@ function getJsonFromUrl(url) return result; } -// Removal in array of strings (socket IDs) -function remInArray(arr, item) -{ - const idx = arr.indexOf(item); - if (idx >= 0) - arr.splice(idx, 1); -} - -// TODO: empêcher multi-log du même user (envoyer le user ID + secret en même temps que name et...) -// --> si secret ne matche pas celui trouvé en DB, stop -// TODO: lorsque challenge accepté, seul le dernier joueur à accepter envoi message "please start game" -// avec les coordonnées des participants. Le serveur renvoit alors les détails de la partie (couleurs, position) -//TODO: programmatic re-navigation on current game if we receive a move and are not there - module.exports = function(wss) { let clients = {}; //associative array sid --> socket wss.on("connection", (socket, req) => { const query = getJsonFromUrl(req.url); const sid = query["sid"]; // TODO: later, allow duplicate connections (shouldn't be much more complicated) - // Ignore duplicate connections (on the same live game that we play): if (!!clients[sid]) return socket.send(JSON.stringify({code:"duplicate"})); clients[sid] = socket; @@ -98,14 +83,13 @@ module.exports = function(wss) { case "newchat": clients[obj.target].send(JSON.stringify({code:"newchat",msg:obj.msg})); break; - // Transmit chats and moves to current room // TODO: WebRTC instead in this case (most demanding?) case "newmove": clients[obj.target].send(JSON.stringify({code:"newmove",move:obj.move})); break; - // TODO: generalize that for several opponents case "ping": - socket.send(JSON.stringify({code:"pong",gameId:obj.gameId})); + // If this code is reached, then obj.target is connected + socket.send(JSON.stringify({code:"pong"})); break; case "lastate": const oppId = obj.target; @@ -118,6 +102,12 @@ module.exports = function(wss) { case "abort": clients[obj.target].send(JSON.stringify({code:"abort",msg:obj.msg})); break; + case "drawoffer": + clients[obj.target].send(JSON.stringify({code:"drawoffer"})); + break; + case "draw": + clients[obj.target].send(JSON.stringify({code:"draw"})); + break; } }); socket.on("close", () => {