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 = {}; | |
5bd05dba BA |
27 | wss.on("connection", (socket, req) => { |
28 | const query = getJsonFromUrl(req.url); | |
29 | const sid = query["sid"]; | |
8418f0d7 | 30 | const tmpId = query["tmpId"]; |
71468011 BA |
31 | const page = query["page"]; |
32 | const notifyRoom = (page,code,obj={}) => { | |
1611a25f | 33 | if (!clients[page]) return; |
71468011 BA |
34 | Object.keys(clients[page]).forEach(k => { |
35 | Object.keys(clients[page][k]).forEach(x => { | |
1611a25f BA |
36 | if (k == sid && x == tmpId) return; |
37 | send( | |
a041d5d8 BA |
38 | clients[page][k][x].socket, |
39 | Object.assign({ code: code, from: sid }, obj) | |
40 | ); | |
41 | }); | |
42 | }); | |
43 | }; | |
44 | // For focus events: no need to target self | |
45 | const notifyAllButMe = (page,code,obj={}) => { | |
46 | if (!clients[page]) return; | |
47 | Object.keys(clients[page]).forEach(k => { | |
48 | if (k == sid) return; | |
49 | Object.keys(clients[page][k]).forEach(x => { | |
50 | send( | |
51 | clients[page][k][x].socket, | |
aae89b49 | 52 | Object.assign({ code: code, from: sid }, obj) |
1611a25f | 53 | ); |
71468011 | 54 | }); |
92a523d1 BA |
55 | }); |
56 | }; | |
71468011 BA |
57 | const deleteConnexion = () => { |
58 | if (!clients[page] || !clients[page][sid] || !clients[page][sid][tmpId]) | |
59 | return; //job already done | |
60 | delete clients[page][sid][tmpId]; | |
1611a25f | 61 | if (Object.keys(clients[page][sid]).length == 0) { |
71468011 | 62 | delete clients[page][sid]; |
1611a25f | 63 | if (Object.keys(clients[page]).length == 0) |
71468011 BA |
64 | delete clients[page]; |
65 | } | |
66 | }; | |
1611a25f | 67 | |
f5f51daf BA |
68 | const doDisconnect = () => { |
69 | deleteConnexion(); | |
1611a25f | 70 | if (!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 => { | |
1611a25f | 142 | if (p != "/") { |
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 BA |
156 | case "asklastate": |
157 | case "askchallenge": | |
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 BA |
192 | case "newchallenge": |
193 | case "newgame": | |
194 | case "deletechallenge": | |
5bd05dba | 195 | case "resign": |
b988c726 | 196 | case "abort": |
2cc10cdb | 197 | case "drawoffer": |
2cc10cdb | 198 | case "draw": |
e5c1d0fb BA |
199 | notifyRoom(page, obj.code, {data: obj.data}); |
200 | break; | |
201 | ||
202 | case "newmove": { | |
aae89b49 | 203 | const dataWithFrom = { from: [sid,tmpId], data: obj.data }; |
f9c36b2d | 204 | // Special case re-send newmove only to opponent: |
e5c1d0fb | 205 | if (!!obj.target && !!clients[page][obj.target]) { |
f9c36b2d BA |
206 | Object.keys(clients[page][obj.target]).forEach(x => { |
207 | send( | |
a041d5d8 | 208 | clients[page][obj.target][x].socket, |
aae89b49 | 209 | Object.assign({ code: "newmove" }, dataWithFrom) |
f9c36b2d BA |
210 | ); |
211 | }); | |
e5c1d0fb BA |
212 | } else { |
213 | // NOTE: data.from is useful only to opponent | |
214 | notifyRoom(page, "newmove", dataWithFrom); | |
f9c36b2d | 215 | } |
f9c36b2d | 216 | break; |
e5c1d0fb | 217 | } |
f9c36b2d | 218 | case "gotmove": |
e5c1d0fb BA |
219 | if ( |
220 | !!clients[page][obj.target[0]] && | |
221 | !!clients[page][obj.target[0]][obj.target[1]] | |
222 | ) { | |
223 | send( | |
a041d5d8 | 224 | clients[page][obj.target[0]][obj.target[1]].socket, |
e01e086d | 225 | { code: "gotmove" } |
e5c1d0fb | 226 | ); |
f9c36b2d | 227 | } |
71468011 BA |
228 | break; |
229 | ||
48ab808f BA |
230 | case "result": |
231 | // Special case: notify all, 'transroom': Game --> Hall | |
aae89b49 | 232 | notifyRoom("/", "result", { gid: obj.gid, score: obj.score }); |
1611a25f BA |
233 | break; |
234 | ||
235 | case "mconnect": | |
236 | // Special case: notify some game rooms that | |
237 | // I'm watching game state from MyGames | |
238 | // TODO: this code is ignored for now | |
239 | obj.gids.forEach(gid => { | |
240 | const pg = "/game/" + gid; | |
241 | Object.keys(clients[pg]).forEach(s => { | |
242 | Object.keys(clients[pg][s]).forEach(x => { | |
243 | send( | |
a041d5d8 | 244 | clients[pg][s][x].socket, |
e01e086d | 245 | { code: "mconnect", from: sid } |
1611a25f BA |
246 | ); |
247 | }); | |
248 | }); | |
249 | }); | |
250 | break; | |
251 | case "mdisconnect": | |
252 | // TODO | |
253 | // Also TODO: pass newgame to MyGames, and gameover (result) | |
48ab808f | 254 | break; |
aae89b49 BA |
255 | case "mabort": { |
256 | const gamePg = "/game/" + obj.gid; | |
257 | if (!!clients[gamePg] && !!clients[gamePg][obj.target]) { | |
3b0f26c1 | 258 | Object.keys(clients[gamePg][obj.target]).forEach(x => { |
aae89b49 | 259 | send( |
a041d5d8 | 260 | clients[gamePg][obj.target][x].socket, |
aae89b49 BA |
261 | { code: "abort" } |
262 | ); | |
263 | }); | |
264 | } | |
265 | break; | |
266 | } | |
48ab808f | 267 | |
a041d5d8 BA |
268 | case "getfocus": |
269 | case "losefocus": | |
270 | if (page == "/") notifyAllButMe("/", obj.code, { page: "/" }); | |
271 | else { | |
272 | // Notify game room + Hall: | |
273 | notifyAllButMe(page, obj.code); | |
274 | notifyAllButMe("/", obj.code, { page: page }); | |
275 | } | |
276 | break; | |
277 | ||
71468011 BA |
278 | // Passing, relaying something: from isn't needed, |
279 | // but target is fully identified (sid + tmpId) | |
280 | case "challenge": | |
281 | case "fullgame": | |
282 | case "game": | |
283 | case "identity": | |
284 | case "lastate": | |
8b152ada BA |
285 | { |
286 | const pg = obj.target[2] || page; //required for identity and game | |
8477e53d | 287 | // NOTE: if in game we ask identity to opponent still in Hall, |
f9c36b2d | 288 | // but leaving Hall, clients[pg] or clients[pg][target] could be undefined |
aae89b49 BA |
289 | if (!!clients[pg] && !!clients[pg][obj.target[0]]) { |
290 | send( | |
a041d5d8 | 291 | clients[pg][obj.target[0]][obj.target[1]].socket, |
aae89b49 BA |
292 | { code:obj.code, data:obj.data } |
293 | ); | |
294 | } | |
2cc10cdb | 295 | break; |
8b152ada | 296 | } |
5bd05dba | 297 | } |
a3ac374b BA |
298 | }; |
299 | const closeListener = () => { | |
092de306 | 300 | // For browser or tab closing (including page reload): |
f5f51daf | 301 | doDisconnect(); |
a3ac374b | 302 | }; |
71468011 | 303 | // Update clients object: add new connexion |
a041d5d8 | 304 | const newElt = { socket: socket, focus: true }; |
71468011 | 305 | if (!clients[page]) |
a041d5d8 | 306 | clients[page] = { [sid]: {[tmpId]: newElt } }; |
71468011 | 307 | else if (!clients[page][sid]) |
a041d5d8 | 308 | clients[page][sid] = { [tmpId]: newElt }; |
71468011 | 309 | else |
a041d5d8 | 310 | clients[page][sid][tmpId] = newElt; |
a3ac374b BA |
311 | socket.on("message", messageListener); |
312 | socket.on("close", closeListener); | |
5bd05dba | 313 | }); |
1d184b4c | 314 | } |