Fix websocket leaks (#1334)

lib/nostr.js

@@ -69,6 +69,9 @@ export class Relay {
 
     try {
       return await withTimeout(checkPromise, timeout)
+    } catch (err) {
+      this.close()
+      throw err
     } finally {
       clearInterval(interval)
     }
@@ -187,7 +190,11 @@ export function nostrZapDetails (zap) {
 async function publishNostrEvent (signedEvent, relayUrl) {
   const timeout = 3000
   const relay = await Relay.connect(relayUrl, { timeout })
+  try {
     await relay.publish(signedEvent, { timeout })
+  } finally {
+    relay.close()
+  }
 }
 
 export async function crosspost (event, relays = DEFAULT_CROSSPOSTING_RELAYS) {

worker/nostr.js

@@ -54,7 +54,11 @@ export async function nip57 ({ data: { hash }, boss, lnd, models }) {
       relays.map(async r => {
         const timeout = 1000
         const relay = await Relay.connect(r, { timeout })
+        try {
           await relay.publish(e, { timeout })
+        } finally {
+          relay.close()
+        }
       })
     )
   } catch (e) {