From fd2d66d2c4713d266b4b906e9b560310d0e9a3a1 Mon Sep 17 00:00:00 2001 From: Derrick Hammer Date: Thu, 30 Mar 2023 21:06:04 -0400 Subject: [PATCH] *add getActivePeers api method --- src/index.ts | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/src/index.ts b/src/index.ts index 46c88c3..fb0bf40 100644 --- a/src/index.ts +++ b/src/index.ts @@ -68,6 +68,7 @@ addHandler("stat", handleStat); addHandler("ls", handleLs, { receiveUpdates: true }); addHandler("cat", handleCat, { receiveUpdates: true }); addHandler("ipnsResolve", handleIpnsResolve); +addHandler("getActivePeers", handleGetActivePeers); async function handlePresentSeed() { swarm = createClient(); @@ -329,6 +330,12 @@ async function handleIpnsResolve(aq: ActiveQuery) { } } +async function handleGetActivePeers(aq: ActiveQuery) { + await ready(); + + aq.respond(PeerManager.instance.ipfs.libp2p.getPeers()); +} + async function ready() { await moduleDefer.promise; await PeerManager.instance.ipfsReady;