X-Git-Url: https://git.auder.net/?p=vchess.git;a=blobdiff_plain;f=server%2Fsockets.js;h=a8e393e6515e3f1a6f942c493f3b0dfb945164e2;hp=333fe77b47b90c9f77675ed63695b78a816df63b;hb=a6bddfc684bd3cc4defd7d49cc15bf59f2d9a9e9;hpb=5a3da96860d36e5131cc5c7c761ac46fb6787685 diff --git a/server/sockets.js b/server/sockets.js index 333fe77b..a8e393e6 100644 --- a/server/sockets.js +++ b/server/sockets.js @@ -33,7 +33,7 @@ module.exports = function(wss) { wss.on("connection", (socket, req) => { const query = getJsonFromUrl(req.url); const sid = query["sid"]; - // Ignore duplicate connections (on the same live game that we play): + // Ignore duplicate connections (on the same live game that we play): if (!!clients[sid]) return socket.send(JSON.stringify({code:"duplicate"})); clients[sid] = socket; @@ -49,23 +49,45 @@ module.exports = function(wss) { //console.log(obj.code); switch (obj.code) { - case "askclients": - socket.send(JSON.stringify({code:"clients", sockIds:Object.keys(clients).filter(k => k != sid)})); + case "pollclients": + socket.send(JSON.stringify({code:"pollclients", + sockIds:Object.keys(clients).filter(k => k != sid)})); break; case "askidentity": - clients[obj.target].send(JSON.stringify({code:"identify",from:sid})); + clients[obj.target].send( + JSON.stringify({code:"askidentity",from:sid})); + break; + case "askchallenge": + clients[obj.target].send( + JSON.stringify({code:"askchallenge",from:sid})); + break; + case "askgame": + clients[obj.target].send( + JSON.stringify({code:"askgame",from:sid})); break; case "identity": - clients[obj.target].send(JSON.stringify({code:"identity",user:obj.user})); + clients[obj.target].send( + JSON.stringify({code:"identity",user:obj.user})); + break; + case "challenge": + // Relay challenge to other player + clients[obj.target].send( + JSON.stringify({code:"challenge", chall:obj.chall, from:sid})); + break; + case "acceptchallenge": + clients[obj.target].send( + JSON.stringify({code:"acceptchallenge", cid:obj.cid, from:sid})); break; - case "askchallenges": - // TODO: ask directly to people (webRTC) - // TODO... + clarify socket system + case "withdrawchallenge": + clients[obj.target].send( + JSON.stringify({code:"withdrawchallenge", cid:obj.cid, from:sid})); break; - case "newchallenge": - clients[obj.target].send(JSON.stringify({code:"newchallenge",chall:obj.chall})); - case "askgames": - // TODO: ask directly to people (webRTC) + case "newgame": + clients[obj.target].send(JSON.stringify( + {code:"newgame", gameInfo:obj.gameInfo})); + break; + case "game": + // TODO: relay (live) game to other player break; case "newchat": clients[obj.target].send(JSON.stringify({code:"newchat",msg:obj.msg})); @@ -85,24 +107,12 @@ module.exports = function(wss) { clients[oppId].send(JSON.stringify(obj)); break; // TODO: moreover, here, game info should be sent (through challenge; not stored here) - case "newgame": - clients[obj.target].send(JSON.stringify({code:"newgame", game:obj.game})); - break; - case "cancelnewgame": //if a user cancel his seek - // TODO: just transmit event - //delete games[page]; - break; // TODO: also other challenge events case "resign": clients[obj.target].send(JSON.stringify({code:"resign"})); break; // TODO: case "challenge" (get ID) --> send to all, "acceptchallenge" (with ID) --> send to all, "cancelchallenge" --> send to all // also, "sendgame" (give current game info, if any) --> to new connections, "sendchallenges" (same for challenges) --> to new connections - case "newchallenge": - console.log("challenge received"); - console.log(obj.sender); - console.log(obj); - break; } }); socket.on("close", () => {