From cd5172bbb63e547e70db551ed62efab43fd3cf88 Mon Sep 17 00:00:00 2001 From: Joel Klabo Date: Mon, 26 Jan 2026 17:05:04 -0800 Subject: [PATCH] Nostr: await publish promises --- extensions/nostr/src/nostr-bus.ts | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/extensions/nostr/src/nostr-bus.ts b/extensions/nostr/src/nostr-bus.ts index 89afb04f0..792abca3f 100644 --- a/extensions/nostr/src/nostr-bus.ts +++ b/extensions/nostr/src/nostr-bus.ts @@ -676,7 +676,10 @@ async function sendEncryptedDm( const startTime = Date.now(); try { - await pool.publish([relay], reply); + const [publishResult] = await Promise.allSettled(pool.publish([relay], reply)); + if (publishResult?.status === "rejected") { + throw publishResult.reason; + } const latency = Date.now() - startTime; // Record success @@ -761,7 +764,10 @@ async function sendTypingIndicator( const startTime = Date.now(); try { - await pool.publish([relay], event); + const [publishResult] = await Promise.allSettled(pool.publish([relay], event)); + if (publishResult?.status === "rejected") { + throw publishResult.reason; + } const latency = Date.now() - startTime; cb?.recordSuccess(); healthTracker.recordSuccess(relay, latency);