From 419c7a0bb5e8e3863cc60adf862968789941151f Mon Sep 17 00:00:00 2001 From: Jon Staab Date: Thu, 2 Oct 2025 14:08:24 -0700 Subject: [PATCH] Auto close negentropy requests --- packages/net/src/diff.ts | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/packages/net/src/diff.ts b/packages/net/src/diff.ts index ae6946c..947e814 100644 --- a/packages/net/src/diff.ts +++ b/packages/net/src/diff.ts @@ -80,6 +80,8 @@ export class Difference extends EventEmitter { if (newMsg) { this._adapter.send([RelayMessageType.NegMsg, this._id, newMsg]) + } else { + this.close() } } } @@ -89,6 +91,7 @@ export class Difference extends EventEmitter { if (negid === this._id) { this.emit(DifferenceEvent.Error, msg, url) + this.close() } } }, @@ -141,12 +144,10 @@ export const diff = async ({relays, filters, ...options}: DiffOptions) => { }) diff.on(DifferenceEvent.Error, (url, message) => { - reject(message) - diff.close() + console.warn(`Negentropy error on ${url}: ${message}`) }) sleep(30_000).then(() => { - reject("timeout") diff.close() }) }),