Skip to content

feat(stellar): retry + exponential backoff for Soroban RPC #28

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
gregemax wants to merge 1 commit into from
Closed

feat(stellar): retry + exponential backoff for Soroban RPC #28

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
93 changes: 65 additions & 28 deletions src/components/StellarReceive.tsx
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,7 @@ import { useStellarWallet } from '@/context/StellarWalletContext';
import { CopyButton } from '@/components/CopyButton';
import { stellarTxUrl, stellarAddrUrl } from '@/lib/explorer';
import { STELLAR_NETWORK } from '@/config';
import { withRetry, StellarRetryExhaustedError } from '@/lib/stellar/retry';

const ANNOUNCER_CONTRACT = 'CCJLJ2QRBJAAKIG6ELNQVXLLWMKKWVN5O2FKWUETHZGMPAD4MHK7WVWL';
const REGISTRY_CONTRACT = 'CC2LAUCXYOPJ4DV4CYXNXYAXRDVOTMAWFF76W4WFD5OVQBD6TN4PYYJ5';
Expand All @@ -36,20 +37,22 @@ async function fetchAnnouncementEvents(

try {
let startLedger = 1;
const probeRes = await fetch(rpcUrl, {
method: 'POST',
headers: { 'Content-Type': 'application/json' },
body: JSON.stringify({
jsonrpc: '2.0',
id: 0,
method: 'getEvents',
params: {
startLedger: 1,
filters: [{ type: 'contract', contractIds: [contractId] }],
pagination: { limit: 1 },
},
const probeRes = await withRetry(() =>
fetch(rpcUrl, {
method: 'POST',
headers: { 'Content-Type': 'application/json' },
body: JSON.stringify({
jsonrpc: '2.0',
id: 0,
method: 'getEvents',
params: {
startLedger: 1,
filters: [{ type: 'contract', contractIds: [contractId] }],
pagination: { limit: 1 },
},
}),
}),
});
);
const probeData = await probeRes.json();

if (probeData.error?.message) {
Expand Down Expand Up @@ -78,11 +81,13 @@ async function fetchAnnouncementEvents(
params.startLedger = startLedger;
}

const res = await fetch(rpcUrl, {
method: 'POST',
headers: { 'Content-Type': 'application/json' },
body: JSON.stringify({ jsonrpc: '2.0', id: 2, method: 'getEvents', params }),
});
const res = await withRetry(() =>
fetch(rpcUrl, {
method: 'POST',
headers: { 'Content-Type': 'application/json' },
body: JSON.stringify({ jsonrpc: '2.0', id: 2, method: 'getEvents', params }),
}),
);

const data = await res.json();
const events = data.result?.events ?? [];
Expand Down Expand Up @@ -150,14 +155,17 @@ function StellarStealthRow({
const [withdrawing, setWithdrawing] = useState(false);
const [withdrawHash, setWithdrawHash] = useState<string | null>(null);
const [error, setError] = useState('');
const [retryExhausted, setRetryExhausted] = useState(false);
const [showKey, setShowKey] = useState(false);

const scalarHex = match.stealthPrivateScalar.toString(16).padStart(64, '0');

useEffect(() => {
(async () => {
try {
const res = await fetch(`${STELLAR_NETWORK.horizonUrl}/accounts/${match.stealthAddress}`);
const res = await withRetry(() =>
fetch(`${STELLAR_NETWORK.horizonUrl}/accounts/${match.stealthAddress}`),
);
if (!res.ok) {
setBalance('0');
return;
Expand All @@ -176,13 +184,16 @@ function StellarStealthRow({
const handleWithdraw = async () => {
if (!dest) return;
setError('');
setRetryExhausted(false);
setWithdrawing(true);

try {
const horizonUrl = STELLAR_NETWORK.horizonUrl;
const networkPassphrase = STELLAR_NETWORK.networkPassphrase;

const res = await fetch(`${horizonUrl}/accounts/${match.stealthAddress}`);
const res = await withRetry(() =>
fetch(`${horizonUrl}/accounts/${match.stealthAddress}`),
);
if (!res.ok) throw new Error('Account not found');
const account = await res.json();

Expand Down Expand Up @@ -213,11 +224,13 @@ function StellarStealthRow({
const signatureBase64 = Buffer.from(signature).toString('base64');
tx.addSignature(match.stealthAddress, signatureBase64);

const submitRes = await fetch(`${horizonUrl}/transactions`, {
method: 'POST',
headers: { 'Content-Type': 'application/x-www-form-urlencoded' },
body: `tx=${encodeURIComponent(tx.toXDR())}`,
});
const submitRes = await withRetry(() =>
fetch(`${horizonUrl}/transactions`, {
method: 'POST',
headers: { 'Content-Type': 'application/x-www-form-urlencoded' },
body: `tx=${encodeURIComponent(tx.toXDR())}`,
}),
);

const submitData = await submitRes.json();
if (!submitRes.ok) {
Expand All @@ -229,7 +242,12 @@ function StellarStealthRow({
setWithdrawHash(submitData.hash);
onWithdrawn();
} catch (err) {
setError(err instanceof Error ? err.message : 'Withdraw failed');
if (err instanceof StellarRetryExhaustedError) {
setRetryExhausted(true);
setError('Network unstable — try again.');
} else {
setError(err instanceof Error ? err.message : 'Withdraw failed');
}
} finally {
setWithdrawing(false);
}
Expand Down Expand Up @@ -292,7 +310,19 @@ function StellarStealthRow({
</div>
)}

{error && <p className="text-xs text-error">{error}</p>}
{error && (
<div className="flex items-center gap-3">
<p className="text-xs text-error">{error}</p>
{retryExhausted && (
<button
onClick={handleWithdraw}
className="font-heading text-[11px] font-semibold uppercase tracking-widest text-primary underline"
>
Retry
</button>
)}
</div>
)}

{withdrawHash && (
<div className="flex items-center gap-2">
Expand Down Expand Up @@ -345,6 +375,7 @@ export function StellarReceive() {
const [matched, setMatched] = useState<MatchedAnnouncement[]>([]);
const [hasScanned, setHasScanned] = useState(false);
const [error, setError] = useState('');
const [scanRetryExhausted, setScanRetryExhausted] = useState(false);
const [isRegistering, setIsRegistering] = useState(false);
const [isRegSuccess, setIsRegSuccess] = useState(false);
const [regHash, setRegHash] = useState<string | null>(null);
Expand Down Expand Up @@ -502,7 +533,13 @@ export function StellarReceive() {
setMatched(results);
setHasScanned(true);
} catch (err) {
setError(err instanceof Error ? err.message : 'Scan failed');
setError(
err instanceof StellarRetryExhaustedError
? 'Network unstable — try again.'
: err instanceof Error
? err.message
: 'Scan failed',
);
} finally {
setIsScanning(false);
}
Expand Down
44 changes: 33 additions & 11 deletions src/components/StellarSend.tsx
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -18,6 +18,7 @@ import { useStellarWallet } from '@/context/StellarWalletContext';
import { stellarTxUrl, stellarAddrUrl } from '@/lib/explorer';
import { STELLAR_NETWORK } from '@/config';
import { CopyButton } from '@/components/CopyButton';
import { withRetry, StellarRetryExhaustedError } from '@/lib/stellar/retry';

const ANNOUNCER_CONTRACT = 'CCJLJ2QRBJAAKIG6ELNQVXLLWMKKWVN5O2FKWUETHZGMPAD4MHK7WVWL';

Expand All @@ -27,6 +28,7 @@ export function StellarSend() {
const [amount, setAmount] = useState('');
const [error, setError] = useState('');
const [isPending, setIsPending] = useState(false);
const [retryExhausted, setRetryExhausted] = useState(false);
const [stealthResult, setStealthResult] = useState<{
stealthAddress: string;
ephemeralPubKey: Uint8Array;
Expand All @@ -42,6 +44,7 @@ export function StellarSend() {
}

setError('');
setRetryExhausted(false);
setIsPending(true);

try {
Expand All @@ -59,13 +62,13 @@ export function StellarSend() {
const horizonUrl = STELLAR_NETWORK.horizonUrl;
const networkPassphrase = STELLAR_NETWORK.networkPassphrase;

const accountRes = await fetch(`${horizonUrl}/accounts/${address}`);
const accountRes = await withRetry(() => fetch(`${horizonUrl}/accounts/${address}`));
if (!accountRes.ok) throw new Error('Failed to load sender account');
const accountData = await accountRes.json();
const sourceAccount = new Account(address, accountData.sequence);

const stealthExists = await fetch(`${horizonUrl}/accounts/${result.stealthAddress}`).then(
(r) => r.ok,
const stealthExists = await withRetry(() =>
fetch(`${horizonUrl}/accounts/${result.stealthAddress}`).then((r) => r.ok),
);

let classicTx;
Expand Down Expand Up @@ -94,11 +97,13 @@ export function StellarSend() {

const signedXdr = await signTransaction(classicTx.toXDR());

const submitRes = await fetch(`${horizonUrl}/transactions`, {
method: 'POST',
headers: { 'Content-Type': 'application/x-www-form-urlencoded' },
body: `tx=${encodeURIComponent(signedXdr)}`,
});
const submitRes = await withRetry(() =>
fetch(`${horizonUrl}/transactions`, {
method: 'POST',
headers: { 'Content-Type': 'application/x-www-form-urlencoded' },
body: `tx=${encodeURIComponent(signedXdr)}`,
}),
);

const submitData = await submitRes.json();
if (!submitRes.ok) {
Expand All @@ -115,7 +120,7 @@ export function StellarSend() {
const soroban = new rpcMod.Server(STELLAR_NETWORK.rpcUrl);
const announcerContract = new Contract(ANNOUNCER_CONTRACT);

const freshRes = await fetch(`${horizonUrl}/accounts/${address}`);
const freshRes = await withRetry(() => fetch(`${horizonUrl}/accounts/${address}`));
const freshData = await freshRes.json();
const freshAccount = new Account(address, freshData.sequence);

Expand Down Expand Up @@ -152,7 +157,12 @@ export function StellarSend() {

setIsSuccess(true);
} catch (err) {
setError(err instanceof Error ? err.message : 'Transaction failed');
if (err instanceof StellarRetryExhaustedError) {
setRetryExhausted(true);
setError('Network unstable — try again.');
} else {
setError(err instanceof Error ? err.message : 'Transaction failed');
}
} finally {
setIsPending(false);
}
Expand Down Expand Up @@ -263,7 +273,19 @@ export function StellarSend() {
</div>
</div>

{error && <p className="text-sm text-error">{error}</p>}
{error && (
<div className="flex items-center gap-3">
<p className="text-sm text-error">{error}</p>
{retryExhausted && (
<button
onClick={handleSend}
className="font-heading text-[11px] font-semibold uppercase tracking-widest text-primary underline"
>
Retry
</button>
)}
</div>
)}

<button
onClick={handleSend}
Expand Down
Loading