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 } }