Commit | Line | Data |
---|---|---|
a29d9d6b | 1 | const url = require('url'); |
1d184b4c | 2 | |
2807f530 | 3 | // Node version in Ubuntu 16.04 does not know about URL class |
a0c41e7e | 4 | // NOTE: url is already transformed, without ?xxx=yyy... parts |
1611a25f | 5 | function getJsonFromUrl(url) { |
80ee5d5a BA |
6 | const query = url.substr(2); //starts with "/?" |
7 | let result = {}; | |
8 | query.split("&").forEach((part) => { | |
5bd05dba BA |
9 | const item = part.split("="); |
10 | result[item[0]] = decodeURIComponent(item[1]); | |
11 | }); | |
12 | return result; | |
2807f530 BA |
13 | } |
14 | ||
8b152ada | 15 | // Helper to safe-send some message through a (web-)socket: |
1611a25f | 16 | function send(socket, message) { |
f9c36b2d | 17 | if (!!socket && socket.readyState == 1) |
8b152ada BA |
18 | socket.send(JSON.stringify(message)); |
19 | } | |
20 | ||
1d184b4c | 21 | module.exports = function(wss) { |
71468011 | 22 | // Associative array page --> sid --> tmpId --> socket |
8418f0d7 | 23 | // "page" is either "/" for hall or "/game/some_gid" for Game, |
a041d5d8 | 24 | // or "/mygames" for Mygames page (simpler: no 'people' array). |
8418f0d7 BA |
25 | // tmpId is required if a same user (browser) has different tabs |
26 | let clients = {}; | |
cafe0166 BA |
27 | let sidToPages = {}; |
28 | let idToSid = {}; | |
5bd05dba BA |
29 | wss.on("connection", (socket, req) => { |
30 | const query = getJsonFromUrl(req.url); | |
31 | const sid = query["sid"]; | |
cafe0166 | 32 | const id = query["id"]; |
8418f0d7 | 33 | const tmpId = query["tmpId"]; |
71468011 | 34 | const page = query["page"]; |
f14572c4 | 35 | const notifyRoom = (page, code, obj={}, except) => { |
a041d5d8 | 36 | if (!clients[page]) return; |
f14572c4 | 37 | except = except || []; |
a041d5d8 | 38 | Object.keys(clients[page]).forEach(k => { |
856f995c | 39 | if (except.includes(k)) return; |
a041d5d8 | 40 | Object.keys(clients[page][k]).forEach(x => { |
f14572c4 | 41 | if (k == sid && x == tmpId) return; |
a041d5d8 BA |
42 | send( |
43 | clients[page][k][x].socket, | |
aae89b49 | 44 | Object.assign({ code: code, from: sid }, obj) |
1611a25f | 45 | ); |
71468011 | 46 | }); |
92a523d1 BA |
47 | }); |
48 | }; | |
71468011 BA |
49 | const deleteConnexion = () => { |
50 | if (!clients[page] || !clients[page][sid] || !clients[page][sid][tmpId]) | |
51 | return; //job already done | |
52 | delete clients[page][sid][tmpId]; | |
1611a25f | 53 | if (Object.keys(clients[page][sid]).length == 0) { |
71468011 | 54 | delete clients[page][sid]; |
cafe0166 BA |
55 | const pgIndex = sidToPages[sid].findIndex(pg => pg == page); |
56 | sidToPages[sid].splice(pgIndex, 1); | |
1611a25f | 57 | if (Object.keys(clients[page]).length == 0) |
71468011 | 58 | delete clients[page]; |
cafe0166 BA |
59 | // Am I totally offline? |
60 | if (sidToPages[sid].length == 0) { | |
61 | delete sidToPages[sid]; | |
62 | delete idToSid[id]; | |
63 | } | |
71468011 BA |
64 | } |
65 | }; | |
1611a25f | 66 | |
f5f51daf BA |
67 | const doDisconnect = () => { |
68 | deleteConnexion(); | |
cafe0166 BA |
69 | // Nothing to notify when disconnecting from MyGames page: |
70 | if (page != "/mygames" && (!clients[page] || !clients[page][sid])) { | |
f5f51daf BA |
71 | // I effectively disconnected from this page: |
72 | notifyRoom(page, "disconnect"); | |
73 | if (page.indexOf("/game/") >= 0) | |
aae89b49 | 74 | notifyRoom("/", "gdisconnect", { page:page }); |
f5f51daf BA |
75 | } |
76 | }; | |
a3ac374b | 77 | const messageListener = (objtxt) => { |
5bd05dba | 78 | let obj = JSON.parse(objtxt); |
1611a25f | 79 | switch (obj.code) { |
a3ac374b BA |
80 | // Wait for "connect" message to notify connection to the room, |
81 | // because if game loading is slow the message listener might | |
82 | // not be ready too early. | |
1611a25f | 83 | case "connect": { |
71468011 BA |
84 | notifyRoom(page, "connect"); |
85 | if (page.indexOf("/game/") >= 0) | |
aae89b49 | 86 | notifyRoom("/", "gconnect", { page:page }); |
41c80bb6 | 87 | break; |
120fe373 | 88 | } |
8418f0d7 | 89 | case "disconnect": |
71468011 | 90 | // When page changes: |
f5f51daf | 91 | doDisconnect(); |
8418f0d7 | 92 | break; |
1611a25f | 93 | case "killme": { |
51d87b52 BA |
94 | // Self multi-connect: manual removal + disconnect |
95 | const doKill = (pg) => { | |
96 | Object.keys(clients[pg][obj.sid]).forEach(x => { | |
a041d5d8 | 97 | send(clients[pg][obj.sid][x].socket, { code: "killed" }); |
51d87b52 BA |
98 | }); |
99 | delete clients[pg][obj.sid]; | |
100 | }; | |
101 | const disconnectFromOtherConnexion = (pg,code,o={}) => { | |
102 | Object.keys(clients[pg]).forEach(k => { | |
1611a25f | 103 | if (k != obj.sid) { |
51d87b52 | 104 | Object.keys(clients[pg][k]).forEach(x => { |
1611a25f | 105 | send( |
a041d5d8 | 106 | clients[pg][k][x].socket, |
aae89b49 | 107 | Object.assign({ code: code, from: obj.sid }, o) |
1611a25f | 108 | ); |
51d87b52 BA |
109 | }); |
110 | } | |
111 | }); | |
112 | }; | |
113 | Object.keys(clients).forEach(pg => { | |
1611a25f | 114 | if (clients[pg][obj.sid]) { |
51d87b52 BA |
115 | doKill(pg); |
116 | disconnectFromOtherConnexion(pg, "disconnect"); | |
1611a25f | 117 | if (pg.indexOf("/game/") >= 0 && clients["/"]) |
aae89b49 | 118 | disconnectFromOtherConnexion("/", "gdisconnect", { page: pg }); |
51d87b52 BA |
119 | } |
120 | }); | |
121 | break; | |
122 | } | |
1611a25f BA |
123 | case "pollclients": { |
124 | // From Hall or Game | |
71468011 BA |
125 | let sockIds = []; |
126 | Object.keys(clients[page]).forEach(k => { | |
51d87b52 | 127 | // Avoid polling myself: no new information to get |
1611a25f | 128 | if (k != sid) sockIds.push(k); |
8418f0d7 | 129 | }); |
aae89b49 | 130 | send(socket, { code: "pollclients", sockIds: sockIds }); |
92a523d1 | 131 | break; |
ac8f441c | 132 | } |
1611a25f BA |
133 | case "pollclientsandgamers": { |
134 | // From Hall | |
71468011 BA |
135 | let sockIds = []; |
136 | Object.keys(clients["/"]).forEach(k => { | |
51d87b52 | 137 | // Avoid polling myself: no new information to get |
1611a25f | 138 | if (k != sid) sockIds.push({sid:k}); |
71468011 BA |
139 | }); |
140 | // NOTE: a "gamer" could also just be an observer | |
141 | Object.keys(clients).forEach(p => { | |
cafe0166 | 142 | if (p.indexOf("/game/") >= 0) { |
71468011 | 143 | Object.keys(clients[p]).forEach(k => { |
1611a25f | 144 | // 'page' indicator is needed for gamers |
aae89b49 | 145 | if (k != sid) sockIds.push({ sid:k, page:p }); |
71468011 BA |
146 | }); |
147 | } | |
8418f0d7 | 148 | }); |
aae89b49 | 149 | send(socket, { code: "pollclientsandgamers", sockIds: sockIds }); |
5a3da968 | 150 | break; |
8418f0d7 | 151 | } |
71468011 BA |
152 | |
153 | // Asking something: from is fully identified, | |
154 | // but the requested resource can be from any tmpId (except current!) | |
5a3da968 | 155 | case "askidentity": |
71468011 | 156 | case "asklastate": |
28b32b4f | 157 | case "askchallenges": |
71468011 | 158 | case "askgame": |
1611a25f | 159 | case "askfullgame": { |
8b152ada | 160 | const pg = obj.page || page; //required for askidentity and askgame |
910d631b | 161 | // In cas askfullgame to wrong SID for example, would crash: |
f9c36b2d | 162 | if (!!clients[pg] && !!clients[pg][obj.target]) { |
910d631b | 163 | const tmpIds = Object.keys(clients[pg][obj.target]); |
1611a25f BA |
164 | if (obj.target == sid) { |
165 | // Targetting myself | |
910d631b | 166 | const idx_myTmpid = tmpIds.findIndex(x => x == tmpId); |
1611a25f | 167 | if (idx_myTmpid >= 0) tmpIds.splice(idx_myTmpid, 1); |
910d631b BA |
168 | } |
169 | const tmpId_idx = Math.floor(Math.random() * tmpIds.length); | |
170 | send( | |
a041d5d8 | 171 | clients[pg][obj.target][tmpIds[tmpId_idx]].socket, |
aae89b49 | 172 | { code: obj.code, from: [sid,tmpId,page] } |
910d631b | 173 | ); |
71468011 | 174 | } |
81d9ce72 | 175 | break; |
8418f0d7 | 176 | } |
71468011 BA |
177 | |
178 | // Some Hall events: target all tmpId's (except mine), | |
179 | case "refusechallenge": | |
180 | case "startgame": | |
181 | Object.keys(clients[page][obj.target]).forEach(x => { | |
182 | if (obj.target != sid || x != tmpId) | |
1611a25f | 183 | send( |
a041d5d8 | 184 | clients[page][obj.target][x].socket, |
aae89b49 | 185 | { code: obj.code, data: obj.data } |
1611a25f | 186 | ); |
c6788ecf | 187 | }); |
4d64881e | 188 | break; |
71468011 BA |
189 | |
190 | // Notify all room: mostly game events | |
5bd05dba | 191 | case "newchat": |
71468011 | 192 | case "newchallenge": |
28b32b4f | 193 | case "deletechallenge_s": |
c292ebb2 | 194 | case "newgame": |
5bd05dba | 195 | case "resign": |
b988c726 | 196 | case "abort": |
2cc10cdb | 197 | case "drawoffer": |
c292ebb2 | 198 | case "rematchoffer": |
2cc10cdb | 199 | case "draw": |
f14572c4 | 200 | notifyRoom(page, obj.code, {data: obj.data}, obj.excluded); |
c292ebb2 BA |
201 | break; |
202 | ||
203 | case "rnewgame": | |
585d0955 | 204 | // A rematch game started: |
f14572c4 BA |
205 | notifyRoom(page, "newgame", {data: obj.data}); |
206 | // Explicitely notify Hall if gametype == corr. | |
207 | // Live games will be polled from Hall after gconnect event. | |
208 | if (obj.data.cadence.indexOf('d') >= 0) | |
209 | notifyRoom("/", "newgame", {data: obj.data}); | |
e5c1d0fb BA |
210 | break; |
211 | ||
212 | case "newmove": { | |
aae89b49 | 213 | const dataWithFrom = { from: [sid,tmpId], data: obj.data }; |
f9c36b2d | 214 | // Special case re-send newmove only to opponent: |
e5c1d0fb | 215 | if (!!obj.target && !!clients[page][obj.target]) { |
f9c36b2d BA |
216 | Object.keys(clients[page][obj.target]).forEach(x => { |
217 | send( | |
a041d5d8 | 218 | clients[page][obj.target][x].socket, |
aae89b49 | 219 | Object.assign({ code: "newmove" }, dataWithFrom) |
f9c36b2d BA |
220 | ); |
221 | }); | |
e5c1d0fb BA |
222 | } else { |
223 | // NOTE: data.from is useful only to opponent | |
224 | notifyRoom(page, "newmove", dataWithFrom); | |
f9c36b2d | 225 | } |
f9c36b2d | 226 | break; |
e5c1d0fb | 227 | } |
f9c36b2d | 228 | case "gotmove": |
e5c1d0fb BA |
229 | if ( |
230 | !!clients[page][obj.target[0]] && | |
231 | !!clients[page][obj.target[0]][obj.target[1]] | |
232 | ) { | |
233 | send( | |
a041d5d8 | 234 | clients[page][obj.target[0]][obj.target[1]].socket, |
e01e086d | 235 | { code: "gotmove" } |
e5c1d0fb | 236 | ); |
f9c36b2d | 237 | } |
71468011 BA |
238 | break; |
239 | ||
48ab808f BA |
240 | case "result": |
241 | // Special case: notify all, 'transroom': Game --> Hall | |
aae89b49 | 242 | notifyRoom("/", "result", { gid: obj.gid, score: obj.score }); |
1611a25f BA |
243 | break; |
244 | ||
aae89b49 BA |
245 | case "mabort": { |
246 | const gamePg = "/game/" + obj.gid; | |
247 | if (!!clients[gamePg] && !!clients[gamePg][obj.target]) { | |
3b0f26c1 | 248 | Object.keys(clients[gamePg][obj.target]).forEach(x => { |
aae89b49 | 249 | send( |
a041d5d8 | 250 | clients[gamePg][obj.target][x].socket, |
aae89b49 BA |
251 | { code: "abort" } |
252 | ); | |
253 | }); | |
254 | } | |
255 | break; | |
256 | } | |
48ab808f | 257 | |
cafe0166 BA |
258 | case "notifyscore": |
259 | case "notifyturn": | |
260 | case "notifynewgame": | |
261 | if (!!clients["/mygames"]) { | |
262 | obj.targets.forEach(t => { | |
0234201f | 263 | const k = t.sid || idToSid[t.id]; |
cafe0166 BA |
264 | if (!!clients["/mygames"][k]) { |
265 | Object.keys(clients["/mygames"][k]).forEach(x => { | |
266 | send( | |
267 | clients["/mygames"][k][x].socket, | |
268 | { code: obj.code, data: obj.data } | |
269 | ); | |
270 | }); | |
271 | } | |
272 | }); | |
273 | } | |
274 | break; | |
275 | ||
a041d5d8 BA |
276 | case "getfocus": |
277 | case "losefocus": | |
f14572c4 | 278 | if (page == "/") notifyRoom("/", obj.code, { page: "/" }, [sid]); |
a041d5d8 BA |
279 | else { |
280 | // Notify game room + Hall: | |
f14572c4 BA |
281 | notifyRoom(page, obj.code, {}, [sid]); |
282 | notifyRoom("/", obj.code, { page: page }, [sid]); | |
a041d5d8 BA |
283 | } |
284 | break; | |
285 | ||
71468011 BA |
286 | // Passing, relaying something: from isn't needed, |
287 | // but target is fully identified (sid + tmpId) | |
28b32b4f | 288 | case "challenges": |
71468011 BA |
289 | case "fullgame": |
290 | case "game": | |
291 | case "identity": | |
292 | case "lastate": | |
8b152ada BA |
293 | { |
294 | const pg = obj.target[2] || page; //required for identity and game | |
8477e53d | 295 | // NOTE: if in game we ask identity to opponent still in Hall, |
f9c36b2d | 296 | // but leaving Hall, clients[pg] or clients[pg][target] could be undefined |
aae89b49 BA |
297 | if (!!clients[pg] && !!clients[pg][obj.target[0]]) { |
298 | send( | |
a041d5d8 | 299 | clients[pg][obj.target[0]][obj.target[1]].socket, |
aae89b49 BA |
300 | { code:obj.code, data:obj.data } |
301 | ); | |
302 | } | |
2cc10cdb | 303 | break; |
8b152ada | 304 | } |
5bd05dba | 305 | } |
a3ac374b BA |
306 | }; |
307 | const closeListener = () => { | |
092de306 | 308 | // For browser or tab closing (including page reload): |
f5f51daf | 309 | doDisconnect(); |
a3ac374b | 310 | }; |
71468011 | 311 | // Update clients object: add new connexion |
a041d5d8 | 312 | const newElt = { socket: socket, focus: true }; |
71468011 | 313 | if (!clients[page]) |
a041d5d8 | 314 | clients[page] = { [sid]: {[tmpId]: newElt } }; |
71468011 | 315 | else if (!clients[page][sid]) |
a041d5d8 | 316 | clients[page][sid] = { [tmpId]: newElt }; |
71468011 | 317 | else |
a041d5d8 | 318 | clients[page][sid][tmpId] = newElt; |
cafe0166 BA |
319 | // Also update helper correspondances |
320 | if (!idToSid[id]) idToSid[id] = sid; | |
321 | if (!sidToPages[sid]) sidToPages[sid] = []; | |
322 | const pgIndex = sidToPages[sid].findIndex(pg => pg == page); | |
323 | if (pgIndex === -1) sidToPages[sid].push(page); | |
a3ac374b BA |
324 | socket.on("message", messageListener); |
325 | socket.on("close", closeListener); | |
5bd05dba | 326 | }); |
1d184b4c | 327 | } |