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

http.js: fix regex & method of getting websocket URLs from bouncer

Browse Source 
Signed-off-by: Yonle <yonle@lecturify.net>
This commit is contained in:
Yonle 2024-05-13 16:36:52 +07:00
parent 396bd3f7bb
commit 34ab5f6013
1 changed files with 18 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
http.js
View File

@ -18,6 +18,9 @@ const log = _ => console.log(process.pid, curD(), "-", _);
let server = null;
let config = require(process.env.BOSTR_CONFIG_PATH || "./config");
let wslinkregex = /(?:^- )(wss?:\/\/.*)(?: \(.*\))/gm;
let loadbalancerUpstreamLinks = [];
config.server_meta.version = version;
if (!config.relays?.length) (async () => {
@ -29,7 +32,12 @@ if (!config.relays?.length) (async () => {
});
const text = await request.body.text();
config.relays = text.match(/(w{1,2}s)s?:\/\/.+/g);
let l = null
while ((l = wslinkregex.exec(text)) !== null) {
loadbalancerUpstreamLinks.push(l[1]);
}
console.log("Got list:");
console.log("- " + loadbalancerUpstreamLinks.join("\n- "))
})();
if (
@ -77,10 +85,15 @@ server.on('request', (req, res) => {
"Content-Type": "text/plain"
});
res.write("Hello. This nostr bouncer (bostr) is bouncing the following relays:\n\n");
config.relays.forEach(_ => {
const { raw_rx, rx, tx, f } = bouncer.getStat(_);
res.write("- " + _ + ` (raw_rx: ${raw_rx}; rx: ${rx}; tx: ${tx}; fail: ${f})` + "\n");
});
if (config.relays.length) {
config.relays.forEach(_ => {
const { raw_rx, rx, tx, f } = bouncer.getStat(_);
res.write("- " + _ + ` (raw_rx: ${raw_rx}; rx: ${rx}; tx: ${tx}; fail: ${f})` + "\n");
});
} else if (loadbalancerUpstreamLinks.length) {
res.write("- " + loadbalancerUpstreamLinks.join("\n- ") + "\n");
}
res.write(`\nI have ${wss.clients.size} clients currently connected to this bouncer${(process.env.CLUSTERS || config.clusters) > 1 ? " on this cluster" : ""}.\n`);