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

*add socketExists api method

This commit is contained in:
Derrick Hammer 2022-08-13 15:12:49 -04:00
parent 4e4a22542f
commit cd33e1508b
Signed by: pcfreak30
GPG Key ID: C997C339BE476FF2
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/index.ts
View File

@ -26,6 +26,7 @@ addHandler("connect", handleConnect);
addHandler("listenSocketEvent", handleListenSocketEvent, { addHandler("listenSocketEvent", handleListenSocketEvent, {
receiveUpdates: true, receiveUpdates: true,
}); });
addHandler("socketExists", handleSocketExists);
addHandler("close", handleCloseSocketEvent); addHandler("close", handleCloseSocketEvent);
addHandler("write", handleWriteSocketEvent); addHandler("write", handleWriteSocketEvent);
addHandler("addRelay", handleAddRelay); addHandler("addRelay", handleAddRelay);
@ -149,6 +150,12 @@ function handleListenSocketEvent(aq: ActiveQuery) {
}); });
} }
async function handleSocketExists(aq: ActiveQuery) {
const { id = null } = aq.callerInput;
aq.respond(hasDhtConnection(Number(id)));
}
function handleCloseSocketEvent(aq: ActiveQuery) { function handleCloseSocketEvent(aq: ActiveQuery) {
const socket = validateConnection(aq); const socket = validateConnection(aq);