From 564306bed23e62c009af982a49c7eb1d9a58a9d9 Mon Sep 17 00:00:00 2001 From: Derrick Hammer Date: Sun, 14 Aug 2022 06:19:13 -0400 Subject: [PATCH] *If we have no active gateways, try to refresh the list first --- src/index.ts | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/src/index.ts b/src/index.ts index bed4f91..8ebdfbb 100644 --- a/src/index.ts +++ b/src/index.ts @@ -1,4 +1,4 @@ -import { addHandler, handleMessage , log} from "libkmodule"; +import { addHandler, handleMessage, log } from "libkmodule"; import type { ActiveQuery } from "libkmodule"; import PQueue from "p-queue"; import { ipfsPath, ipnsPath } from "is-ipfs"; @@ -137,6 +137,9 @@ async function fetchFromRelays( stream = undefined ) { let error = new Error("NOT_FOUND"); + if (0 == activeRelays.length) { + await refreshGatewayList(); + } for (const relay of activeRelays) { let resp; try { @@ -216,7 +219,7 @@ async function rpcCall( stream(response?.data.data); if (response?.data.done) { socket.end(); - resolve(true); + resolve(true); } } }); @@ -229,7 +232,7 @@ async function rpcCall( force: true, }) ); -/* timer = setTimeout(() => { + /* timer = setTimeout(() => { socket.end(); reject("timeout"); }, 10 * 1000) as NodeJS.Timeout;*/