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

bouncer: remove event retransmitting

Browse Source 
bostr already connected to relays before client is connecting to an
bouncer. So this feature is no longer needed.

Signed-off-by: Yonle <yonle@lecturify.net>
This commit is contained in:
Yonle 2024-05-10 18:46:43 +07:00
parent b6af5af30b
commit 81fd6ebfac
1 changed files with 0 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
worker_bouncer.js
View File

@ -122,8 +122,6 @@ parentPort.on('message', m => {
if (!csess.hasOwnProperty(m.id)) return; if (!csess.hasOwnProperty(m.id)) return;
const ws = csess[m.id]; const ws = csess[m.id];
ws.my_events.add(m.event.id);
bc(["EVENT", m.event], m.id); bc(["EVENT", m.event], m.id);
parentPort.postMessage({ parentPort.postMessage({
type: "upstream_msg", type: "upstream_msg",
@ -211,7 +209,6 @@ function getIdleSess(ident, infos) {
ws.subs = {}; // contains filter submitted by clients. per subID ws.subs = {}; // contains filter submitted by clients. per subID
ws.pause_subs = new Set(); // pause subscriptions from receiving events after reached over <filter.limit> until all relays send EOSE. per subID ws.pause_subs = new Set(); // pause subscriptions from receiving events after reached over <filter.limit> until all relays send EOSE. per subID
ws.events = {}; // only to prevent the retransmit of the same event. per subID ws.events = {}; // only to prevent the retransmit of the same event. per subID
ws.my_events = new Set(); // for event retransmitting.
ws.pendingEOSE = {}; // each contain subID ws.pendingEOSE = {}; // each contain subID
ws.reconnectTimeout = new Set(); // relays timeout() before reconnection. Only use after client disconnected. ws.reconnectTimeout = new Set(); // relays timeout() before reconnection. Only use after client disconnected.
ws.subalias = {}; ws.subalias = {};
@ -301,9 +298,6 @@ function newConn(addr, id, reconn_t = 0) {
if (log_about_relays) console.log(threadId, "---", id, "Connected to", addr, `(${relay_type(addr)})`); if (log_about_relays) console.log(threadId, "---", id, "Connected to", addr, `(${relay_type(addr)})`);
if (!client) return; if (!client) return;
for (const i of client.my_events) {
relay.send(JSON.stringify(["EVENT", i]));
}
for (const i in client.subs) { for (const i in client.subs) {
relay.send(JSON.stringify(["REQ", client.fakesubalias[i], ...client.subs[i]])); relay.send(JSON.stringify(["REQ", client.fakesubalias[i], ...client.subs[i]]));