From cd33e1508bf1f761dd8aba3048a8797aab44f5ab Mon Sep 17 00:00:00 2001 From: Derrick Hammer Date: Sat, 13 Aug 2022 15:12:49 -0400 Subject: [PATCH] *add socketExists api method --- src/index.ts | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/src/index.ts b/src/index.ts index bea1f53..6af15b0 100644 --- a/src/index.ts +++ b/src/index.ts @@ -26,6 +26,7 @@ addHandler("connect", handleConnect); addHandler("listenSocketEvent", handleListenSocketEvent, { receiveUpdates: true, }); +addHandler("socketExists", handleSocketExists); addHandler("close", handleCloseSocketEvent); addHandler("write", handleWriteSocketEvent); 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) { const socket = validateConnection(aq);