From 491c3f51253363a3d40a4920ee208b01e0f4c612 Mon Sep 17 00:00:00 2001
From: Alex Gleason <alex@alexgleason.me>
Date: Wed, 14 Feb 2024 15:25:25 -0600
Subject: [PATCH] Catch client.query calls

---
 src/storages/optimizer.ts  | 10 +++++++---
 src/storages/reqmeister.ts | 10 +++++++---
 2 files changed, 14 insertions(+), 6 deletions(-)

diff --git a/src/storages/optimizer.ts b/src/storages/optimizer.ts
index 67c838c..dcf7ad9 100644
--- a/src/storages/optimizer.ts
+++ b/src/storages/optimizer.ts
@@ -82,9 +82,13 @@ class Optimizer implements NStore {
 
     // Finally, query the client.
     this.#debug('Querying client...');
-    for (const clientEvent of await this.#client.query(filters, opts)) {
-      results.add(clientEvent);
-      if (results.size >= limit) return getResults();
+    try {
+      for (const clientEvent of await this.#client.query(filters, opts)) {
+        results.add(clientEvent);
+        if (results.size >= limit) return getResults();
+      }
+    } catch (_e) {
+      // do nothing
     }
 
     /** Get return type from map. */
diff --git a/src/storages/reqmeister.ts b/src/storages/reqmeister.ts
index d696654..37556a0 100644
--- a/src/storages/reqmeister.ts
+++ b/src/storages/reqmeister.ts
@@ -64,10 +64,14 @@ class Reqmeister extends EventEmitter<{ [filterId: string]: (event: NostrEvent)
     if (wantedAuthors.size) filters.push({ kinds: [0], authors: [...wantedAuthors] });
 
     if (filters.length) {
-      const events = await client.query(filters, { signal: AbortSignal.timeout(timeout) });
+      try {
+        const events = await client.query(filters, { signal: AbortSignal.timeout(timeout) });
 
-      for (const event of events) {
-        this.event(event);
+        for (const event of events) {
+          this.event(event);
+        }
+      } catch (_e) {
+        // do nothing
       }
     }