highperfocused/bostr
1
0
Fork 0
mirror of https://github.com/Yonle/bostr.git synced 2025-09-27 13:26:30 +02:00
Code Issues Packages Projects Releases Wiki Activity

bouncer: close an already opened subscription

Browse Source 
Signed-off-by: Yonle <yonle@lecturify.net>
This commit is contained in:
Yonle
2024-01-29 21:36:20 +07:00
parent 5d6e35ae7e
commit a46b56adad
1 changed files with 1 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
bouncer.js
View File

@@ -91,10 +91,7 @@ module.exports = (ws, req, onClose) => {
if (typeof(data[1]) !== "string") return ws.send(JSON.stringify(["NOTICE", "error: expected subID a string. but got the otherwise."])); if (typeof(data[1]) !== "string") return ws.send(JSON.stringify(["NOTICE", "error: expected subID a string. but got the otherwise."]));
if (typeof(data[2]) !== "object") return ws.send(JSON.stringify(["CLOSED", data[1], "error: expected filter to be obj, instead gives the otherwise."])); if (typeof(data[2]) !== "object") return ws.send(JSON.stringify(["CLOSED", data[1], "error: expected filter to be obj, instead gives the otherwise."]));
if ((max_client_subs !== -1) && (ws.subs.size > max_client_subs)) return ws.send(JSON.stringify(["CLOSED", data[1], "rate-limited: too many subscriptions."])); if ((max_client_subs !== -1) && (ws.subs.size > max_client_subs)) return ws.send(JSON.stringify(["CLOSED", data[1], "rate-limited: too many subscriptions."]));
if (ws.subs.has(data[1])) { if (ws.subs.has(data[1])) return ws.send(JSON.stringify(["CLOSED", data[1], "duplicate: subscription already opened"]));
direct_bc(["CLOSE", data[1]], ws.id);
cache_bc(["CLOSE", data[1]], ws.id);
}
ws.subs.set(data[1], data.slice(2)); ws.subs.set(data[1], data.slice(2));
ws.events.set(data[1], new Set()); ws.events.set(data[1], new Set());
ws.pause_subs.delete(data[1]); ws.pause_subs.delete(data[1]);