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

*Move existing connection logic up

This commit is contained in:
Derrick Hammer 2023-04-04 11:22:37 -04:00
parent c0b99e8146
commit 2f30b743f6
Signed by: pcfreak30
GPG Key ID: C997C339BE476FF2
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/index.ts
View File

@ -351,6 +351,12 @@ async function handleListenConnections(aq: ActiveQuery) {
aq.respond(); aq.respond();
}); });
for (const conn of connections) {
if (conn[1].swarm === swarmId) {
listener(conn[1].conn);
}
}
const closeCb = () => { const closeCb = () => {
swarmEvent?.off("connection", listener); swarmEvent?.off("connection", listener);
swarmEvent?.emit("close"); swarmEvent?.emit("close");
@ -366,12 +372,6 @@ async function handleListenConnections(aq: ActiveQuery) {
return; return;
} }
swarm.onceSelf("ready", hookClose); swarm.onceSelf("ready", hookClose);
for (const conn of connections) {
if (conn[1].swarm === swarmId) {
listener(conn[1].conn);
}
}
} }
async function handleGetSocketInfo(aq: ActiveQuery) { async function handleGetSocketInfo(aq: ActiveQuery) {