highperfocused/bostr
1
0
Fork 0
mirror of https://github.com/Yonle/bostr.git synced 2025-10-02 12:34:25 +02:00
Code Issues Packages Projects Releases Wiki Activity

bouncer: override opened subscription when requested.

Browse Source 
Signed-off-by: Yonle <yonle@lecturify.net>
This commit is contained in:
Yonle
2024-03-23 13:38:35 +07:00
parent 3ea250a248
commit be9b0698b8
1 changed files with 13 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
bouncer.js
View File

@@ -104,8 +104,19 @@ 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[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 (ws.subs.has(data[1])) return ws.send(JSON.stringify(["CLOSED", data[1], "duplicate: subscription already opened"]));
const origID = data[1];
if (ws.subs.has(data[1])) {
const faked = ws.fakesubalias.get(origID);
ws.subs.delete(origID);
ws.events.delete(origID);
ws.pendingEOSE.delete(origID);
ws.pause_subs.delete(origID);
ws.fakesubalias.delete(origID);
ws.subalias.delete(faked);
ws.mergedFilters.delete(origID);
bc(["CLOSE", faked], ws.id);
};
const faked = Date.now() + Math.random().toString(36);
let filters = data.slice(2);
let filter = mergeFilters(...filters);
@@ -148,7 +159,7 @@ module.exports = (ws, req, onClose) => {
case "CLOSE":
if (!authorized) return;
if (typeof(data[1]) !== "string") return ws.send(JSON.stringify(["NOTICE", "error: bad request."]));
if (!ws.fakesubalias.has(data[1])) return ws.send(JSON.stringify(["CLOSED", data[1], "error: this sub is not opened."]));
if (!ws.subs.has(data[1])) return ws.send(JSON.stringify(["CLOSED", data[1], "error: this sub is not opened."]));
const origID = data[1];
const faked = ws.fakesubalias.get(origID);
ws.subs.delete(origID);