LumeWeb
/
kernel-swarm
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

*Change ready to init 

*Add new ready method that listens for a ready event but returns if activeRelay is set
This commit is contained in:
Derrick Hammer 2023-02-01 12:07:46 -05:00
parent 4e443f4ccb
commit 236e445ff8
Signed by: pcfreak30
GPG Key ID: C997C339BE476FF2
1 changed files with 20 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
src/index.ts
View File

@ -49,6 +49,7 @@ addHandler("addRelay", handleAddRelay);
addHandler("removeRelay", handleRemoveRelay); addHandler("removeRelay", handleRemoveRelay);
addHandler("clearRelays", handleClearRelays); addHandler("clearRelays", handleClearRelays);
addHandler("getRelays", handleGetRelays); addHandler("getRelays", handleGetRelays);
addHandler("init", handleInit);
addHandler("ready", handleReady); addHandler("ready", handleReady);
async function handlePresentSeed(aq: ActiveQuery) { async function handlePresentSeed(aq: ActiveQuery) {
@ -282,9 +283,25 @@ async function handleGetPeerByPubkey(aq: ActiveQuery) {
); );
} }
async function handleReady(aq: ActiveQuery) { async function handleInit(aq: ActiveQuery) {
const swarm = await getSwarm(aq); const swarm = await getSwarm(aq);
// @ts-ignore try {
await swarm.ready(); await swarm.init();
} catch (e) {
aq.reject((e as Error).message);
return;
}
aq.respond(); aq.respond();
} }
async function handleReady(aq: ActiveQuery) {
const swarm = await getSwarm(aq);
if (swarm.activeRelay) {
aq.respond();
return;
}
swarm.once("ready", () => {
aq.respond();
});
}