highperfocused/bostr
1
0
Fork 0
mirror of https://github.com/Yonle/bostr.git synced 2025-03-17 21:32:43 +01:00
Code Issues Packages Projects Releases Wiki Activity

bog

Browse Source 
Signed-off-by: Yonle <yonle@lecturify.net>
This commit is contained in:
Yonle 2024-03-22 12:16:37 +07:00
parent 7ed25e3520
commit 0fbe970926
1 changed files with 4 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
bouncer.js
View File

@ -2,7 +2,7 @@
const { version } = require("./package.json"); const { version } = require("./package.json");
const WebSocket = require("ws"); const WebSocket = require("ws");
const querystring = require("querystring"); const querystring = require("querystring");
const { validateEvent, nip19, matchFilters, mergeFilters, getFilterLimit } = require("nostr-tools"); const { validateEvent, nip19, matchFilter, mergeFilters, getFilterLimit } = require("nostr-tools");
const auth = require("./auth.js"); const auth = require("./auth.js");
const nip42 = require("./nip42.js"); const nip42 = require("./nip42.js");
@ -109,7 +109,7 @@ module.exports = (ws, req, onClose) => {
const filters = data.slice(2); const filters = data.slice(2);
let filter = mergeFilters(...filters); let filter = mergeFilters(...filters);
if (!Array.isArray(filter.kinds)) { if (!Array.isArray(filter.kinds) && ws.acceptKinds) {
filter.kinds = ws.acceptKinds; filter.kinds = ws.acceptKinds;
} else { } else {
filter.kinds = filter.kinds?.filter(kind => { filter.kinds = filter.kinds?.filter(kind => {
@ -133,7 +133,7 @@ module.exports = (ws, req, onClose) => {
ws.pause_subs.delete(origID); ws.pause_subs.delete(origID);
ws.subalias.set(faked, origID); ws.subalias.set(faked, origID);
ws.fakesubalias.set(origID, faked); ws.fakesubalias.set(origID, faked);
if (!filter.since) filter.since = Math.floor(Date.now() / 1000); // Will not impact everything. Only used for handling passing pause_on_limit (or save mode) //if (!filter.since) filter.since = Math.floor(Date.now() / 1000); // Will not impact everything. Only used for handling passing pause_on_limit (or save mode)
bc(["REQ", faked, filter], ws.id); bc(["REQ", faked, filter], ws.id);
if (filter.limit < 1) return ws.send(JSON.stringify(["EOSE", origID])); if (filter.limit < 1) return ws.send(JSON.stringify(["EOSE", origID]));
ws.pendingEOSE.set(origID, 0); ws.pendingEOSE.set(origID, 0);
@ -263,11 +263,9 @@ function newConn(addr, id, reconn_t = 0) {
data[1] = client.subalias.get(data[1]); data[1] = client.subalias.get(data[1]);
const filter = client.subs.get(data[1]); const filter = client.subs.get(data[1]);
if (client.pause_subs.has(data[1]) && (filter.since > data[2].created_at)) return; if (client.pause_subs.has(data[1]) && (filter.since > data[2].created_at)) return;
if (client.rejectKinds && client.rejectKinds.includes(data[2]?.id)) return; if (client.rejectKinds && client.rejectKinds.includes(data[2]?.id)) return;
const filters = client.subs.get(data[1]); if (!matchFilter(filter, data[2])) return;
if (!matchFilters(filters, data[2])) return;
const NotInSearchQuery = "search" in filter && !data[2]?.content?.toLowerCase().includes(filter.search.toLowerCase()); const NotInSearchQuery = "search" in filter && !data[2]?.content?.toLowerCase().includes(filter.search.toLowerCase());
if (NotInSearchQuery) return; if (NotInSearchQuery) return;