Calls: the routes found before the offer or answer ride inside it (until there's a direct and a relayed one, 1.5 s at most) and only later ones go one by one — each route was its own signed message, dozens per call; a household's two devices calling each other got its IP banned by damus and rate-limited by relay.coinos.io, and the answer was refused with them: the callee stuck on Connecting…, the caller ringing on. An offer, answer, hang-up or decline no relay took is tried again (1.5, 3, 6 s) before the call gives up.

Co-Authored-By: Claude Opus 5.5 <[email protected]>
Claude-Session: https://claude.ai/code/session_013ZDf1cyCQLkfjftYhymZAg

1 files changed, 11 insertions, 3 deletions

diff --git a/src/features/messages.js b/src/features/messages.js
index 887f327..bfdabd1 100644
--- a/src/features/messages.js
+++ b/src/features/messages.js
@@ -53,7 +53,7 @@ import { animateZap, warmZapSound } from '../zap-animation.js';
 import { SIGNER_SILENT } from '../dm.js';
 import { cacheStorage, onCacheReady, cacheIsReady } from '../cache-store.js';
 import { dlog } from '../debug.js';
-import { createCalls, openCall, wrapCall, CALL_WRAP, RING_S } from '../calls.js';
+import { createCalls, openCall, wrapCall, CALL, CALL_WRAP, RING_S } from '../calls.js';
 import { LIVE_KIND, LIVE_CHAT_KIND, LIVE_RELAYS, liveAddr, liveHost, liveTitle, liveSummary, liveImage, liveViewers, liveStarts, liveStream, liveRecording, liveStatus as announcedStatus, isLiveNow as isLiveAnnounced, liveRelays, newestByAddr, zapLine, setZapAddr } from '../live.js';
 import { qrSvg } from '../qr.js';
 
@@ -9305,9 +9305,17 @@ export function messagesFeature(ctx) {
     calls = createCalls({
       me: () => dmSubKeys()[0],
       sign: signAsMe,
+      // An offer, answer, hang-up or decline nobody took is tried again for a
+      // while (a relay's per-minute limit, a socket reconnecting): a lost
+      // answer left the caller ringing on and the callee "Connecting…".
+      // A late route isn't worth the wait.
       send: async (pk, signed) => {
-        const ok = await publishOn(await inboxFor(pk), wrapCall(signed, pk), { onauth: relayAuth });
-        if (!ok) throw new Error('not delivered');
+        const tries = signed.kind === CALL.ICE ? 1 : 4;
+        for (let i = 0; i < tries; i++) {
+          if (i) await new Promise((r) => setTimeout(r, 1500 * 2 ** (i - 1)));
+          if (await publishOn(await inboxFor(pk), wrapCall(signed, pk), { onauth: relayAuth })) return;
+        }
+        throw new Error('not delivered');
       },
       iceServers: callIce,
       media: callMedia,