nostr/primal-web-app
1
0
Fork 0
mirror of https://github.com/PrimalHQ/primal-web-app.git synced 2024-09-29 08:21:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

Connect to relays in parallel

Browse Source
This commit is contained in:
Bojan Mojsilovic 2023-07-19 15:14:34 +02:00
parent 724f2a2585
commit 3e79e5acda
1 changed files with 16 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
src/lib/relays.ts
View File

@ -22,22 +22,22 @@ export const closeRelays = async (relays: Relay[], success = () => {}, fail = ()
}
};
const connectToRelay = (relay: Relay) => new Promise(
const connectToRelay: (relay: Relay) => Promise<Relay> = (relay: Relay) => new Promise(
(resolve, reject) => {
const timeout = setTimeout(() => {
relay.close();
logError(relay, null, true);
reject();
reject(relay);
}, relayConnectingTimeout);
relay.connect()
.then(() => {
clearTimeout(timeout);
resolve(true);
resolve(relay);
})
.catch((e: any) => {
logError(relay, e);
reject();
reject(relay);
});
},
);
@ -49,19 +49,28 @@ export const connectRelays = async (
const urls = Object.keys(relaySettings);
const relays = urls.map(u => relayInit(u));
const connected: Relay[] = [];
let promisses: Promise<Relay>[] = [];
for (let i=0; i < relays.length; i++) {
const relay = relays[i];
if (relay.status === WebSocket.CLOSED) {
try {
await connectToRelay(relay);
connected.push(relay);
promisses.push(connectToRelay(relay));
} catch(e){
logError(relay, e);
};
}
}
const result: PromiseSettledResult<Relay>[] = await Promise.allSettled(promisses);
const connected: Relay[] = result.reduce((acc, r) =>
r.status === 'fulfilled' ?
[...acc, r.value] :
[...acc],
[] as Relay[],
);
onConnect(connected);
};