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

*Wrap connection event in an init call event to survive the relay being recreated

This commit is contained in:
Derrick Hammer 2023-02-17 22:37:05 -05:00
parent db079ce214
commit 2ad6b1fd5d
Signed by: pcfreak30
GPG Key ID: C997C339BE476FF2
1 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/index.ts
View File

@ -80,12 +80,14 @@ async function createSwarm(): Promise<number> {
const id = getSwarmId(); const id = getSwarmId();
swarmInstances.set(id, swarmInstance); swarmInstances.set(id, swarmInstance);
swarmInstance.on("connection", (peer) => { swarmInstance.onSelf("init", () => {
const socketId = getSocketId(); swarmInstance.on("connection", (peer: any) => {
connections.set(socketId, { swarm: id, conn: peer }); const socketId = getSocketId();
connections.set(socketId, { swarm: id, conn: peer });
peer.on("close", () => { peer.on("close", () => {
connections.delete(socketId); connections.delete(socketId);
});
}); });
}); });
@ -308,6 +310,7 @@ async function handleListenConnections(aq: ActiveQuery) {
const swarm = await getSwarm(aq); const swarm = await getSwarm(aq);
const listener = (peer: any) => { const listener = (peer: any) => {
debugger;
aq.sendUpdate(getSwarmToSocketConnectionId(peer)); aq.sendUpdate(getSwarmToSocketConnectionId(peer));
}; };