From a0aa86a0b337801f829033c52f0104c935645318 Mon Sep 17 00:00:00 2001 From: Kieran Date: Thu, 29 Feb 2024 12:13:08 +0000 Subject: [PATCH] delete command on timeout --- packages/worker-relay/package.json | 2 +- packages/worker-relay/src/interface.ts | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/packages/worker-relay/package.json b/packages/worker-relay/package.json index de6cb275..bafa8151 100644 --- a/packages/worker-relay/package.json +++ b/packages/worker-relay/package.json @@ -1,6 +1,6 @@ { "name": "@snort/worker-relay", - "version": "1.0.2", + "version": "1.0.3", "description": "A nostr relay in a service worker", "main": "dist/index.js", "types": "dist/index.d.ts", diff --git a/packages/worker-relay/src/interface.ts b/packages/worker-relay/src/interface.ts index ca7138e2..a57b27bb 100644 --- a/packages/worker-relay/src/interface.ts +++ b/packages/worker-relay/src/interface.ts @@ -73,6 +73,7 @@ export class WorkerRelayInterface { this.#worker.postMessage(msg); return await new Promise((resolve, reject) => { const t = setTimeout(() => { + this.#commandQueue.delete(id); reject(new Error("Timeout")); }, this.timeout); this.#commandQueue.set(id, (v, port) => {