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

b2: don't chill down.

Browse Source 
Signed-off-by: Yonle <yonle@lecturify.net>
This commit is contained in:
Yonle
2023-11-15 21:40:04 +07:00
parent d00c6b2d00
commit 5f13300734
1 changed files with 0 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
bouncer/bouncer2.js
View File

@@ -76,9 +76,6 @@ module.exports = (ws, req) => {
terminate_sess(ws.id); terminate_sess(ws.id);
}); });
// Chill down first buddy....
ws.pause();
csess.set(ws.id, ws); csess.set(ws.id, ws);
relays.forEach(_ => newConn(_, ws.id)); relays.forEach(_ => newConn(_, ws.id));
} }
@@ -129,7 +126,6 @@ function newConn(addr, id) {
relay.on('open', _ => { relay.on('open', _ => {
socks.add(relay); // Add this socket session to [socks] socks.add(relay); // Add this socket session to [socks]
if (process.env.LOG_ABOUT_RELAYS || log_about_relays) console.log(process.pid, "---", `[${id}] [${socks.size}/${relays.length*csess.size}]`, relay.url, "is connected"); if (process.env.LOG_ABOUT_RELAYS || log_about_relays) console.log(process.pid, "---", `[${id}] [${socks.size}/${relays.length*csess.size}]`, relay.url, "is connected");
if (csess.get(id)?.isPaused) csess.get(id).resume();
for (i of sess.prepare("SELECT data FROM recentEvents WHERE cID = ?;").iterate(id)) { for (i of sess.prepare("SELECT data FROM recentEvents WHERE cID = ?;").iterate(id)) {
if (relay.readyState >= 2) break; if (relay.readyState >= 2) break;