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

fix [relays: Re-sub after reconnect]

Browse Source 
Signed-off-by: Yonle <yonle@lecturify.net>
This commit is contained in:
Yonle 2023-10-31 15:15:00 +07:00
parent 1776c4c888
commit 8370bf2cd7
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
bouncer/bouncer1.js
View File

@ -92,7 +92,7 @@ function newConn(addr) {
relay.on('open', _ => {
socks.add(relay); // Add this socket session to [socks]
console.log(process.pid, "---", `[${socks.size}/${relays.length}]`, relay.addr, "is connected");
for (i of db.prepare("SELECT subID FROM sess WHERE cID = ?;").iterate(id)) {
for (i of sess.prepare("SELECT subID FROM sess WHERE cID = ?;").iterate(id)) {
if (relay.readyState >= 2) break;
relay.send(JSON.stringify(["REQ", i.subID]));
}

2
bouncer/bouncer2.js
View File

@ -107,7 +107,7 @@ function newConn(addr, id) {
relay.on('open', _ => {
socks.add(relay); // Add this socket session to [socks]
console.log(process.pid, "---", `[${id}] [${socks.size}/${relays.length}]`, relay.addr, "is connected");
for (i of db.prepare("SELECT subID FROM sess WHERE cID = ?;").iterate(id)) {
for (i of sess.prepare("SELECT subID FROM sess WHERE cID = ?;").iterate(id)) {
if (relay.readyState >= 2) break;
relay.send(JSON.stringify(["REQ", i.subID]));
}