fix: improve error reporting for trustless gateways

Include more information in the thrown errors and allow identifying
individual gateways on stringification.

Author: achingbrain

packages/block-brokers/src/trustless-gateway/trustless-gateway.ts

@@ -141,7 +141,7 @@ export class TrustlessGateway {
           this.log('GET %s %d', gwUrl, res.status)
           if (!res.ok) {
             this.#errors++
-            throw new Error(`unable to fetch raw block for CID ${cid} from gateway ${this.url}`)
+            throw new Error(`Unable to fetch raw block for CID ${cid} from gateway ${this.url}, recieved ${res.status} ${res.statusText}`)
           }
           // limited Response ensures the body is less than 2MiB (or configurable maxSize)
           // see https://github.com/ipfs/helia/issues/790
@@ -152,14 +152,14 @@ export class TrustlessGateway {
         this.#pendingResponses.set(blockId, pendingResponse)
       }
       return await pendingResponse
-    } catch (cause) {
+    } catch (cause: any) {
       // @ts-expect-error - TS thinks signal?.aborted can only be false now
       // because it was checked for true above.
       if (signal?.aborted === true) {
-        throw new Error(`fetching raw block for CID ${cid} from gateway ${this.url} was aborted`)
+        throw new Error(`Fetching raw block for CID ${cid} from gateway ${this.url} was aborted`)
       }
       this.#errors++
-      throw new Error(`unable to fetch raw block for CID ${cid}`)
+      throw new Error(`Unable to fetch raw block for CID ${cid} - ` + cause.message)
     } finally {
       signal?.removeEventListener('abort', abortInnerSignal)
       this.#pendingResponses.delete(blockId)
@@ -215,4 +215,8 @@ export class TrustlessGateway {
       pendingResponses: this.#pendingResponses.size
     }
   }
+
+  toString (): string {
+    return `TrustlessGateway(${this.url})`
+  }
 }

packages/utils/src/abstract-session.ts

@@ -100,7 +100,7 @@ export abstract class AbstractSession<Provider, RetrieveBlockProgressEvents exte
       concurrency: this.maxProviders
     })
     queue.addEventListener('failure', (evt) => {
-      this.log.error('error querying provider %o, evicting from session', evt.detail.job.options.provider, evt.detail.error)
+      this.log.error('error querying provider %s, evicting from session - %e', evt.detail.job.options.provider, evt.detail.error)
       this.evict(evt.detail.job.options.provider)
     })
     queue.addEventListener('success', (evt) => {