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;