fixing fs.cat

silkroadnomad · Dec 21, 2024 · 735e2b4 · 735e2b4
1 parent e8015d5
commit 735e2b4
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 5 deletions.
diff --git a/relay/src/pinner/scanBlockchainForNameOps.js b/relay/src/pinner/scanBlockchainForNameOps.js
@@ -208,15 +208,13 @@ async function pinIpfsContent(electrumClient, helia, orbitdb, nameOp, nameId, ip
     let metadataContent = '';
     let totalSize = 0;
     let metadataSize = 0;
-
+    const fs = unixfs(helia);
     try {
         logger.info(`Attempting to retrieve IPFS metadata content with CID: ${cid}`);
 
         // Notify network that we're starting to pin
         helia.libp2p.services.pubsub.publish(CONTENT_TOPIC, new TextEncoder().encode("PINNING-CID:" + cid));
 
-        const fs = unixfs(helia);
-
         // Measure metadata size
         for await (const chunk of fs.cat(CID.parse(cid))) {
             metadataContent += new TextDecoder().decode(chunk);
@@ -245,7 +243,6 @@ async function pinIpfsContent(electrumClient, helia, orbitdb, nameOp, nameId, ip
         try {
             logger.info(`Measuring file size for CID: ${imageCid}`);
             let fileSize = 0;
-
             // Measure actual file size
             for await (const chunk of fs.cat(CID.parse(imageCid))) {
                 fileSize += chunk.length;

diff --git a/relay/src/pubsubHandler.js b/relay/src/pubsubHandler.js
@@ -18,7 +18,7 @@ export function setupPubsub(helia, orbitdb, pinningService, electrumClient, fsHe
         try {
             messageObject = JSON.parse(message);
         } catch (err) {
-            logger.warn('Failed to parse message as JSON:', err);
+            // logger.warn('Failed to parse message as JSON:', err);
         }
 
         if (messageObject && topic.startsWith(CONTENT_TOPIC)) {