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 |
98db2082 BA |
5 | function getJsonFromUrl(url) |
6 | { | |
80ee5d5a BA |
7 | const query = url.substr(2); //starts with "/?" |
8 | let result = {}; | |
9 | query.split("&").forEach((part) => { | |
5bd05dba BA |
10 | const item = part.split("="); |
11 | result[item[0]] = decodeURIComponent(item[1]); | |
12 | }); | |
13 | return result; | |
2807f530 BA |
14 | } |
15 | ||
1d184b4c | 16 | module.exports = function(wss) { |
5bd05dba BA |
17 | let clients = {}; //associative array sid --> socket |
18 | wss.on("connection", (socket, req) => { | |
19 | const query = getJsonFromUrl(req.url); | |
20 | const sid = query["sid"]; | |
c6788ecf | 21 | const notifyRoom = (page,code,obj={},excluded=[]) => { |
92a523d1 | 22 | Object.keys(clients).forEach(k => { |
c6788ecf BA |
23 | if (k in excluded) |
24 | return; | |
92a523d1 | 25 | if (k != sid && clients[k].page == page) |
5c8e044f BA |
26 | { |
27 | clients[k].sock.send(JSON.stringify(Object.assign( | |
c6788ecf | 28 | {code:code, from:sid}, obj))); |
5c8e044f | 29 | } |
92a523d1 BA |
30 | }); |
31 | }; | |
a3ac374b | 32 | const messageListener = (objtxt) => { |
5bd05dba | 33 | let obj = JSON.parse(objtxt); |
5a3da968 | 34 | if (!!obj.target && !clients[obj.target]) |
b4d619d1 | 35 | return; //receiver not connected, nothing we can do |
5bd05dba BA |
36 | switch (obj.code) |
37 | { | |
a3ac374b BA |
38 | case "duplicate": |
39 | // Turn off message listening, and send disconnect if needed: | |
40 | socket.removeListener("message", messageListener); | |
41 | socket.removeListener("close", closeListener); | |
d641bec1 | 42 | // From obj.page to clients[sid].page (TODO: unclear) |
a3ac374b BA |
43 | if (clients[sid].page != obj.page) |
44 | { | |
d641bec1 BA |
45 | notifyRoom(obj.page, "disconnect"); |
46 | if (obj.page.indexOf("/game/") >= 0) | |
a3ac374b BA |
47 | notifyRoom("/", "gdisconnect"); |
48 | } | |
49 | break; | |
50 | // Wait for "connect" message to notify connection to the room, | |
51 | // because if game loading is slow the message listener might | |
52 | // not be ready too early. | |
41c80bb6 | 53 | case "connect": |
120fe373 BA |
54 | { |
55 | const curPage = clients[sid].page; | |
56 | notifyRoom(curPage, "connect"); //Hall or Game | |
57 | if (curPage.indexOf("/game/") >= 0) | |
ac8f441c | 58 | notifyRoom("/", "gconnect"); //notify main hall |
41c80bb6 | 59 | break; |
120fe373 | 60 | } |
81d9ce72 | 61 | case "pollclients": |
ac8f441c | 62 | { |
f41ce580 | 63 | const curPage = clients[sid].page; |
81d9ce72 | 64 | socket.send(JSON.stringify({code:"pollclients", |
ac8f441c BA |
65 | sockIds: Object.keys(clients).filter(k => |
66 | k != sid && clients[k].page == curPage | |
c6788ecf | 67 | )})); |
92a523d1 | 68 | break; |
ac8f441c BA |
69 | } |
70 | case "pollgamers": | |
ac8f441c BA |
71 | socket.send(JSON.stringify({code:"pollgamers", |
72 | sockIds: Object.keys(clients).filter(k => | |
73 | k != sid && clients[k].page.indexOf("/game/") >= 0 | |
74 | )})); | |
75 | break; | |
92a523d1 | 76 | case "pagechange": |
9335d45b | 77 | // page change clients[sid].page --> obj.page |
a0c41e7e | 78 | // TODO: some offline rooms don't need to receive disconnect event |
c6788ecf | 79 | notifyRoom(clients[sid].page, "disconnect"); |
bcaa8c00 | 80 | if (clients[sid].page.indexOf("/game/") >= 0) |
ac8f441c | 81 | notifyRoom("/", "gdisconnect"); |
92a523d1 | 82 | clients[sid].page = obj.page; |
a0c41e7e BA |
83 | // No need to notify connection: it's self-sent in .vue file |
84 | //notifyRoom(obj.page, "connect"); | |
bcaa8c00 | 85 | if (obj.page.indexOf("/game/") >= 0) |
ac8f441c | 86 | notifyRoom("/", "gconnect"); |
5a3da968 BA |
87 | break; |
88 | case "askidentity": | |
f41ce580 BA |
89 | clients[obj.target].sock.send(JSON.stringify( |
90 | {code:"askidentity",from:sid})); | |
81d9ce72 | 91 | break; |
a0c41e7e BA |
92 | case "asklastate": |
93 | clients[obj.target].sock.send(JSON.stringify( | |
94 | {code:"asklastate",from:sid})); | |
95 | break; | |
dd75774d | 96 | case "askchallenge": |
f41ce580 BA |
97 | clients[obj.target].sock.send(JSON.stringify( |
98 | {code:"askchallenge",from:sid})); | |
81d9ce72 | 99 | break; |
cd0d7743 | 100 | case "askgames": |
dc284d90 | 101 | { |
c6788ecf | 102 | // Check all clients playing, and send them a "askgame" message |
dc284d90 BA |
103 | let gameSids = {}; //game ID --> [sid1, sid2] |
104 | const regexpGid = /\/[a-zA-Z0-9]+$/; | |
c6788ecf BA |
105 | Object.keys(clients).forEach(k => { |
106 | if (k != sid && clients[k].page.indexOf("/game/") >= 0) | |
107 | { | |
dc284d90 BA |
108 | const gid = clients[k].page.match(regexpGid)[0]; |
109 | if (!gameSids[gid]) | |
110 | gameSids[gid] = [k]; | |
111 | else | |
112 | gameSids[gid].push(k); | |
c6788ecf BA |
113 | } |
114 | }); | |
dc284d90 BA |
115 | // Request only one client out of 2 (TODO: this is a bit heavy) |
116 | // Alt: ask game to all, and filter later? | |
117 | Object.keys(gameSids).forEach(gid => { | |
118 | const L = gameSids[gid].length; | |
119 | const idx = L > 1 | |
120 | ? Math.floor(Math.random() * Math.floor(L)) | |
121 | : 0; | |
122 | const rid = gameSids[gid][idx]; | |
123 | clients[rid].sock.send(JSON.stringify( | |
ab6f48ea | 124 | {code:"askgame", from: sid})); |
dc284d90 BA |
125 | }); |
126 | break; | |
127 | } | |
26f3a887 BA |
128 | case "askgame": |
129 | clients[obj.target].sock.send(JSON.stringify( | |
130 | {code:"askgame", from:sid})); | |
131 | break; | |
dc284d90 BA |
132 | case "askfullgame": |
133 | clients[obj.target].sock.send(JSON.stringify( | |
134 | {code:"askfullgame", from:sid})); | |
135 | break; | |
136 | case "fullgame": | |
137 | clients[obj.target].sock.send(JSON.stringify( | |
138 | {code:"fullgame", game:obj.game})); | |
5a3da968 BA |
139 | break; |
140 | case "identity": | |
f41ce580 BA |
141 | clients[obj.target].sock.send(JSON.stringify( |
142 | {code:"identity",user:obj.user})); | |
4d64881e | 143 | break; |
5bd05dba | 144 | case "refusechallenge": |
f41ce580 BA |
145 | clients[obj.target].sock.send(JSON.stringify( |
146 | {code:"refusechallenge", cid:obj.cid, from:sid})); | |
5bd05dba | 147 | break; |
98f48579 | 148 | case "deletechallenge": |
f41ce580 BA |
149 | clients[obj.target].sock.send(JSON.stringify( |
150 | {code:"deletechallenge", cid:obj.cid, from:sid})); | |
98f48579 | 151 | break; |
a6bddfc6 | 152 | case "newgame": |
92a523d1 | 153 | clients[obj.target].sock.send(JSON.stringify( |
5bd05dba | 154 | {code:"newgame", gameInfo:obj.gameInfo, cid:obj.cid})); |
a6bddfc6 | 155 | break; |
42c15a75 | 156 | case "challenge": |
92a523d1 | 157 | clients[obj.target].sock.send(JSON.stringify( |
42c15a75 BA |
158 | {code:"challenge", chall:obj.chall, from:sid})); |
159 | break; | |
dd75774d | 160 | case "game": |
c6788ecf BA |
161 | if (!!obj.target) |
162 | { | |
163 | clients[obj.target].sock.send(JSON.stringify( | |
80ee5d5a | 164 | {code:"game", game:obj.game, from:sid})); |
c6788ecf BA |
165 | } |
166 | else | |
167 | { | |
168 | // Notify all room except opponent and me: | |
80ee5d5a | 169 | notifyRoom("/", "game", {game:obj.game}, [obj.oppsid]); |
c6788ecf | 170 | } |
4d64881e | 171 | break; |
5bd05dba | 172 | case "newchat": |
ac8f441c | 173 | notifyRoom(clients[sid].page, "newchat", {chat:obj.chat}); |
5bd05dba | 174 | break; |
5bd05dba | 175 | // TODO: WebRTC instead in this case (most demanding?) |
26f3a887 | 176 | // --> Or else: at least do a "notifyRoom" (also for draw, resign...) |
5bd05dba | 177 | case "newmove": |
f41ce580 | 178 | clients[obj.target].sock.send(JSON.stringify( |
c6788ecf | 179 | {code:"newmove", move:obj.move})); |
5bd05dba BA |
180 | break; |
181 | case "lastate": | |
f41ce580 BA |
182 | clients[obj.target].sock.send(JSON.stringify( |
183 | {code:"lastate", state:obj.state})); | |
5bd05dba | 184 | break; |
5bd05dba | 185 | case "resign": |
f41ce580 | 186 | clients[obj.target].sock.send(JSON.stringify( |
3837d4f7 | 187 | {code:"resign", side:obj.side})); |
5bd05dba | 188 | break; |
b988c726 | 189 | case "abort": |
f41ce580 | 190 | clients[obj.target].sock.send(JSON.stringify( |
3837d4f7 | 191 | {code:"abort"})); |
b988c726 | 192 | break; |
2cc10cdb | 193 | case "drawoffer": |
f41ce580 BA |
194 | clients[obj.target].sock.send(JSON.stringify( |
195 | {code:"drawoffer"})); | |
2cc10cdb BA |
196 | break; |
197 | case "draw": | |
f41ce580 | 198 | clients[obj.target].sock.send(JSON.stringify( |
dcd68c41 | 199 | {code:"draw", message:obj.message})); |
2cc10cdb | 200 | break; |
5bd05dba | 201 | } |
a3ac374b BA |
202 | }; |
203 | const closeListener = () => { | |
92a523d1 | 204 | const page = clients[sid].page; |
5bd05dba | 205 | delete clients[sid]; |
92a523d1 | 206 | notifyRoom(page, "disconnect"); |
bcaa8c00 | 207 | if (page.indexOf("/game/") >= 0) |
ac8f441c | 208 | notifyRoom("/", "gdisconnect"); //notify main hall |
a3ac374b BA |
209 | }; |
210 | if (!!clients[sid]) | |
211 | { | |
212 | // Turn off old sock through current client: | |
213 | clients[sid].sock.send(JSON.stringify({code:"duplicate"})); | |
214 | } | |
215 | // Potentially replace current connection: | |
216 | clients[sid] = {sock: socket, page: query["page"]}; | |
217 | socket.on("message", messageListener); | |
218 | socket.on("close", closeListener); | |
5bd05dba | 219 | }); |
1d184b4c | 220 | } |