highperfocused/bostr
1
0
Fork 0
mirror of https://github.com/Yonle/bostr.git synced 2025-11-18 18:07:49 +01:00
Code Issues Packages Projects Releases Wiki Activity

also handle after client close

Browse Source 
Signed-off-by: Yonle <yonle@lecturify.net>
This commit is contained in:
Yonle
2024-01-29 22:34:43 +07:00
parent 990c8b2202
commit 22486202e4
1 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
bouncer.js
View File

@@ -149,9 +149,8 @@ module.exports = (ws, req, onClose) => {
onClose(); onClose();
console.log(process.pid, "---", `${ip} (${ws.id}) disconnected (${howManyOrphanSess()+1} orphans)`); console.log(process.pid, "---", `${ip} (${ws.id}) disconnected (${howManyOrphanSess()+1} orphans)`);
if (csess.has(ws.id)) { if (csess.has(ws.id))
csess.set(ws.id, null); // set as orphan. csess.set(ws.id, null); // set as orphan.
}
for (const i of ws.EOSETimeout) { for (const i of ws.EOSETimeout) {
clearTimeout(i[1]); clearTimeout(i[1]);
@@ -166,8 +165,8 @@ module.exports = (ws, req, onClose) => {
} }
for (const i of ws.subs) { for (const i of ws.subs) {
direct_bc(["CLOSE", i[0]], ws.id); direct_bc(["CLOSE", ws.fakesubalias.get(i[0])], ws.id);
cache_bc(["CLOSE", i[0]], ws.id); cache_bc(["CLOSE", ws.fakesubalias.get(i[0])], ws.id);
} }
onClientDisconnect(); onClientDisconnect();