Fix fatal error and slow network

apps/box/src/file/index.ts

@@ -1,8 +1,5 @@
 import {FileProtocol as Protocol, SchemaProtocol as Schema} from "@functionland/file-protocol";
-import config from "config";
-import { create } from 'ipfs-http-client'
 
-const IPFS_HTTP = config.get("ipfs.http")
 
 export const registerFile = async (libp2pNode, ipfsNode) => {
 
@@ -11,25 +8,40 @@ export const registerFile = async (libp2pNode, ipfsNode) => {
 
 
     Protocol.setMetaRetrievalMethod(async ({id}) => {
-        for await (const file of ipfsNode.cat(id)) {
-            const {meta} = Schema.File.fromBinary(file);
-            return meta;
+        try{
+            for await (const file of ipfsNode.cat(id)) {
+                const {meta} = Schema.File.fromBinary(file);
+                return meta;
+            }
+        }catch (e) {
+            console.log(e)
         }
+
     });
 
     Protocol.setContentRetrievalMethod(async ({id}) => {
-        for await (const file of ipfsNode.cat(id)) {
-            const {contentPath} = Schema.File.fromBinary(file);
-            return ipfsNode.cat(contentPath);
+        try {
+            for await (const file of ipfsNode.cat(id)) {
+                const {contentPath} = Schema.File.fromBinary(file);
+                return ipfsNode.cat(contentPath);
+            }
+        }catch (e) {
+            console.log(e)
         }
+
     });
 
     Protocol.incomingFiles.subscribe(async ({getContent, meta, declareId}) => {
-        const {cid: file} = await ipfsNode.add(
-          getContent()
-        );
-        const {cid} = await ipfsNode.add(Schema.File.toBinary({contentPath: file.toString(), meta}));
-        declareId(cid.toString());
+        try{
+            const {cid: file} = await ipfsNode.add(
+              getContent()
+            );
+            const {cid} = await ipfsNode.add(Schema.File.toBinary({contentPath: file.toString(), meta}));
+            declareId(cid.toString());
+        }catch (e) {
+            console.log(e)
+        }
+
     });
 }
 

apps/box/src/graph/index.ts

@@ -97,37 +97,47 @@ export const registerGraph = async (libp2pNode, ipfsNode) => {
   }
 
   setQueryResolutionMethod(async function (req: Request) {
-    // eslint-disable-next-line @typescript-eslint/ban-ts-comment
-    // @ts-ignore
-
-    const {query, variableValues, operationName} = Request.toJson(req)
-    const gqlQuery = parse(query)
-    const data = await executeAndSelect(gqlQuery, resolvers, variableValues, operationName, loadDB)
-    const s = Result.fromJson(data)
-    const bytes = Result.toBinary(s)
-    return bytes && toAsyncIterable([bytes]);
-  })
 
-  setSubscriptionQueryResolutionMethod(async function* (req: Request) {
-    // eslint-disable-next-line @typescript-eslint/ban-ts-comment
-    // @ts-ignore
+    try{
+      // eslint-disable-next-line @typescript-eslint/ban-ts-comment
+      // @ts-ignore
+      const {query, variableValues, operationName} = Request.toJson(req)
+      const gqlQuery = parse(query)
+      const data = await executeAndSelect(gqlQuery, resolvers, variableValues, operationName, loadDB)
+      const s = Result.fromJson(data)
+      const bytes = Result.toBinary(s)
+      return bytes && toAsyncIterable([bytes]);
+    }catch (e) {
+      console.log(e)
+    }
 
-    const {query, variableValues, operationName} = Request.toJson(req)
-    const gqlQuery = parse(query)
+  })
 
-    const [values, next, complete] = iterateLater()
+  setSubscriptionQueryResolutionMethod(async function* (req: Request) {
+    try{
+      // eslint-disable-next-line @typescript-eslint/ban-ts-comment
+      // @ts-ignore
 
-    const data = await executeAndSelect(gqlQuery, resolvers, variableValues, operationName, loadDB, next, true)
-    const s = Result.fromJson(data)
-    const bytes = Result.toBinary(s)
+      const {query, variableValues, operationName} = Request.toJson(req)
+      const gqlQuery = parse(query)
 
-    yield bytes
+      const [values, next, complete] = iterateLater()
 
-    for await (const res of values) {
-      const s = Result.fromJson(res)
+      const data = await executeAndSelect(gqlQuery, resolvers, variableValues, operationName, loadDB, next, true)
+      const s = Result.fromJson(data)
       const bytes = Result.toBinary(s)
 
       yield bytes
+
+      for await (const res of values) {
+        const s = Result.fromJson(res)
+        const bytes = Result.toBinary(s)
+
+        yield bytes
+      }
+    }catch (e) {
+      console.log(e)
     }
+
   })
 }

common/config/rush/.npmrc

@@ -20,3 +20,5 @@
 #
 registry=https://registry.npmjs.org/:_authToken=${NPM_AUTH_TOKEN}
 always-auth=false
+timeout=60000
+prefer-offline=true