diff options
| author | Adam Soltys <[email protected]> | 2026-06-26 13:50:23 -0700 |
|---|---|---|
| committer | Adam Soltys <[email protected]> | 2026-06-26 13:50:23 -0700 |
| commit | 9f4bc29025287e8e12a7ef31c9918c1adfdfff5d (patch) | |
| tree | cd78a1521769844a6b4c8acc82ee7634f6302099 /src/api.js | |
| parent | 445a2e772eba5377f74a1b68fe7f80508c05fa9c (diff) | |
| download | coinosv3-9f4bc29025287e8e12a7ef31c9918c1adfdfff5d.tar.gz coinosv3-9f4bc29025287e8e12a7ef31c9918c1adfdfff5d.zip | |
Fix broadcast hanging forever on a stalled response
The Esplora broadcast cleared its abort timer right after fetch() resolved, so
the subsequent res.text() body read had no timeout — a stalled response body
hung the whole broadcast (and the send spinner) indefinitely, with the tx never
reaching the network. Keep the abort timer active through the body read, and add
a hard 30s outer timeout in the send handler so a wedged broadcast always surfaces
as 'timed out — try again' instead of spinning forever. (The silent-payment tx
itself is valid — verified structure + BIP143 signature over the real outputs.)
Co-Authored-By: Claude Opus 4.8 (1M context) <[email protected]>
Diffstat (limited to 'src/api.js')
| -rw-r--r-- | src/api.js | 19 |
1 files changed, 10 insertions, 9 deletions
@@ -336,19 +336,20 @@ export class Api { const attempts = this._hosts.map(async (host) => { const ctrl = new AbortController(); const timer = setTimeout(() => ctrl.abort(), this._timeoutMs); - let res; try { - res = await fetch(host.base + '/tx', { method: 'POST', body: hexTx, signal: ctrl.signal }); + // Keep the abort timer active across BOTH the request and the body read — + // a stalled response body must not hang the broadcast forever. + const res = await fetch(host.base + '/tx', { method: 'POST', body: hexTx, signal: ctrl.signal }); + const body = await res.text(); + if (res.status === 429) { + host.cooldownUntil = Date.now() + 30000; + this.#penalize(); + } + if (!res.ok) throw new Error(body || `${res.status} broadcast failed`); + return body.trim(); // txid } finally { clearTimeout(timer); } - const body = await res.text(); - if (res.status === 429) { - host.cooldownUntil = Date.now() + 30000; - this.#penalize(); - } - if (!res.ok) throw new Error(body || `${res.status} broadcast failed`); - return body.trim(); // txid }); const results = await Promise.allSettled(attempts); const ok = results.find((r) => r.status === 'fulfilled'); |
