src/index.ts

@@ -238,10 +238,7 @@ async function handleStat(aq: ActiveQuery) {
     aq.respond(
       JSON.parse(
         JSON.stringify(
-          await fs.stat(
+          await fs.stat(aq.callerInput.cid, aq.callerInput.options ?? {})
-            getCID(aq.callerInput.cid),
-            aq.callerInput.options ?? {}
-          )
         )
       )
     );
@@ -263,10 +260,7 @@ async function handleLs(aq: ActiveQuery) {
     aborted = true;
   });
 
-  const iterable = fs.ls(
+  const iterable = fs.ls(aq.callerInput.cid, aq.callerInput.options ?? {});
-    getCID(aq.callerInput.cid),
-    aq.callerInput.options ?? {}
-  );
 
   for await (const item of iterable) {
     if (aborted) {
@@ -292,10 +286,7 @@ async function handleCat(aq: ActiveQuery) {
     aborted = true;
   });
 
-  const iterable = fs.cat(
+  const iterable = fs.cat(aq.callerInput.cid, aq.callerInput.options ?? {});
-    getCID(aq.callerInput.cid),
-    aq.callerInput.options ?? {}
-  );
 
   for await (const chunk of iterable) {
     if (aborted) {
@@ -313,24 +304,25 @@ async function handleIpnsResolve(aq: ActiveQuery) {
 
   await activePeersDefer.promise;
 
-  if (PeerManager.instance.ipfs.libp2p.getPeers().length === 0) {
-    activePeersDefer = defer();
-  }
-
-  await activePeersDefer.promise;
-
   if (!aq.callerInput || !("cid" in aq.callerInput)) {
     aq.reject("cid required");
     return;
   }
 
+  const prefix = substr(aq.callerInput.cid, 0, 1);
+
+  if (!(prefix in basesByPrefix)) {
+    aq.reject("invalid multibase found in CID");
+    return;
+  }
+
+  const base = basesByPrefix[prefix];
+  const cid = CID.parse(aq.callerInput.cid, base);
+
   try {
     return aq.respond(
       (
-        await IPNS.resolve(
+        await IPNS.resolve(peerIdFromCID(cid), aq.callerInput?.options)
-          peerIdFromCID(getCID(aq.callerInput.cid)),
-          aq.callerInput?.options
-        )
       ).asCID.toString()
     );
   } catch (e: any) {
@@ -338,17 +330,6 @@ async function handleIpnsResolve(aq: ActiveQuery) {
   }
 }
 
-function getCID(cid: string): CID {
-  const prefix = substr(cid, 0, 1);
-
-  if (!(prefix in basesByPrefix)) {
-    throw new Error("invalid multibase found in CID");
-  }
-
-  const base = basesByPrefix[prefix];
-  return CID.parse(cid, base);
-}
-
 async function handleGetActivePeers(aq: ActiveQuery) {
   await ready();