fix: not a file error durring ipfs cat

silkroadnomad · Jan 21, 2025 · e543df5 · e543df5
1 parent 57fae11
commit e543df5
Show file tree

Hide file tree

Showing 2 changed files with 23 additions and 5 deletions.
diff --git a/relay/package.json b/relay/package.json
@@ -1,6 +1,6 @@
 {
   "name": "libp2p-relay",
-  "version": "0.12.42",
+  "version": "0.12.43",
   "private": true,
   "scripts": {
     "start:no-restart": "node src/relay.js",

diff --git a/relay/src/pinner/scanBlockchainForNameOps.js b/relay/src/pinner/scanBlockchainForNameOps.js
@@ -204,10 +204,28 @@ async function pinIpfsContent(electrumClient, helia, nameOp, nameId, ipfsUrl) {
       new TextEncoder().encode('PINNING-CID:' + cid)
     );
 
-    // Measure metadata size
-    for await (const chunk of fs.cat(CID.parse(cid))) {
-      metadataContent += new TextDecoder().decode(chunk);
-      metadataSize += chunk.length;
+    // Try to read as file first, fallback to directory listing
+    try {
+      // Measure metadata size
+      for await (const chunk of fs.cat(CID.parse(cid))) {
+        metadataContent += new TextDecoder().decode(chunk);
+        metadataSize += chunk.length;
+      }
+    } catch (error) {
+      if (error.code === 'ERR_NOT_A_FILE') {
+        // Handle directory case
+        console.info(`CID ${cid} is a directory, listing contents`);
+        for await (const entry of fs.ls(CID.parse(cid))) {
+          console.info(`Found directory entry: ${entry.name}`);
+          // Process each file in directory
+          for await (const chunk of fs.cat(entry.cid)) {
+            metadataContent += new TextDecoder().decode(chunk);
+            metadataSize += chunk.length;
+          }
+        }
+      } else {
+        throw error;
+      }
     }
     totalSize += metadataSize;
   } catch (error) {