From 611eb4fc04726be8dd8c4e2f32a542ebfe800f12 Mon Sep 17 00:00:00 2001
From: Patrick Mulligan <patjmulligan@protonmail.com>
Date: Sat, 28 Feb 2026 07:53:09 -0500
Subject: [PATCH] fix(nostr): close SimplePool after publishing to prevent
 connection leak

Each sendEvent() call created a new SimplePool() but never closed it,
causing relay WebSocket connections to accumulate indefinitely (~20/min).

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
---
 src/services/nostr/nostrPool.ts | 30 +++++++++++++++++-------------
 1 file changed, 17 insertions(+), 13 deletions(-)

diff --git a/src/services/nostr/nostrPool.ts b/src/services/nostr/nostrPool.ts
index d5e47d7f..ee610a35 100644
--- a/src/services/nostr/nostrPool.ts
+++ b/src/services/nostr/nostrPool.ts
@@ -205,20 +205,24 @@ export class NostrPool {
         const log = getLogger({ appName: keys.name })
         this.log(`📤 Publishing Kind ${event.kind} event to ${relays.length} relay(s): ${relays.join(', ')}`)
         const pool = new SimplePool()
-        await Promise.all(pool.publish(relays, signed).map(async p => {
-            try {
-                await p
-                sent = true
-            } catch (e: any) {
-                this.log(ERROR, `Failed to publish Kind ${event.kind} event:`, e.message || e)
-                log(e)
+        try {
+            await Promise.all(pool.publish(relays, signed).map(async p => {
+                try {
+                    await p
+                    sent = true
+                } catch (e: any) {
+                    this.log(ERROR, `Failed to publish Kind ${event.kind} event:`, e.message || e)
+                    log(e)
+                }
+            }))
+            if (!sent) {
+                this.log(ERROR, `Failed to send Kind ${event.kind} event to any relay`)
+                log("failed to send event")
+            } else {
+                this.log(`✅ Kind ${event.kind} event published successfully (id: ${signed.id.slice(0, 16)}...)`)
             }
-        }))
-        if (!sent) {
-            this.log(ERROR, `Failed to send Kind ${event.kind} event to any relay`)
-            log("failed to send event")
-        } else {
-            this.log(`✅ Kind ${event.kind} event published successfully (id: ${signed.id.slice(0, 16)}...)`)
+        } finally {
+            pool.close(relays)
         }
     }