1 const url
= require('url');
3 // Node version in Ubuntu 16.04 does not know about URL class
4 // NOTE: url is already transformed, without ?xxx=yyy... parts
5 function getJsonFromUrl(url
) {
6 const query
= url
.substr(2); //starts with "/?"
8 query
.split("&").forEach((part
) => {
9 const item
= part
.split("=");
10 result
[item
[0]] = decodeURIComponent(item
[1]);
15 // Helper to safe-send some message through a (web-)socket:
16 function send(socket
, message
) {
17 if (!!socket
&& socket
.readyState
== 1)
18 socket
.send(JSON
.stringify(message
));
21 module
.exports = function(wss
) {
22 // Associative array page --> sid --> tmpId --> socket
23 // "page" is either "/" for hall or "/game/some_gid" for Game,
24 // or "/mygames" for Mygames page (simpler: no 'people' array).
25 // tmpId is required if a same user (browser) has different tabs
27 // NOTE: only purpose of sidToPages = know when to delete keys in idToSid
30 wss
.on("connection", (socket
, req
) => {
31 const query
= getJsonFromUrl(req
.url
);
32 const sid
= query
["sid"];
33 const id
= query
["id"];
34 const tmpId
= query
["tmpId"];
35 const page
= query
["page"];
36 const notifyRoom
= (page
, code
, obj
={}, except
) => {
37 if (!clients
[page
]) return;
38 except
= except
|| [];
39 Object
.keys(clients
[page
]).forEach(k
=> {
40 if (except
.includes(k
)) return;
41 Object
.keys(clients
[page
][k
]).forEach(x
=> {
42 if (k
== sid
&& x
== tmpId
) return;
44 clients
[page
][k
][x
].socket
,
45 Object
.assign({ code: code
, from: [sid
, tmpId
] }, obj
)
50 const deleteConnexion
= () => {
51 if (!clients
[page
] || !clients
[page
][sid
] || !clients
[page
][sid
][tmpId
])
52 return; //job already done
53 delete clients
[page
][sid
][tmpId
];
54 if (Object
.keys(clients
[page
][sid
]).length
== 0) {
55 delete clients
[page
][sid
];
56 const pgIndex
= sidToPages
[sid
].findIndex(pg
=> pg
== page
);
57 sidToPages
[sid
].splice(pgIndex
, 1);
58 if (Object
.keys(clients
[page
]).length
== 0)
60 // Am I totally offline?
61 if (sidToPages
[sid
].length
== 0) {
62 delete sidToPages
[sid
];
68 const doDisconnect
= () => {
70 // Nothing to notify when disconnecting from MyGames page:
71 if (page
!= "/mygames") {
72 notifyRoom(page
, "disconnect");
73 if (page
.indexOf("/game/") >= 0)
74 notifyRoom("/", "gdisconnect", { page: page
});
77 const messageListener
= (objtxt
) => {
78 let obj
= JSON
.parse(objtxt
);
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.
84 notifyRoom(page
, "connect");
85 if (page
.indexOf("/game/") >= 0)
86 notifyRoom("/", "gconnect", { page: page
});
94 // Self multi-connect: manual removal + disconnect
95 const doKill
= (pg
) => {
96 Object
.keys(clients
[pg
][obj
.sid
]).forEach(x
=> {
97 send(clients
[pg
][obj
.sid
][x
].socket
, { code: "killed" });
99 delete clients
[pg
][obj
.sid
];
101 const disconnectFromOtherConnexion
= (pg
,code
,o
={}) => {
102 Object
.keys(clients
[pg
]).forEach(k
=> {
104 Object
.keys(clients
[pg
][k
]).forEach(x
=> {
106 clients
[pg
][k
][x
].socket
,
107 Object
.assign({ code: code
, from: obj
.sid
}, o
)
113 Object
.keys(clients
).forEach(pg
=> {
114 if (clients
[pg
][obj
.sid
]) {
116 disconnectFromOtherConnexion(pg
, "disconnect");
117 if (pg
.indexOf("/game/") >= 0 && clients
["/"])
118 disconnectFromOtherConnexion("/", "gdisconnect", { page: pg
});
123 case "pollclients": {
126 Object
.keys(clients
[page
]).forEach(k
=> {
128 Object
.keys(clients
[page
][k
]).forEach(x
=> {
129 // Avoid polling my tmpId: no information to get
130 if (k
!= sid
|| x
!= tmpId
)
131 sockIds
[k
][x
] = { focus: clients
[page
][k
][x
].focus
};
134 send(socket
, { code: "pollclients", sockIds: sockIds
});
137 case "pollclientsandgamers": {
140 Object
.keys(clients
["/"]).forEach(k
=> {
142 Object
.keys(clients
[page
][k
]).forEach(x
=> {
143 // Avoid polling my tmpId: no information to get
144 if (k
!= sid
|| x
!= tmpId
) {
147 focus: clients
[page
][k
][x
].focus
152 // NOTE: a "gamer" could also just be an observer
153 Object
.keys(clients
).forEach(p
=> {
154 if (p
.indexOf("/game/") >= 0) {
155 Object
.keys(clients
[p
]).forEach(k
=> {
156 if (!sockIds
[k
]) sockIds
[k
] = {};
157 Object
.keys(clients
[p
][k
]).forEach(x
=> {
158 if (k
!= sid
|| x
!= tmpId
) {
161 focus: clients
[p
][k
][x
].focus
168 send(socket
, { code: "pollclientsandgamers", sockIds: sockIds
});
172 // Asking something: from is fully identified,
173 // but the requested resource can be from any tmpId (except current!)
176 case "askchallenges":
178 const pg
= obj
.page
|| page
; //required for askidentity and askgame
179 if (!!clients
[pg
] && !!clients
[pg
][obj
.target
]) {
180 let tmpIds
= Object
.keys(clients
[pg
][obj
.target
]);
181 if (obj
.target
== sid
) {
183 const idx_myTmpid
= tmpIds
.findIndex(x
=> x
== tmpId
);
184 if (idx_myTmpid
>= 0) tmpIds
.splice(idx_myTmpid
, 1);
186 if (tmpIds
.length
> 0) {
187 const ttmpId
= tmpIds
[Math
.floor(Math
.random() * tmpIds
.length
)];
189 clients
[pg
][obj
.target
][ttmpId
].socket
,
190 { code: obj
.code
, from: [sid
,tmpId
,page
] }
197 // Special situation of the previous "case":
198 // Full game can be asked to any observer.
199 case "askfullgame": {
200 if (!!clients
[page
]) {
201 let sids
= Object
.keys(clients
[page
]).filter(k
=> k
!= sid
);
202 if (sids
.length
> 0) {
203 // Pick a SID at random in this set, and ask full game:
204 const rid
= sids
[Math
.floor(Math
.random() * sids
.length
)];
205 // ..to a random tmpId:
206 const tmpIds
= Object
.keys(clients
[page
][rid
]);
207 const rtmpId
= tmpIds
[Math
.floor(Math
.random() * tmpIds
.length
)];
209 clients
[page
][rid
][rtmpId
].socket
,
210 { code: "askfullgame", from: [sid
,tmpId
] }
217 // Some Hall events: target all tmpId's (except mine),
218 case "refusechallenge":
220 Object
.keys(clients
[page
][obj
.target
]).forEach(x
=> {
221 if (obj
.target
!= sid
|| x
!= tmpId
)
223 clients
[page
][obj
.target
][x
].socket
,
224 { code: obj
.code
, data: obj
.data
}
229 // Notify all room: mostly game events
232 case "deletechallenge_s":
239 // "newgame" message can provide a page (corr Game --> Hall)
240 notifyRoom(obj
.page
|| page
, obj
.code
, {data: obj
.data
}, obj
.excluded
);
244 // A rematch game started:
245 notifyRoom(page
, "newgame", {data: obj
.data
});
246 // Explicitely notify Hall if gametype == corr.
247 // Live games will be polled from Hall after gconnect event.
248 if (obj
.data
.cadence
.indexOf('d') >= 0)
249 notifyRoom("/", "newgame", {data: obj
.data
});
253 const dataWithFrom
= { from: [sid
,tmpId
], data: obj
.data
};
254 // Special case re-send newmove only to opponent:
255 if (!!obj
.target
&& !!clients
[page
][obj
.target
]) {
256 Object
.keys(clients
[page
][obj
.target
]).forEach(x
=> {
258 clients
[page
][obj
.target
][x
].socket
,
259 Object
.assign({ code: "newmove" }, dataWithFrom
)
263 // NOTE: data.from is useful only to opponent
264 notifyRoom(page
, "newmove", dataWithFrom
);
270 !!clients
[page
][obj
.target
[0]] &&
271 !!clients
[page
][obj
.target
[0]][obj
.target
[1]]
274 clients
[page
][obj
.target
[0]][obj
.target
[1]].socket
,
281 // Special case: notify all, 'transroom': Game --> Hall
282 notifyRoom("/", "result", { gid: obj
.gid
, score: obj
.score
});
286 const gamePg
= "/game/" + obj
.gid
;
287 if (!!clients
[gamePg
] && !!clients
[gamePg
][obj
.target
]) {
288 Object
.keys(clients
[gamePg
][obj
.target
]).forEach(x
=> {
290 clients
[gamePg
][obj
.target
][x
].socket
,
300 case "notifynewgame":
301 if (!!clients
["/mygames"]) {
302 obj
.targets
.forEach(t
=> {
303 const k
= t
.sid
|| idToSid
[t
.id
];
304 if (!!clients
["/mygames"][k
]) {
305 Object
.keys(clients
["/mygames"][k
]).forEach(x
=> {
307 clients
["/mygames"][k
][x
].socket
,
308 { code: obj
.code
, data: obj
.data
}
318 clients
[page
][sid
][tmpId
].focus
= (obj
.code
== "getfocus");
319 if (page
== "/") notifyRoom("/", obj
.code
, { page: "/" }, [sid
]);
321 // Notify game room + Hall:
322 notifyRoom(page
, obj
.code
, {}, [sid
]);
323 notifyRoom("/", obj
.code
, { page: page
}, [sid
]);
327 // Passing, relaying something: from isn't needed,
328 // but target is fully identified (sid + tmpId)
335 const pg
= obj
.target
[2] || page
; //required for identity and game
336 // NOTE: if in game we ask identity to opponent still in Hall,
337 // but leaving Hall, clients[pg] or clients[pg][target] could be undefined
338 if (!!clients
[pg
] && !!clients
[pg
][obj
.target
[0]]) {
340 clients
[pg
][obj
.target
[0]][obj
.target
[1]].socket
,
341 { code:obj
.code
, data:obj
.data
}
348 const closeListener
= () => {
349 // For browser or tab closing (including page reload):
352 // Update clients object: add new connexion
353 const newElt
= { socket: socket
, focus: true };
355 clients
[page
] = { [sid
]: {[tmpId
]: newElt
} };
356 else if (!clients
[page
][sid
])
357 clients
[page
][sid
] = { [tmpId
]: newElt
};
359 clients
[page
][sid
][tmpId
] = newElt
;
360 // Also update helper correspondances
361 if (!idToSid
[id
]) idToSid
[id
] = sid
;
362 if (!sidToPages
[sid
]) sidToPages
[sid
] = [];
363 const pgIndex
= sidToPages
[sid
].findIndex(pg
=> pg
== page
);
364 if (pgIndex
=== -1) sidToPages
[sid
].push(page
);
365 socket
.on("message", messageListener
);
366 socket
.on("close", closeListener
);