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

code comments: remove some old comments and try improve some existing one

Browse Source 
Signed-off-by: Yonle <yonle@lecturify.net>
This commit is contained in:
Yonle 2024-05-12 16:07:38 +07:00
parent b6f490ab4a
commit dc96f87515
2 changed files with 9 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
bouncer.js
View File

@ -25,7 +25,7 @@ if (approved_publishers?.length) {
const worker = new Worker(__dirname + "/worker_bouncer.js", { name: "Bostr (worker)" });
const csess = {}; // this is used for relays.
const csess = {};
const idents = {};
let zeroStats = {
@ -36,7 +36,6 @@ let zeroStats = {
}
let stats = {};
// CL - User socket
function handleConnection(ws, req) {
let query = querystring.parse(req.url.slice(2));
let authKey = null;
@ -155,6 +154,8 @@ function handleConnection(ws, req) {
});
}
// Below code is for talking to worker.
function resolveClient(ws) {
for (const resolve of ws.onready) {
ws.onready.delete(resolve);
@ -183,7 +184,6 @@ function handleWorker(msg) {
}
};
// WS - Broadcast message to every existing sockets
function _req(id, sid, filters) {
worker.postMessage({
type: "req",

13
worker_bouncer.js
View File

@ -17,7 +17,7 @@ if (relays.length) loadbalancer.unshift("_me");
// CL MaxEoseScore: Set <max_eose_score> as 0 if configured relays is under of the expected number from <max_eose_score>
if (relays.length < max_eose_score) max_eose_score = 0;
const csess = {}; // this is used for relays.
const csess = {};
const userRelays = {}; // per ID contains Set() of <WebSocket>
const idleSess = new Set();
const idents = {};
@ -194,7 +194,7 @@ function newsess() {
}
}
// WS - Broadcast message to every existing sockets
// WS - Broadcast message to every upstream relays
function bc(msg, id, toCacheOnly) {
if (toCacheOnly && !cache_relays?.length) return;
for (const relay of userRelays[id]) {
@ -220,8 +220,8 @@ function getIdleSess(ws) {
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.events = {}; // only to prevent the retransmit of the same event. per subID
ws.pendingEOSE = {}; // each contain subID
ws.reconnectTimeout = new Set(); // relays timeout() before reconnection. Only use after client disconnected.
ws.pendingEOSE = {}; // each contain subID of integer
ws.reconnectTimeout = new Set(); // relay's timeout() before reconnection. Only use after client disconnected.
ws.subalias = {};
ws.fakesubalias = {};
ws.mergedFilters = {};
@ -274,7 +274,6 @@ function relay_type(addr) {
}
}
// WS - Sessions
function newConn(addr, id, reconn_t = 0) {
if (!csess.hasOwnProperty(id)) return;
if (!stats[addr]) stats[addr] = { raw_rx: 0, rx: 0, tx: 0, f: 0 };
@ -431,7 +430,7 @@ function newConn(addr, id, reconn_t = 0) {
relay.on('close', _ => {
if (!userRelays.hasOwnProperty(id)) return;
userRelays[id].delete(relay); // Remove this socket session from <client.relays> list
userRelays[id].delete(relay);
if (log_about_relays) console.log(threadId, "-!-", id, "Disconnected from", addr, `(${relay_type(addr)})`);
reconn_t += reconnect_time || 5000
setTimeout(_ => {
@ -453,7 +452,7 @@ function newConn(addr, id, reconn_t = 0) {
stats[addr].f++
});
userRelays[id].add(relay); // Add this socket session to <client.relays>
userRelays[id].add(relay);
}
for (let i = 1; i <= (idle_sessions || 1); i++) {