+ {IS_MOBILE_WEBVIEW &&
+ MOBILE_WALLETS.map((wallet) => (
+
openWallet(wallet)}
+ className="rounded-full theme-card-elevated py-3 text-[14px] font-semibold theme-text active:scale-[0.98] transition-transform"
+ >
+ Open {wallet.name}
+
+ ))}
{IS_MOBILE_WEBVIEW && (
- Open Wallet App
+ Open another wallet
)}
+ );
+}
+
+export function PreflightSkeleton() {
+ return (
+
+ );
+}
+
+export function BranchesSkeleton() {
+ return (
+
+ {[0, 1].map((i) => (
+
+ ))}
+
+ );
+}
+
+export function SweepSkeleton() {
+ return (
+
+
+
+
+
+
+ {[0, 1].map((i) => (
+
+ ))}
+
+ );
+}
diff --git a/src/components/recovery/SweepForm.tsx b/src/components/recovery/SweepForm.tsx
new file mode 100644
index 0000000..6e39da1
--- /dev/null
+++ b/src/components/recovery/SweepForm.tsx
@@ -0,0 +1,172 @@
+import { useState } from "react";
+import { invoke } from "@tauri-apps/api/core";
+import { toast } from "sonner";
+import { parseSatAmount } from "../../utils/amount";
+import { formatSats, shortTxid } from "../../utils/format";
+import {
+ maxSweepSat,
+ poolBelowDust,
+ sweepAmountError,
+ SWEEP_FEE_BUFFER_SATS,
+ type SweepAmountError,
+} from "./sweepAmount";
+
+export interface UnrolledVtxoMaturity {
+ txid: string;
+ vout: number;
+ amountSat: number;
+ confirmedAt: number | null;
+ csvMatureAt: number | null;
+ mature: boolean;
+}
+
+function errorMessage(err: SweepAmountError): string {
+ switch (err.kind) {
+ case "invalid":
+ return "Enter a whole number of sats";
+ case "belowDust":
+ return `Below the dust limit — must be at least ${formatSats(err.dustSat)} sats`;
+ case "exceedsMax":
+ return `Max ~${formatSats(err.maxSat)} sats after the ~${formatSats(
+ SWEEP_FEE_BUFFER_SATS,
+ )} sat fee`;
+ }
+}
+
+/**
+ * Sweeps ALL mature unrolled outputs in one transaction.
+ */
+export function SweepForm({
+ totalSat,
+ dustSat,
+ outputCount,
+ onSwept,
+}: {
+ totalSat: number;
+ dustSat: number;
+ outputCount: number;
+ onSwept: () => void;
+}) {
+ const [open, setOpen] = useState(false);
+ const [address, setAddress] = useState("");
+ const [amount, setAmount] = useState(String(maxSweepSat(totalSat)));
+ const [amountTouched, setAmountTouched] = useState(false);
+ const [busy, setBusy] = useState(false);
+ // Re-seed the prefill on change unless the user has typed their own amount
+ const [seededFromSat, setSeededFromSat] = useState(totalSat);
+ if (totalSat !== seededFromSat) {
+ setSeededFromSat(totalSat);
+ if (!amountTouched) setAmount(String(maxSweepSat(totalSat)));
+ }
+
+ if (poolBelowDust(totalSat, dustSat)) {
+ return (
+
+ Too small to sweep yet — {formatSats(totalSat)} sats minus the ~
+ {formatSats(SWEEP_FEE_BUFFER_SATS)} sat fee is below the{" "}
+ {formatSats(dustSat)} sat dust limit. The sweep unlocks when more
+ outputs mature.
+
+ );
+ }
+
+ const parsedAmount = parseSatAmount(amount);
+ const amountErr = sweepAmountError(parsedAmount ?? NaN, totalSat, dustSat);
+
+ async function submit() {
+ const trimmed = address.trim();
+ if (!trimmed) {
+ toast.error("Enter a destination address");
+ return;
+ }
+ if (amountErr || parsedAmount === null) {
+ toast.error(amountErr ? errorMessage(amountErr) : "Enter a whole number of sats");
+ return;
+ }
+ setBusy(true);
+ try {
+ const txid = await invoke
("sweep_unrolled_to_onchain", {
+ address: trimmed,
+ amountSat: parsedAmount,
+ });
+ toast.success(`Swept — ${shortTxid(txid)}`);
+ setOpen(false);
+ setAddress("");
+ setAmountTouched(false);
+ onSwept();
+ } catch (e) {
+ const msg = typeof e === "string" ? e : e instanceof Error ? e.message : String(e);
+ toast.error(msg);
+ } finally {
+ setBusy(false);
+ }
+ }
+
+ if (!open) {
+ return (
+ {
+ setAmount(String(maxSweepSat(totalSat)));
+ setAmountTouched(false);
+ setOpen(true);
+ }}
+ className="block w-full rounded-xl bg-lime-300 px-4 py-2 text-center text-xs font-bold text-gray-900 active:scale-95 transition-transform"
+ >
+ Sweep {outputCount > 1 ? `${outputCount} outputs` : ""} to onchain →
+
+ );
+ }
+
+ return (
+
+
+ Destination address
+
+
+
+ Amount (sats) — max ~{formatSats(maxSweepSat(totalSat))} after fee
+
+
+ {amountErr && (
+
{errorMessage(amountErr)}
+ )}
+
+ setOpen(false)}
+ disabled={busy}
+ className="flex-1 rounded-lg theme-card px-3 py-2 text-xs font-medium"
+ >
+ Cancel
+
+ void submit()}
+ disabled={busy || amountErr !== null}
+ className="flex-1 rounded-lg bg-lime-300 px-3 py-2 text-xs font-bold text-gray-900 active:scale-95 transition-transform disabled:opacity-40"
+ >
+ {busy ? "Sweeping…" : "Sweep"}
+
+
+
(null);
+
+ const selected = SUPPORTED_FIAT_CURRENCIES.find((c) => c.code === currency);
+
+ useEffect(() => {
+ if (!open) return;
+ const close = () => {
+ setOpen(false);
+ setQuery("");
+ };
+ const handlePointerDown = (e: MouseEvent | TouchEvent) => {
+ const target = e.target as Node | null;
+ if (rootRef.current && target && !rootRef.current.contains(target)) {
+ close();
+ }
+ };
+ const handleKeyDown = (e: KeyboardEvent) => {
+ if (e.key === "Escape") close();
+ };
+ document.addEventListener("touchstart", handlePointerDown);
+ document.addEventListener("keydown", handleKeyDown);
+ return () => {
+ document.removeEventListener("touchstart", handlePointerDown);
+ document.removeEventListener("keydown", handleKeyDown);
+ };
+ }, [open]);
+
+ const filtered = useMemo(() => {
+ const q = query.trim().toLowerCase();
+ const byName = (a: FiatCurrency, b: FiatCurrency) => a.name.localeCompare(b.name);
+ const selectedEntry = SUPPORTED_FIAT_CURRENCIES.find((c) => c.code === currency);
+
+ if (q) {
+ const matches = SUPPORTED_FIAT_CURRENCIES.filter(
+ (c) =>
+ c.code !== currency &&
+ (c.code.toLowerCase().includes(q) || c.name.toLowerCase().includes(q)),
+ ).sort(byName);
+ const selectedMatches =
+ selectedEntry &&
+ (selectedEntry.code.toLowerCase().includes(q) ||
+ selectedEntry.name.toLowerCase().includes(q));
+ return selectedMatches ? [selectedEntry, ...matches] : matches;
+ }
+
+ const african: FiatCurrency[] = [];
+ const rest: FiatCurrency[] = [];
+ for (const c of SUPPORTED_FIAT_CURRENCIES) {
+ if (c.code === currency) continue;
+ (AFRICAN_CURRENCY_CODES.has(c.code) ? african : rest).push(c);
+ }
+ const grouped = [...african.sort(byName), ...rest.sort(byName)];
+ return selectedEntry ? [selectedEntry, ...grouped] : grouped;
+ }, [query, currency]);
+
+ return (
+
+
setOpen((v) => !v)}
+ className="w-full flex items-center justify-between rounded-xl theme-card-elevated px-3 py-2.5 text-left text-sm"
+ >
+
+ {selected?.flag ?? "🌐"}
+ {selected?.code ?? currency}
+ — {selected?.name ?? "Unknown"}
+
+
+
+
+ {open && (
+
+
setQuery(e.target.value)}
+ placeholder="Search currency"
+ autoCapitalize="none"
+ autoCorrect="off"
+ className="w-full rounded-lg theme-input px-3 py-2 text-sm outline-none focus:ring-2 focus:ring-lime-300/50"
+ />
+
+ {filtered.length === 0 ? (
+
No matches
+ ) : (
+ filtered.map((c) => {
+ const active = c.code === currency;
+ return (
+
{
+ onChange(c.code);
+ setOpen(false);
+ setQuery("");
+ }}
+ className={`w-full flex items-center gap-3 rounded-lg px-3 py-2 text-left text-sm transition-colors ${
+ active ? "theme-accent-bg" : "hover:opacity-80"
+ }`}
+ >
+ {c.flag}
+ {c.code}
+ {c.name}
+
+ );
+ })
+ )}
+
+
+ )}
+
+
Block Explorer (Esplora)
+
+ {presetExplorers.map((option) => (
+ setValue(option.url)}
+ className={`w-full flex items-center gap-3 rounded-xl px-3 py-2.5 text-left text-sm transition-colors ${
+ effectiveValue === option.url ? "theme-accent-bg" : "theme-card-elevated"
+ }`}
+ >
+
+ {option.label}
+ {option.url}
+
+
+ ))}
+ { if (!isCustom) setValue("https://"); }}
+ className={`w-full flex items-center gap-3 rounded-xl px-3 py-2.5 text-left text-sm transition-colors ${
+ isCustom ? "theme-accent-bg" : "theme-card-elevated"
+ }`}
+ >
+ Custom
+
+
+ {isCustom && (
+
setValue(e.target.value)}
+ placeholder="https://your-esplora-server.com/api"
+ className="w-full rounded-xl theme-input px-3 py-2 text-sm outline-none focus:ring-2 focus:ring-lime-300/50 font-mono"
+ />
+ )}
+
void save(urlToSave)}
+ className="w-full rounded-xl theme-card-elevated py-2.5 text-xs font-medium theme-text-secondary hover:opacity-80 transition-opacity disabled:opacity-50"
+ >
+ {saving ? "Saving..." : "Save"}
+
+
Esplora server for onchain sync. Takes effect on next app restart.
+
("");
+ if (price && price !== lastPrice) {
+ setLastPrice(price);
+ }
+
+ // Derive the visible state. When a background refresh fails we keep the
+ // last rate visible but mark it stale.
+ const tickerState: "off" | "live" | "loading" | "stale" | "failed" = !enabled
+ ? "off"
+ : status === "ready" && rate
+ ? "live"
+ : status === "error" && rate
+ ? "stale"
+ : status === "error"
+ ? "failed"
+ : "loading";
+
+ const badge =
+ tickerState === "live"
+ ? { label: "Live", color: "var(--color-accent)", text: "theme-accent", pulse: false, ping: true }
+ : tickerState === "loading"
+ ? { label: "Syncing", color: "var(--color-accent)", text: "theme-accent", pulse: true, ping: false }
+ : tickerState === "stale"
+ ? { label: "Stale", color: "var(--color-warning)", text: "theme-warning", pulse: false, ping: false }
+ : tickerState === "failed"
+ ? { label: "Failed", color: "var(--color-danger)", text: "theme-danger", pulse: false, ping: false }
+ : { label: "Off", color: "var(--color-text-faint)", text: "theme-text-muted", pulse: false, ping: false };
+
+ return (
+
+ {/* Header: status badge + segmented ON / OFF */}
+
+
+
+ {badge.ping && (
+
+
+ {badge.label}
+
+
+
+ onToggle(true)}
+ aria-pressed={enabled}
+ className={`rounded-lg px-3 py-1 text-[11px] font-mono font-semibold tracking-wider transition-colors ${
+ enabled ? "theme-accent-bg" : "theme-text-muted"
+ }`}
+ >
+ ON
+
+ onToggle(false)}
+ aria-pressed={!enabled}
+ className={`rounded-lg px-3 py-1 text-[11px] font-mono font-semibold tracking-wider transition-colors ${
+ !enabled ? "theme-accent-bg" : "theme-text-muted"
+ }`}
+ >
+ OFF
+
+
+
+
+ {/* Quote readout */}
+
+ {tickerState === "live" && price && rate ? (
+
+
+
+ {price}
+
+ / BTC
+
+
+ quoted {formatQuoteTime(rate.timestamp)} · yadio.io
+
+
+ ) : tickerState === "stale" && price && rate ? (
+
+
+
+ {price}
+
+ / BTC
+
+
+
+ last quote {formatQuoteTime(rate.timestamp)} · refresh failed
+
+
+ retry
+
+
+
+ ) : tickerState === "failed" ? (
+
+
+
+ Couldn't reach yadio.io
+
+
+
+
+
+
+ RETRY
+
+
+ check your connection
+
+
+
+ ) : tickerState === "loading" ? (
+
+
+
+ {/* Invisible sizer — matches the footprint of the real price */}
+
+ {lastPrice || "$00,000.00"}
+
+
+ / BTC
+
+
+ updating · yadio.io
+
+
+ ) : (
+
+
+
+ — — —
+
+ / BTC
+
+
+ fiat equivalents hidden beneath sat amounts
+
+
+ )}
+
+
+ {enabled && (
+ <>
+
+
+
+ )}
+
(null);
+ const [loading, setLoading] = useState(false);
+ const [confirmInput, setConfirmInput] = useState("");
+
+ const reveal = async () => {
+ if (nsec) {
+ setStep("revealed");
+ return;
+ }
+ setLoading(true);
+ try {
+ const value = await invoke("nostr_reveal_nsec");
+ setNsec(value);
+ setStep("revealed");
+ } catch (e) {
+ toast.error(typeof e === "string" ? e : "Failed to retrieve private key");
+ } finally {
+ setLoading(false);
+ }
+ };
+
+ const copy = async () => {
+ if (!nsec) return;
+ try {
+ await navigator.clipboard.writeText(nsec);
+ toast.success("nsec copied — paste into a trusted password manager only");
+ } catch {
+ toast.error("Failed to copy");
+ }
+ };
+
+ return (
+ <>
+ {step === "hidden" && (
+
+
setStep("confirm")}
+ className="w-full flex items-center justify-between px-4 py-3.5 text-sm text-left theme-card transition-colors"
+ >
+ Back Up Private Key
+
+
+
+
+
Reveal private key?
+
+ Your nsec controls your Nostr identity. Anyone with it can sign and impersonate you. Before continuing:
+
+
+ Make sure no one can see your screen
+ Save it to a trusted password manager — not chat or notes apps
+ It will only unlock your Nostr identity, not your wallet funds
+
+
+ Type reveal my nsec to continue
+
+
setConfirmInput(e.target.value)}
+ placeholder="reveal my nsec"
+ className="w-full rounded-xl theme-input px-4 py-2.5 text-sm outline-none focus:ring-2 focus:ring-yellow-500/50 mb-4 font-mono"
+ />
+
+ { setStep("hidden"); setConfirmInput(""); }}
+ className="flex-1 rounded-xl theme-card-elevated py-2.5 text-sm font-medium theme-text-secondary transition-colors"
+ >
+ Cancel
+
+ void reveal()}
+ disabled={loading || confirmInput.trim().toLowerCase() !== "reveal my nsec"}
+ className="flex-1 rounded-xl bg-yellow-500 py-2.5 text-sm font-bold text-gray-900 transition-colors hover:bg-yellow-400 disabled:opacity-30"
+ >
+ {loading ? "Loading..." : "Reveal"}
+
+
+
+
Save this somewhere safe — anyone with it controls your Nostr identity
+
{nsec}
+
+ Clipboard data can be read by other apps. Only paste into a trusted password manager — never into messaging apps.
+
+
+ void copy()}
+ className="flex-1 rounded-xl theme-card-elevated px-4 py-2 text-xs font-medium theme-text transition-opacity hover:opacity-80"
+ >
+ Copy nsec
+
+ {
+ setStep("hidden");
+ setNsec(null);
+ setConfirmInput("");
+ }}
+ className="flex-1 rounded-xl theme-card-elevated px-4 py-2 text-xs font-medium theme-text-muted transition-opacity hover:opacity-80"
+ >
+ Hide
+
+
+
+
+
+
+ Package broadcast endpoint
+
+
+ {badge}
+
+
+
+ Required for actually broadcasting the cached exit tree on
+ mainnet. HTTPS endpoint that wraps Bitcoin Core's{" "}
+ submitpackage{" "}
+ RPC. If unset, broadcast falls back to esplora and will fail with
+ a min-fee error.
+
+
+
+ {usingDefault && !editing && (
+ <>
+
+
Built-in endpoint
+
{defaultUrl}
+
+
setEditing(true)}
+ className="w-full rounded-xl theme-card-elevated px-4 py-2.5 text-sm font-semibold theme-text hover:opacity-80 transition-opacity"
+ >
+ Use custom endpoint
+
+
+ )}
+
+ {showForm && (
+ <>
+
+ URL
+
+
+
+ Bearer token (optional)
+ {tokenConfigured && !tokenInput && (
+ (saved)
+ )}
+
+ void removeToken()}
+ disabled={saving}
+ className="mt-1 text-[11px] theme-danger underline underline-offset-2 hover:opacity-80 disabled:opacity-40"
+ >
+ Remove saved token
+
+ )}
+
+
void save()}
+ disabled={saving}
+ className="w-full rounded-xl bg-lime-300 px-4 py-2.5 text-sm font-bold text-gray-900 transition-colors hover:bg-lime-200 disabled:opacity-40"
+ >
+ {saving ? "Saving..." : "Save endpoint"}
+
+ {editing && !hasCustom && (
+
setEditing(false)}
+ disabled={saving}
+ className="w-full rounded-xl theme-card-elevated px-4 py-2.5 text-sm font-medium theme-text-muted hover:opacity-80 transition-opacity"
+ >
+ Cancel
+
+ )}
+ {hasCustom && defaultUrl && (
+
void persist(null, null)}
+ disabled={saving}
+ className="w-full rounded-xl theme-card-elevated px-4 py-2.5 text-sm font-medium theme-text-muted hover:opacity-80 transition-opacity"
+ >
+ Reset to built-in endpoint
+
+ )}
+
+ )}
+
(null);
+ const [loading, setLoading] = useState(false);
+ const [confirmInput, setConfirmInput] = useState("");
+
+ const reveal = async () => {
+ if (mnemonic) {
+ setStep("revealed");
+ return;
+ }
+ setLoading(true);
+ try {
+ const words = await invoke("get_mnemonic");
+ setMnemonic(words);
+ setStep("revealed");
+ } catch (e) {
+ toast.error(typeof e === "string" ? e : "Failed to retrieve seed phrase");
+ } finally {
+ setLoading(false);
+ }
+ };
+
+ return (
+ <>
+ {step === "hidden" && (
+
+
setStep("confirm")}
+ className="w-full flex items-center justify-between px-4 py-3.5 text-sm text-left theme-card transition-colors"
+ >
+ Back Up Seed Phrase
+
+
+
+
+
Reveal seed phrase?
+
Your seed phrase gives full access to your funds. Before continuing:
+
+ Make sure no one can see your screen
+ Do not screenshot or copy to clipboard
+ Write the words down on paper only
+
+
+ Type reveal my seed to continue
+
+
setConfirmInput(e.target.value)}
+ placeholder="reveal my seed"
+ className="w-full rounded-xl theme-input px-4 py-2.5 text-sm outline-none focus:ring-2 focus:ring-yellow-500/50 mb-4 font-mono"
+ />
+
+ { setStep("hidden"); setConfirmInput(""); }}
+ className="flex-1 rounded-xl theme-card-elevated py-2.5 text-sm font-medium theme-text-secondary transition-colors"
+ >
+ Cancel
+
+ void reveal()}
+ disabled={loading || confirmInput.trim().toLowerCase() !== "reveal my seed"}
+ className="flex-1 rounded-xl bg-yellow-500 py-2.5 text-sm font-bold text-gray-900 transition-colors hover:bg-yellow-400 disabled:opacity-30"
+ >
+ {loading ? "Loading..." : "Reveal"}
+
+
+
+
Write these words down on paper — do not copy digitally
+
{mnemonic}
+
Never screenshot, copy to clipboard, or store digitally. Clipboard data can be read by other apps.
+
{
+ setStep("hidden");
+ setMnemonic(null);
+ setConfirmInput("");
+ }}
+ className="mt-3 rounded-xl theme-card-elevated px-4 py-2 text-xs font-medium theme-text-muted hover:opacity-80 transition-opacity"
+ >
+ Hide seed phrase
+
+
(null);
+ const deadTopicsRef = useRef>(new Set());
+
+ const rejectAccountlessSession = useCallback(
+ (client: SignClient, session: SessionTypes.Struct) => {
+ deadTopicsRef.current.add(session.topic);
+ client
+ .disconnect({
+ topic: session.topic,
+ reason: { code: 6000, message: "Session has no eip155 account" },
+ })
+ .catch(() => {
+ // Best-effort: the topic is in deadTopicsRef, so even if the
+ // relay is unreachable and the session lingers in the store, it
+ // will never be adopted.
+ });
+ },
+ []
+ );
useEffect(() => {
if (!PROJECT_ID) return;
@@ -96,11 +121,13 @@ export function WalletConnectProvider({
// sessions to localStorage by default — survives app restart.
const sessions = client.session.getAll();
const session = sessions.length > 0 ? sessions[sessions.length - 1] : null;
- if (session) {
+ const restoredAddress = session ? sessionAddress(session) : null;
+ if (session && restoredAddress) {
sessionRef.current = session;
- setAddress(addressFromAccount(session.namespaces.eip155?.accounts[0]));
+ setAddress(restoredAddress);
setStatus("connected");
} else {
+ if (session) rejectAccountlessSession(client, session);
setStatus("idle");
}
@@ -131,6 +158,41 @@ export function WalletConnectProvider({
};
}, []);
+ // Re-sync from the SignClient session store while the app is running.
+ useEffect(() => {
+ function syncFromStore() {
+ const client = clientRef.current;
+ if (!client) return;
+ const sessions = client.session.getAll();
+ const latest =
+ sessions.length > 0 ? sessions[sessions.length - 1] : null;
+ if (!latest) return;
+ if (latest.topic === sessionRef.current?.topic) return;
+ if (deadTopicsRef.current.has(latest.topic)) return;
+ const addr = sessionAddress(latest);
+ if (!addr) {
+ rejectAccountlessSession(client, latest);
+ return;
+ }
+ sessionRef.current = latest;
+ setAddress(addr);
+ setPairingUri(null);
+ setError(null);
+ setStatus("connected");
+ }
+ function onVisibility() {
+ if (document.visibilityState === "visible") syncFromStore();
+ }
+ const intervalId = window.setInterval(syncFromStore, 1500);
+ document.addEventListener("visibilitychange", onVisibility);
+ window.addEventListener("focus", syncFromStore);
+ return () => {
+ window.clearInterval(intervalId);
+ document.removeEventListener("visibilitychange", onVisibility);
+ window.removeEventListener("focus", syncFromStore);
+ };
+ }, []);
+
const connect = useCallback(async () => {
const client = clientRef.current;
if (!client) return;
@@ -138,7 +200,8 @@ export function WalletConnectProvider({
setStatus("connecting");
try {
const { uri, approval } = await client.connect({
- requiredNamespaces: {
+ requiredNamespaces: {},
+ optionalNamespaces: {
eip155: {
chains: [ETH_MAINNET],
methods: EIP155_METHODS,
@@ -148,15 +211,28 @@ export function WalletConnectProvider({
});
if (uri) setPairingUri(uri);
const session = await approval();
+ const addr = sessionAddress(session);
+ if (!addr) {
+ rejectAccountlessSession(client, session);
+ setPairingUri(null);
+ setStatus("error");
+ setError(
+ "The wallet approved the connection without an Ethereum account. " +
+ "Reconnect and select an Ethereum account in your wallet."
+ );
+ return;
+ }
sessionRef.current = session;
- setAddress(addressFromAccount(session.namespaces.eip155?.accounts[0]));
+ setAddress(addr);
setPairingUri(null);
setStatus("connected");
} catch (e) {
console.error("[wc] connect() failed:", e);
setPairingUri(null);
- setStatus("error");
- setError((e as Error).message ?? String(e));
+ if (!sessionRef.current) {
+ setStatus("error");
+ setError((e as Error).message ?? String(e));
+ }
}
}, []);
@@ -168,6 +244,8 @@ export function WalletConnectProvider({
const disconnect = useCallback(async () => {
const client = clientRef.current;
const session = sessionRef.current;
+ // Mark the topic dead BEFORE the relay round-trip
+ if (session) deadTopicsRef.current.add(session.topic);
sessionRef.current = null;
setAddress(null);
setStatus("idle");
@@ -178,7 +256,7 @@ export function WalletConnectProvider({
reason: { code: 6000, message: "User disconnected" },
});
} catch {
- // Already disconnected / topic invalid — state is already cleared.
+ // Relay unreachable or topic already gone.
}
}
}, []);
diff --git a/src/context/WalletContext.tsx b/src/context/WalletContext.tsx
index 1e6efb5..dada777 100644
--- a/src/context/WalletContext.tsx
+++ b/src/context/WalletContext.tsx
@@ -18,6 +18,7 @@ export type ConnectionState =
| "connecting"
| "loading"
| "connected"
+ | "offline"
| "error";
type FetchMode = "initial" | "manual" | "auto";
@@ -100,9 +101,21 @@ export function WalletProvider({ children }: { children: React.ReactNode }) {
const cancelledRef = useRef(false);
const fetchIdRef = useRef(0);
const autoFailureStreakRef = useRef(0);
+ const connectionStateRef = useRef("checking");
+
+ useEffect(() => {
+ connectionStateRef.current = connectionState;
+ }, [connectionState]);
const fetchData = useCallback(
async (mode: FetchMode = "auto") => {
+ if (connectionStateRef.current === "offline") {
+ if (mode === "manual") {
+ toast.error("ASP is unreachable. Retry the connection before refreshing.");
+ }
+ return;
+ }
+
const id = ++fetchIdRef.current;
setRefreshing(true);
try {
@@ -182,6 +195,11 @@ export function WalletProvider({ children }: { children: React.ReactNode }) {
);
const fetchVtxos = useCallback(async (force = false) => {
+ if (connectionStateRef.current === "offline") {
+ toast.error("ASP is unreachable. Retry the connection before loading coins.");
+ return;
+ }
+
if (!force) {
const age = Date.now() - lastVtxosFetchRef.current;
if (lastVtxosFetchRef.current > 0 && age < VTXOS_STALE_TIME_MS) return;
@@ -230,7 +248,7 @@ export function WalletProvider({ children }: { children: React.ReactNode }) {
const message =
typeof error === "string" ? error : "Failed to connect to ASP";
setConnectionError(message);
- setConnectionState("error");
+ setConnectionState("offline");
});
})
.catch((error) => {
diff --git a/src/router.tsx b/src/router.tsx
index d06312e..23cbe14 100644
--- a/src/router.tsx
+++ b/src/router.tsx
@@ -10,6 +10,7 @@ import { SwapRoute } from "./routes/swap-route";
import { SwapCheckoutRoute } from "./routes/swap-checkout-route";
import { SwapHistoryRoute } from "./routes/swap-history-route";
import { RecoverLnRoute } from "./routes/recover-ln-route";
+import { RecoveryRoute } from "./routes/recovery-route";
import { ProfileRoute } from "./routes/profile-route";
import { AppLayout } from "./components/AppLayout";
@@ -95,6 +96,12 @@ const recoverLnRoute = createRoute({
component: RecoverLnRoute,
});
+const recoveryRoute = createRoute({
+ getParentRoute: () => appLayoutRoute,
+ path: "/recover/exit",
+ component: RecoveryRoute,
+});
+
const profileRoute = createRoute({
getParentRoute: () => appLayoutRoute,
path: "/profile",
@@ -112,6 +119,7 @@ const routeTree = rootRoute.addChildren([
swapCheckoutRoute,
swapHistoryRoute,
recoverLnRoute,
+ recoveryRoute,
profileRoute,
settingsRoute,
]),
diff --git a/src/routes/coins-route.tsx b/src/routes/coins-route.tsx
index 0539a34..67cb930 100644
--- a/src/routes/coins-route.tsx
+++ b/src/routes/coins-route.tsx
@@ -5,6 +5,8 @@ import { formatSats } from "../utils/format";
import { useWallet } from "../context/WalletContext";
import { VtxoCard } from "../components/VtxoCard";
import type { VtxoInfo } from "../components/VtxoCard";
+import { ExitingVtxoCard } from "../components/ExitingVtxoCard";
+import type { UnrolledVtxoMaturity } from "../components/recovery/SweepForm";
import SelectedCoinsSendDrawer from "../components/SelectedCoinsSendDrawer";
interface FeeEstimate {
@@ -16,21 +18,51 @@ interface RenewResult {
txid: string | null;
}
+/// Subset of the recovery screen's ExitSweepStatus that the coins list needs.
+interface ExitSweepStatus {
+ now: number;
+ vtxos: UnrolledVtxoMaturity[];
+}
+
type SortKey = "expiry" | "amount";
-type FilterStatus = "all" | "confirmed" | "preconfirmed" | "recoverable";
+type FilterStatus = "all" | "confirmed" | "preconfirmed" | "recoverable" | "exiting";
const FILTERS: { value: FilterStatus; label: string }[] = [
{ value: "all", label: "All" },
{ value: "confirmed", label: "Spendable" },
{ value: "preconfirmed", label: "Pre-confirmed" },
{ value: "recoverable", label: "Recoverable" },
+ { value: "exiting", label: "Exiting" },
];
+const SETTLE_ELIGIBILITY_WINDOW_SECS = 28 * 24 * 60 * 60;
+
function isExpiring(expiresAt: number): boolean {
const now = Date.now() / 1000;
return (expiresAt - now) / 3600 < 72;
}
+function canSettleVtxo(vtxo: VtxoInfo, now: number): boolean {
+ return vtxo.status === "recoverable" || vtxo.expires_at - now <= SETTLE_ELIGIBILITY_WINDOW_SECS;
+}
+
+function actionForTargets(targets: VtxoInfo[]): "recover" | "settle" | "renew" {
+ if (targets.length > 0 && targets.every((v) => v.status === "recoverable")) return "recover";
+ if (targets.some((v) => v.status === "preconfirmed")) return "settle";
+ return "renew";
+}
+
+function actionText(action: "recover" | "settle" | "renew") {
+ switch (action) {
+ case "recover":
+ return { label: "Recover", active: "Recovering...", done: "recovered" };
+ case "settle":
+ return { label: "Settle", active: "Settling...", done: "settled" };
+ case "renew":
+ return { label: "Renew", active: "Renewing...", done: "renewed" };
+ }
+}
+
export function CoinsRoute() {
const {
fetchData,
@@ -50,20 +82,40 @@ export function CoinsRoute() {
const [selectMode, setSelectMode] = useState(false);
const [selectedKeys, setSelectedKeys] = useState>(new Set());
const [sendDrawerOpen, setSendDrawerOpen] = useState(false);
+ const [exitSweep, setExitSweep] = useState(null);
const loading = !vtxosLoaded;
- // On mount, refresh in the background. fetchVtxos() (no-arg) skips the
- // network call when the cache is still fresh, so re-navigating between
- // tabs is cheap; first-ever mount triggers the full load.
+ // VTXOs mid unilateral-exit. Best-effort: needs the ASP (CSV delay) plus
+ // esplora, and most wallets have none — failure just hides the section.
+ const fetchExiting = useCallback(async () => {
+ try {
+ setExitSweep(await invoke("unilateral_exit_sweep_status"));
+ } catch {
+ setExitSweep(null);
+ }
+ }, []);
+
useEffect(() => {
void fetchVtxos();
- }, [fetchVtxos]);
+ void fetchExiting();
+ }, [fetchVtxos, fetchExiting]);
+
+ const nowSecs = Date.now() / 1000;
- const nowSecs = useMemo(() => Date.now() / 1000, [vtxos]);
+ // The ASP's vtxo list and the exiting list overlap during the window where
+ // an exit leaf is in the mempool but the ASP hasn't flagged the VTXO
+ // unrolled yet
+ const spendableVtxos = useMemo(() => {
+ const exiting = exitSweep?.vtxos;
+ if (!exiting || exiting.length === 0) return vtxos;
+ const exitingKeys = new Set(exiting.map((v) => `${v.txid}:${v.vout}`));
+ return vtxos.filter((v) => !exitingKeys.has(`${v.txid}:${v.vout}`));
+ }, [vtxos, exitSweep]);
const filtered = useMemo(() => {
- let result = vtxos;
+ if (filter === "exiting") return [];
+ let result = spendableVtxos;
if (filter !== "all") {
result = result.filter((v) => v.status === filter);
}
@@ -71,21 +123,37 @@ export function CoinsRoute() {
if (sortKey === "expiry") return a.expires_at - b.expires_at;
return b.amount_sat - a.amount_sat;
});
- }, [vtxos, filter, sortKey]);
+ }, [spendableVtxos, filter, sortKey]);
+
+
+ const shownExiting = useMemo(
+ () => (filter === "all" || filter === "exiting" ? (exitSweep?.vtxos ?? []) : []),
+ [filter, exitSweep],
+ );
+
+ const preconfirmedVtxos = useMemo(
+ () => spendableVtxos.filter((v) => v.status === "preconfirmed"),
+ [spendableVtxos],
+ );
+
+ const settleablePreconfirmedVtxos = useMemo(
+ () => preconfirmedVtxos.filter((v) => canSettleVtxo(v, nowSecs)),
+ [preconfirmedVtxos, nowSecs],
+ );
const expiringVtxos = useMemo(
- () => vtxos.filter((v) => v.status !== "recoverable" && isExpiring(v.expires_at)),
- [vtxos],
+ () => spendableVtxos.filter((v) => v.status === "confirmed" && isExpiring(v.expires_at)),
+ [spendableVtxos],
);
const recoverableVtxos = useMemo(
- () => vtxos.filter((v) => v.status === "recoverable"),
- [vtxos],
+ () => spendableVtxos.filter((v) => v.status === "recoverable"),
+ [spendableVtxos],
);
const selectedVtxos = useMemo(
- () => vtxos.filter((v) => selectedKeys.has(`${v.txid}:${v.vout}`)),
- [vtxos, selectedKeys],
+ () => spendableVtxos.filter((v) => selectedKeys.has(`${v.txid}:${v.vout}`)),
+ [spendableVtxos, selectedKeys],
);
const selectedTotalSat = useMemo(
@@ -93,28 +161,43 @@ export function CoinsRoute() {
[selectedVtxos],
);
+ const selectedSettleableVtxos = useMemo(
+ () => selectedVtxos.filter((v) => canSettleVtxo(v, nowSecs)),
+ [selectedVtxos, nowSecs],
+ );
+
+ const selectedSkippedVtxos = selectedVtxos.length - selectedSettleableVtxos.length;
+
const startRenew = useCallback(async (targets: VtxoInfo[]) => {
if (renewing) return;
- if (targets.length === 0) {
- toast.info("Nothing to renew");
+ const eligibleTargets = targets.filter((v) => canSettleVtxo(v, Date.now() / 1000));
+ const skippedTargets = targets.length - eligibleTargets.length;
+
+ if (eligibleTargets.length === 0) {
+ const action = actionText(actionForTargets(targets));
+ toast.info(`No VTXOs are ready to ${action.label.toLowerCase()} yet`);
return;
}
+ if (skippedTargets > 0) {
+ toast.info(`${skippedTargets} VTXO${skippedTargets > 1 ? "s" : ""} skipped; not close enough to expiry yet`);
+ }
if (quickRenew) {
// Skip confirmation
+ const action = actionText(actionForTargets(eligibleTargets));
setRenewing(true);
- const outpoints = targets.map((v) => `${v.txid}:${v.vout}`);
+ const outpoints = eligibleTargets.map((v) => `${v.txid}:${v.vout}`);
try {
const result = await invoke("renew_vtxos", { outpoints });
if (result.renewed) {
- toast.success(`${outpoints.length} VTXO${outpoints.length > 1 ? "s" : ""} renewed${result.txid ? ` (txid: ${result.txid})` : ""}`);
+ toast.success(`${outpoints.length} VTXO${outpoints.length > 1 ? "s" : ""} ${action.done}${result.txid ? ` (txid: ${result.txid})` : ""}`);
void fetchVtxos(true);
void fetchData();
} else {
- toast.info("Nothing to renew");
+ toast.info(`Nothing to ${action.label.toLowerCase()}`);
}
} catch (e) {
- toast.error(typeof e === "string" ? e : "Failed to renew VTXOs");
+ toast.error(typeof e === "string" ? e : `Failed to ${action.label.toLowerCase()} VTXOs`);
} finally {
setRenewing(false);
}
@@ -122,8 +205,8 @@ export function CoinsRoute() {
}
setRenewing(true);
- setPendingRenewTargets(targets);
- const outpoints = targets.map((v) => `${v.txid}:${v.vout}`);
+ setPendingRenewTargets(eligibleTargets);
+ const outpoints = eligibleTargets.map((v) => `${v.txid}:${v.vout}`);
try {
const fee = await invoke("estimate_renew_fees", { outpoints });
setFeeEstimate(fee);
@@ -138,6 +221,7 @@ export function CoinsRoute() {
const confirmRenew = useCallback(async () => {
const targets = pendingRenewTargets ?? [];
+ const action = actionText(actionForTargets(targets));
const outpoints = targets.map((v) => `${v.txid}:${v.vout}`);
setRenewing(true);
setShowRenewConfirm(false);
@@ -145,19 +229,27 @@ export function CoinsRoute() {
try {
const result = await invoke("renew_vtxos", { outpoints });
if (result.renewed) {
- toast.success(`${outpoints.length} VTXO${outpoints.length > 1 ? "s" : ""} renewed${result.txid ? ` (txid: ${result.txid})` : ""}`);
+ toast.success(`${outpoints.length} VTXO${outpoints.length > 1 ? "s" : ""} ${action.done}${result.txid ? ` (txid: ${result.txid})` : ""}`);
+ setSelectMode(false);
+ setSelectedKeys(new Set());
void fetchVtxos(true);
void fetchData();
} else {
- toast.info("Nothing to renew");
+ toast.info(`Nothing to ${action.label.toLowerCase()}`);
}
} catch (e) {
- toast.error(typeof e === "string" ? e : "Failed to renew VTXOs");
+ toast.error(typeof e === "string" ? e : `Failed to ${action.label.toLowerCase()} VTXOs`);
} finally {
setRenewing(false);
}
}, [pendingRenewTargets, fetchVtxos, fetchData]);
+ const pendingRenewAction = actionText(actionForTargets(pendingRenewTargets ?? []));
+ const selectedRenewAction = actionText(actionForTargets(selectedSettleableVtxos));
+ const selectedSettleLabel = selectedSettleableVtxos.length > 0
+ ? `${selectedRenewAction.label} ${selectedSettleableVtxos.length} selected`
+ : "No ready VTXOs";
+
const toggleSelectMode = useCallback(() => {
setExpandedId(null);
setShowRenewConfirm(false);
@@ -213,7 +305,10 @@ export function CoinsRoute() {
{selectMode ? "Cancel" : "Select"}
void fetchVtxos(true)}
+ onClick={() => {
+ void fetchVtxos(true);
+ void fetchExiting();
+ }}
disabled={refreshingVtxos}
className="rounded-full theme-card-elevated p-2 theme-text-secondary hover:opacity-80 transition-colors disabled:opacity-40"
title="Refresh"
@@ -236,7 +331,7 @@ export function CoinsRoute() {
{recoverableVtxos.length > 0 && (
1 ? "s" : ""} (${formatSats(recoverableVtxos.reduce((sum, v) => sum + v.amount_sat, 0))} sats)`}
)}
+ {settleablePreconfirmedVtxos.length > 0 && (
+
void startRenew(settleablePreconfirmedVtxos)}
+ disabled={renewing}
+ className="w-full rounded-xl theme-accent-bg py-2.5 text-sm font-medium theme-accent hover:opacity-80 transition-opacity disabled:opacity-50"
+ >
+ {renewing ? "Settling..." : `Settle ${settleablePreconfirmedVtxos.length} pre-confirmed VTXO${settleablePreconfirmedVtxos.length > 1 ? "s" : ""} (${formatSats(settleablePreconfirmedVtxos.reduce((sum, v) => sum + v.amount_sat, 0))} sats)`}
+
+ )}
{expiringVtxos.length > 0 && (
void startRenew(expiringVtxos)}
@@ -260,9 +364,9 @@ export function CoinsRoute() {
)}
{/* Renew Confirmation */}
- {!selectMode && showRenewConfirm && (
+ {showRenewConfirm && (
-
Renew VTXOs?
+
{pendingRenewAction.label} VTXOs?
This settles all eligible VTXOs into the next ASP round.
@@ -278,7 +382,7 @@ export function CoinsRoute() {
-
Quick renew (skip confirmation next time)
+
Quick {pendingRenewAction.label.toLowerCase()} (skip confirmation next time)
- {renewing ? "Renewing..." : "Renew"}
+ {renewing ? pendingRenewAction.active : pendingRenewAction.label}
- VTXOs ({filtered.length})
+ VTXOs ({filtered.length + shownExiting.length})
- {filtered.length === 0 ? (
+ {filtered.length === 0 && shownExiting.length === 0 ? (
{filter !== "all" ? "No matching VTXOs" : "No VTXOs"}
) : (
-
+
{filtered.map((vtxo) => {
const key = `${vtxo.txid}:${vtxo.vout}`;
return (
@@ -348,7 +452,7 @@ export function CoinsRoute() {
vtxo={vtxo}
now={nowSecs}
expanded={expandedId === key}
- canAct={!selectMode && !showRenewConfirm && !renewing}
+ canAct={!selectMode && !showRenewConfirm && !renewing && canSettleVtxo(vtxo, nowSecs)}
onToggle={() => setExpandedId(expandedId === key ? null : key)}
onAction={() => void startRenew([vtxo])}
selectable={selectMode && vtxo.status !== "recoverable"}
@@ -357,12 +461,19 @@ export function CoinsRoute() {
/>
);
})}
+ {shownExiting.map((vtxo) => (
+
)}
{/* Coin-control send footer — sits just above the bottom nav */}
- {selectMode && (
+ {selectMode && !showRenewConfirm && (
{selectedVtxos.length} selected
+ {selectedSkippedVtxos > 0 ? `, ${selectedSkippedVtxos} not ready` : ""}
{formatSats(selectedTotalSat)} sats
void startRenew(selectedVtxos)}
+ className="mb-2 w-full rounded-xl theme-accent-bg py-2.5 text-sm font-bold theme-accent active:scale-[0.98] transition-transform disabled:opacity-30 disabled:active:scale-100"
+ >
+ {renewing ? selectedRenewAction.active : selectedSettleLabel}
+
+
setSendDrawerOpen(true)}
className="w-full rounded-xl bg-lime-300 py-2.5 text-sm font-bold text-gray-900 active:scale-[0.98] transition-transform disabled:opacity-30 disabled:active:scale-100"
>
diff --git a/src/routes/recovery-route.tsx b/src/routes/recovery-route.tsx
new file mode 100644
index 0000000..4ff567e
--- /dev/null
+++ b/src/routes/recovery-route.tsx
@@ -0,0 +1,599 @@
+import { useCallback, useEffect, useRef, useState } from "react";
+import { Link } from "@tanstack/react-router";
+import { invoke } from "@tauri-apps/api/core";
+import { toast } from "sonner";
+import {
+ BranchesSkeleton,
+ PreflightSkeleton,
+ Skeleton,
+ SweepSkeleton,
+} from "../components/recovery/Skeleton";
+import { SweepForm, type UnrolledVtxoMaturity } from "../components/recovery/SweepForm";
+import { formatCountdown, formatSats, shortTxid } from "../utils/format";
+
+interface PreflightStatus {
+ ready: boolean;
+ blockers: string[];
+ onchainBalanceSat: number;
+ onchainPendingSat: number;
+ onchainAddress: string | null;
+}
+
+interface ExitTxStatus {
+ txid: string;
+ confirmedAt: number | null;
+}
+
+interface ExitBranchStatus {
+ branchIndex: number;
+ txs: ExitTxStatus[];
+ nextPendingIndex: number | null;
+ sourceOutpoint: string | null;
+ sourceAmountSat: number | null;
+}
+
+interface UnilateralExitStatus {
+ branches: ExitBranchStatus[];
+}
+
+interface ExitSweepStatus {
+ csvDelaySeconds: number;
+ now: number;
+ dustSat: number;
+ vtxos: UnrolledVtxoMaturity[];
+}
+
+interface BroadcastOutcome {
+ parentTxid: string;
+ anchorTxid: string | null;
+ feeSat: number;
+ alreadyPublished: boolean;
+ dryRun: boolean;
+}
+
+const POLL_INTERVAL_MS = 30_000;
+
+function disabledHint(pf: PreflightStatus | null, busy: boolean): string | null {
+ if (busy || !pf || pf.ready) return null;
+ if (pf.onchainBalanceSat === 0) {
+ if (pf.onchainPendingSat > 0) {
+ return "Waiting for your pending onchain change to confirm (~1 block).";
+ }
+ return "Send plain-onchain sats to the address above to enable.";
+ }
+ return "Resolve the pre-flight blockers above to enable.";
+}
+
+function formatExitDelay(secs: number): string {
+ if (secs < 3600) return `${Math.floor(secs / 60)}m`;
+ const h = secs / 3600;
+ if (h < 48) return `${Math.round(h)}h`;
+ return `${Math.round(h / 24)}d`;
+}
+
+async function shareAddress(address: string) {
+ if (navigator.share) {
+ try {
+ await navigator.share({ title: "Plain onchain address", text: address });
+ return;
+ } catch (err) {
+ if (err instanceof Error && err.name === "AbortError") return;
+ }
+ }
+ try {
+ await invoke("share_text", { text: address });
+ } catch {
+ toast.error("Failed to share");
+ }
+}
+
+export function RecoveryRoute() {
+ const [preflight, setPreflight] = useState(null);
+ const [status, setStatus] = useState(null);
+ const [sweep, setSweep] = useState(null);
+ const [loading, setLoading] = useState(true);
+ const [refreshing, setRefreshing] = useState(false);
+ const [statusLoading, setStatusLoading] = useState(true);
+ const [sweepLoading, setSweepLoading] = useState(true);
+ const [loadError, setLoadError] = useState(null);
+ const [actionBusy, setActionBusy] = useState(null);
+ const [confirmation, setConfirmation] = useState<{
+ branchIndex: number;
+ outcome: BroadcastOutcome;
+ } | null>(null);
+ const cancelledRef = useRef(false);
+
+ const loadAll = useCallback(async (showLoading: boolean) => {
+ if (showLoading) setLoading(true);
+ else setRefreshing(true);
+ setLoadError(null);
+
+ try {
+ const pf = await invoke("unilateral_exit_preflight");
+ if (cancelledRef.current) return;
+ setPreflight(pf);
+ } catch (e) {
+ if (cancelledRef.current) return;
+ const msg = typeof e === "string" ? e : (e instanceof Error ? e.message : String(e));
+ setLoadError(msg);
+ if (showLoading) setLoading(false);
+ else setRefreshing(false);
+ setStatusLoading(false);
+ setSweepLoading(false);
+ return;
+ }
+
+ if (!cancelledRef.current) {
+ if (showLoading) setLoading(false);
+ else setRefreshing(false);
+ }
+
+ setStatusLoading(true);
+ setSweepLoading(true);
+
+ const statusPromise = invoke("unilateral_exit_status")
+ .then((st) => {
+ if (cancelledRef.current) return;
+ setStatus(st);
+ })
+ .catch((e) => {
+ if (cancelledRef.current) return;
+ const msg = typeof e === "string" ? e : (e instanceof Error ? e.message : String(e));
+ console.warn("unilateral_exit_status failed:", msg);
+ })
+ .finally(() => {
+ if (!cancelledRef.current) setStatusLoading(false);
+ });
+
+ const sweepPromise = invoke("unilateral_exit_sweep_status")
+ .then((sw) => {
+ if (cancelledRef.current) return;
+ setSweep(sw);
+ })
+ .catch((e) => {
+ if (cancelledRef.current) return;
+ const msg = typeof e === "string" ? e : (e instanceof Error ? e.message : String(e));
+ console.warn("unilateral_exit_sweep_status failed:", msg);
+ })
+ .finally(() => {
+ if (!cancelledRef.current) setSweepLoading(false);
+ });
+
+ await Promise.allSettled([statusPromise, sweepPromise]);
+ }, []);
+
+ useEffect(() => {
+ cancelledRef.current = false;
+ void loadAll(true);
+ const interval = setInterval(() => void loadAll(false), POLL_INTERVAL_MS);
+ return () => {
+ cancelledRef.current = true;
+ clearInterval(interval);
+ };
+ }, [loadAll]);
+
+ async function onPrepareBroadcast(branchIndex: number) {
+ setActionBusy(branchIndex);
+ setConfirmation(null);
+ try {
+ const outcome = await invoke("unilateral_exit_broadcast_next", {
+ branchIndex,
+ dryRun: true,
+ });
+ if (outcome.alreadyPublished) {
+ toast.info("Every transaction in this branch is already on-chain.");
+ await loadAll(false);
+ return;
+ }
+ setConfirmation({ branchIndex, outcome });
+ } catch (e) {
+ const msg = typeof e === "string" ? e : (e instanceof Error ? e.message : String(e));
+ toast.error(msg);
+ } finally {
+ setActionBusy(null);
+ }
+ }
+
+ async function onConfirmBroadcast() {
+ if (!confirmation) return;
+ const { branchIndex } = confirmation;
+ setActionBusy(branchIndex);
+ setConfirmation(null);
+ try {
+ const outcome = await invoke("unilateral_exit_broadcast_next", {
+ branchIndex,
+ dryRun: false,
+ });
+ if (outcome.alreadyPublished) {
+ toast.info("Already on-chain — nothing was broadcast.");
+ } else {
+ toast.success(
+ `Broadcast ${shortTxid(outcome.parentTxid)} (anchor ${shortTxid(
+ outcome.anchorTxid ?? "",
+ )}, ${formatSats(outcome.feeSat)} sats fee).`,
+ );
+ }
+ await loadAll(false);
+ } catch (e) {
+ const msg = typeof e === "string" ? e : (e instanceof Error ? e.message : String(e));
+ toast.error(msg);
+ } finally {
+ setActionBusy(null);
+ }
+ }
+
+ return (
+
+
+ Emergency exit
+ void loadAll(false)}
+ disabled={refreshing || loading || statusLoading || sweepLoading}
+ className="rounded-full theme-card-elevated p-2 active:scale-95 transition-transform disabled:opacity-50"
+ >
+
+
+
+
+
+
+ Broadcasts your cached unilateral-exit tree to Bitcoin without the ASP. Each
+ transaction is fee-bumped from your onchain balance; you must wait for each to
+ confirm before broadcasting the next. After every tx in a branch confirms, the
+ VTXO is on-chain — sweeping it to a regular address is a separate flow that
+ opens after the exit-delay (CSV) elapses.
+
+
+ {loading && (
+ <>
+
+
+
+
+ Loading recovery state
+
+
+ )}
+
+ {loadError && !loading && (
+
+ Couldn't load recovery state: {loadError}
+
+ )}
+
+ {!loading && preflight && (
+
+
+
Pre-flight
+
+ {preflight.ready ? "Ready" : "Blocked"}
+
+
+ {preflight.blockers.map((b, i) => (
+
+ {b}
+
+ ))}
+
+ )}
+ {preflight.onchainBalanceSat === 0 &&
+ preflight.onchainPendingSat === 0 &&
+ preflight.onchainAddress && (
+
+
Plain onchain address
+
+ Send any small amount (~5-10k sats) here to fund fee-bumping.
+ This is not your boarding address.
+
+
+ {preflight.onchainAddress}
+
+
+ {
+ void navigator.clipboard.writeText(preflight.onchainAddress!).then(
+ () => toast.success("Address copied"),
+ () => toast.error("Failed to copy"),
+ );
+ }}
+ >
+ Copy
+
+ void shareAddress(preflight.onchainAddress!)}
+ >
+ Share
+
+
+
+
+
Onchain available
+
+ {formatSats(preflight.onchainBalanceSat)} sats
+ {preflight.onchainPendingSat > 0 && (
+
+ {" · "}
+ {formatSats(preflight.onchainPendingSat)} pending
+
+ )}
+
+
+
+
Branches
+ {status !== null ? (
+
{status.branches.length}
+ ) : statusLoading ? (
+
+ ) : (
+
+ —
+
+ )}
+
+
+ )}
+
+ {!loading && statusLoading && status === null &&
}
+
+ {!loading && !statusLoading && status === null && (
+
+ Couldn't load recovery branches. Tap refresh to retry.
+
+ )}
+
+ {!loading && status && status.branches.length > 0 && (() => {
+ // Multiple VTXOs can descend from the same Ark round commitment, so
+ // their exit chains share early-tree virtual txs. Map each pending
+ // txid to the branches it's the next-pending for; if more than one
+ // branch shares it, broadcasting once advances all of them.
+ const sharedNextPending = new Map
();
+ for (const b of status.branches) {
+ if (b.nextPendingIndex !== null) {
+ const txid = b.txs[b.nextPendingIndex].txid;
+ const list = sharedNextPending.get(txid) ?? [];
+ list.push(b.branchIndex);
+ sharedNextPending.set(txid, list);
+ }
+ }
+ return (
+
+ {status.branches.map((branch) => {
+ const total = branch.txs.length;
+ const confirmed = branch.txs.filter((t) => t.confirmedAt !== null).length;
+ const allDone = branch.nextPendingIndex === null;
+ const busy = actionBusy === branch.branchIndex;
+ const showingConfirm = confirmation?.branchIndex === branch.branchIndex;
+ const nextTx =
+ branch.nextPendingIndex !== null ? branch.txs[branch.nextPendingIndex] : null;
+
+ return (
+
+
+
+ Branch {branch.branchIndex + 1}
+ {branch.sourceAmountSat !== null && (
+
+ · {formatSats(branch.sourceAmountSat)} sats
+
+ )}
+
+
+ {confirmed} of {total} confirmed
+
+
+
+ {/* Progress bar */}
+
+
+ {allDone ? (
+
+ All transactions confirmed. Wait for the exit-delay before sweeping.
+
+ ) : (
+ <>
+
+ Next pending: {shortTxid(nextTx!.txid)}
+
+
+ {(() => {
+ const sharers = sharedNextPending.get(nextTx!.txid) ?? [];
+ const others = sharers.filter((i) => i !== branch.branchIndex);
+ if (others.length === 0) return null;
+ const labels = others
+ .map((i) => `Branch ${i + 1}`)
+ .join(", ");
+ return (
+
+ Broadcasting this also advances {labels}.
+
+ );
+ })()}
+
+ {showingConfirm && confirmation && (
+
+
Confirm broadcast
+
+ Broadcasts {shortTxid(confirmation.outcome.parentTxid)} {" "}
+ + anchor {shortTxid(confirmation.outcome.anchorTxid ?? "")} .
+
+
+ Fee: {formatSats(confirmation.outcome.feeSat)} sats · irrevocable.
+
+
+ setConfirmation(null)}
+ disabled={busy}
+ >
+ Cancel
+
+ void onConfirmBroadcast()}
+ disabled={busy}
+ >
+ {busy ? "Broadcasting…" : "Broadcast"}
+
+
+
+ )}
+
+ {!showingConfirm && (() => {
+ const broadcastDisabled = busy || !preflight?.ready;
+ const hint = disabledHint(preflight, busy);
+ return (
+
+
void onPrepareBroadcast(branch.branchIndex)}
+ disabled={broadcastDisabled}
+ >
+ {busy ? "Preparing…" : "Broadcast next"}
+
+ {hint && (
+
{hint}
+ )}
+
+ );
+ })()}
+
+ )}
+
+ );
+ })()}
+
+ {!loading && status && status.branches.length === 0 && preflight?.ready && (
+
+ The recovery package is empty — there is nothing to broadcast.
+
+ )}
+
+ {!loading && sweepLoading && sweep === null &&
+
+
Awaiting sweep
+
+ Exit delay: ~{formatExitDelay(sweep.csvDelaySeconds)}
+
+
+
+ VTXOs you've already broadcast. Each is on-chain but locked by a CSV
+ timelock; once a countdown reaches zero, the sweep form below moves
+ all unlocked funds to any Bitcoin address in one transaction.
+
+
+ {sweep.vtxos.map((v) => {
+ const remaining = v.csvMatureAt !== null ? v.csvMatureAt - sweep.now : null;
+ return (
+
+
+
+ {formatSats(v.amountSat)} sats
+
+
+ {v.mature
+ ? "Ready to sweep"
+ : remaining !== null
+ ? `In ${formatCountdown(remaining)}`
+ : "Awaiting confirmation"}
+
+
+
+ {shortTxid(v.txid)}:{v.vout}
+
+
+ );
+ })}
+
+
+
+ {formatSats(totalSat)} sats ready
+
+
+ {mature.length} output{mature.length > 1 ? "s" : ""}
+
+
+
void loadAll(false)}
+ />
+
+ )}
+
-
Block Explorer (Esplora)
-
- {presetExplorers.map((option) => (
- onChange(option.url)}
- className={`w-full flex items-center gap-3 rounded-xl px-3 py-2.5 text-left text-sm transition-colors ${
- effectiveValue === option.url ? "theme-accent-bg" : "theme-card-elevated"
- }`}
- >
-
- {option.label}
- {option.url}
-
-
- ))}
- { if (!isCustom) onChange("https://"); }}
- className={`w-full flex items-center gap-3 rounded-xl px-3 py-2.5 text-left text-sm transition-colors ${
- isCustom ? "theme-accent-bg" : "theme-card-elevated"
- }`}
- >
- Custom
-
-
- {isCustom && (
-
onChange(e.target.value)}
- placeholder="https://your-esplora-server.com/api"
- className="w-full rounded-xl theme-input px-3 py-2 text-sm outline-none focus:ring-2 focus:ring-lime-300/50 font-mono"
- />
- )}
-
onSave(urlToSave)}
- className="w-full rounded-xl theme-card-elevated py-2.5 text-xs font-medium theme-text-secondary hover:opacity-80 transition-opacity disabled:opacity-50"
- >
- {saving ? "Saving..." : "Save"}
-
-
Esplora server for onchain sync. Takes effect on next app restart.
-
(null);
-
- const selected = SUPPORTED_FIAT_CURRENCIES.find((c) => c.code === currency);
-
- useEffect(() => {
- if (!open) return;
- const close = () => {
- setOpen(false);
- setQuery("");
- };
- const handlePointerDown = (e: MouseEvent | TouchEvent) => {
- const target = e.target as Node | null;
- if (rootRef.current && target && !rootRef.current.contains(target)) {
- close();
- }
- };
- const handleKeyDown = (e: KeyboardEvent) => {
- if (e.key === "Escape") close();
- };
- document.addEventListener("touchstart", handlePointerDown);
- document.addEventListener("keydown", handleKeyDown);
- return () => {
- document.removeEventListener("touchstart", handlePointerDown);
- document.removeEventListener("keydown", handleKeyDown);
- };
- }, [open]);
-
- const filtered = useMemo(() => {
- const q = query.trim().toLowerCase();
- const byName = (a: FiatCurrency, b: FiatCurrency) => a.name.localeCompare(b.name);
- const selectedEntry = SUPPORTED_FIAT_CURRENCIES.find((c) => c.code === currency);
-
- if (q) {
- // Flat alphabetical while searching — grouping just adds noise.
- // Selected still floats to the top if it matches the query.
- const matches = SUPPORTED_FIAT_CURRENCIES.filter(
- (c) =>
- c.code !== currency &&
- (c.code.toLowerCase().includes(q) || c.name.toLowerCase().includes(q)),
- ).sort(byName);
- const selectedMatches =
- selectedEntry &&
- (selectedEntry.code.toLowerCase().includes(q) ||
- selectedEntry.name.toLowerCase().includes(q));
- return selectedMatches ? [selectedEntry, ...matches] : matches;
- }
-
- const african: FiatCurrency[] = [];
- const rest: FiatCurrency[] = [];
- for (const c of SUPPORTED_FIAT_CURRENCIES) {
- if (c.code === currency) continue;
- (AFRICAN_CURRENCY_CODES.has(c.code) ? african : rest).push(c);
- }
- const grouped = [...african.sort(byName), ...rest.sort(byName)];
- return selectedEntry ? [selectedEntry, ...grouped] : grouped;
- }, [query, currency]);
-
- return (
-
-
setOpen((v) => !v)}
- className="w-full flex items-center justify-between rounded-xl theme-card-elevated px-3 py-2.5 text-left text-sm"
- >
-
- {selected?.flag ?? "🌐"}
- {selected?.code ?? currency}
- — {selected?.name ?? "Unknown"}
-
-
-
-
- {open && (
-
-
setQuery(e.target.value)}
- placeholder="Search currency"
- autoCapitalize="none"
- autoCorrect="off"
- className="w-full rounded-lg theme-input px-3 py-2 text-sm outline-none focus:ring-2 focus:ring-lime-300/50"
- />
-
- {filtered.length === 0 ? (
-
No matches
- ) : (
- filtered.map((c) => {
- const active = c.code === currency;
- return (
-
{
- onChange(c.code);
- setOpen(false);
- setQuery("");
- }}
- className={`w-full flex items-center gap-3 rounded-lg px-3 py-2 text-left text-sm transition-colors ${
- active ? "theme-accent-bg" : "hover:opacity-80"
- }`}
- >
- {c.flag}
- {c.code}
- {c.name}
-
- );
- })
- )}
-
-
- )}
-
("");
- if (price && price !== lastPrice) {
- setLastPrice(price);
- }
-
- // Derive the visible state. When a background refresh fails we keep the
- // last rate visible but mark it stale. When an initial fetch fails we
- // have no rate to show — treat as a hard failure with a retry affordance.
- const tickerState: "off" | "live" | "loading" | "stale" | "failed" = !enabled
- ? "off"
- : status === "ready" && rate
- ? "live"
- : status === "error" && rate
- ? "stale"
- : status === "error"
- ? "failed"
- : "loading";
-
- const badge =
- tickerState === "live"
- ? { label: "Live", color: "var(--color-accent)", text: "theme-accent", pulse: false, ping: true }
- : tickerState === "loading"
- ? { label: "Syncing", color: "var(--color-accent)", text: "theme-accent", pulse: true, ping: false }
- : tickerState === "stale"
- ? { label: "Stale", color: "var(--color-warning)", text: "theme-warning", pulse: false, ping: false }
- : tickerState === "failed"
- ? { label: "Failed", color: "var(--color-danger)", text: "theme-danger", pulse: false, ping: false }
- : { label: "Off", color: "var(--color-text-faint)", text: "theme-text-muted", pulse: false, ping: false };
-
- return (
-
- {/* Header: status badge + segmented ON / OFF */}
-
-
-
- {badge.ping && (
-
-
- {badge.label}
-
-
-
- onToggle(true)}
- aria-pressed={enabled}
- className={`rounded-lg px-3 py-1 text-[11px] font-mono font-semibold tracking-wider transition-colors ${
- enabled ? "theme-accent-bg" : "theme-text-muted"
- }`}
- >
- ON
-
- onToggle(false)}
- aria-pressed={!enabled}
- className={`rounded-lg px-3 py-1 text-[11px] font-mono font-semibold tracking-wider transition-colors ${
- !enabled ? "theme-accent-bg" : "theme-text-muted"
- }`}
- >
- OFF
-
-
-
-
- {/* Quote readout */}
-
- {tickerState === "live" && price && rate ? (
-
-
-
- {price}
-
- / BTC
-
-
- quoted {formatQuoteTime(rate.timestamp)} · yadio.io
-
-
- ) : tickerState === "stale" && price && rate ? (
-
-
-
- {price}
-
- / BTC
-
-
-
- last quote {formatQuoteTime(rate.timestamp)} · refresh failed
-
-
- retry
-
-
-
- ) : tickerState === "failed" ? (
-
-
-
- Couldn't reach yadio.io
-
-
-
-
-
-
- RETRY
-
-
- check your connection
-
-
-
- ) : tickerState === "loading" ? (
-
-
-
- {/* Invisible sizer — matches the footprint of the real price */}
-
- {lastPrice || "$00,000.00"}
-
-
- / BTC
-
-
- updating · yadio.io
-
-
- ) : (
-
-
-
- — — —
-
- / BTC
-
-
- fiat equivalents hidden beneath sat amounts
-
-
- )}
-
-
- {enabled && (
- <>
-
-
-
- )}
-
(promise: Promise, ms: number, message: string): Promise {
+ return new Promise((resolve, reject) => {
+ const timer = window.setTimeout(() => reject(new Error(message)), ms);
+ promise.then(
+ (value) => {
+ window.clearTimeout(timer);
+ resolve(value);
+ },
+ (error) => {
+ window.clearTimeout(timer);
+ reject(error);
+ },
+ );
+ });
}
export function SettingsRoute() {
const navigate = useNavigate();
const { theme, setTheme } = useTheme();
+ const { connectionState } = useWallet();
const [settings, setSettings] = useState(null);
- const [seedStep, setSeedStep] = useState<"hidden" | "confirm" | "revealed">("hidden");
- const [mnemonic, setMnemonic] = useState(null);
- const [loadingSeed, setLoadingSeed] = useState(false);
- const [confirmInput, setConfirmInput] = useState("");
const [showDeleteConfirm, setShowDeleteConfirm] = useState(false);
const [deleting, setDeleting] = useState(false);
- const [esploraInput, setEsploraInput] = useState("");
- const [savingEsplora, setSavingEsplora] = useState(false);
const { pinEnabled, refreshPinStatus } = usePinLock();
const {
enabled: fiatEnabled,
@@ -511,16 +69,13 @@ export function SettingsRoute() {
const [pinFlow, setPinFlow] = useState<"none" | "setup" | "disable">("none");
const [maxAttempts, setMaxAttempts] = useState(10);
const [appVersion, setAppVersion] = useState(null);
- const [nsecStep, setNsecStep] = useState<"hidden" | "confirm" | "revealed">("hidden");
- const [nsec, setNsec] = useState(null);
- const [loadingNsec, setLoadingNsec] = useState(false);
- const [confirmNsecInput, setConfirmNsecInput] = useState("");
+ const [recoveryCache, setRecoveryCache] = useState(null);
+ const [refreshingRecoveryCache, setRefreshingRecoveryCache] = useState(false);
const fetchSettings = useCallback(async () => {
try {
const data = await invoke("settings");
setSettings(data);
- setEsploraInput(data.esplora_url ?? "");
} catch (e) {
console.warn("Failed to load settings:", e);
toast.warning("Could not load settings");
@@ -532,6 +87,19 @@ export function SettingsRoute() {
void fetchSettings();
}, [fetchSettings]);
+ const fetchRecoveryCacheStatus = useCallback(async () => {
+ try {
+ const status = await invoke("get_unilateral_exit_cache_status");
+ setRecoveryCache(status);
+ } catch (e) {
+ console.warn("Failed to load recovery cache status:", e);
+ }
+ }, []);
+
+ useEffect(() => {
+ void fetchRecoveryCacheStatus();
+ }, [fetchRecoveryCacheStatus]);
+
useEffect(() => {
invoke<{ max_attempts: number }>("get_pin_status")
.then((s) => setMaxAttempts(s.max_attempts))
@@ -544,50 +112,6 @@ export function SettingsRoute() {
.catch(() => {});
}, []);
- const handleRevealSeed = async () => {
- if (mnemonic) {
- setSeedStep("revealed");
- return;
- }
- setLoadingSeed(true);
- try {
- const words = await invoke("get_mnemonic");
- setMnemonic(words);
- setSeedStep("revealed");
- } catch (e) {
- toast.error(typeof e === "string" ? e : "Failed to retrieve seed phrase");
- } finally {
- setLoadingSeed(false);
- }
- };
-
- const handleRevealNsec = async () => {
- if (nsec) {
- setNsecStep("revealed");
- return;
- }
- setLoadingNsec(true);
- try {
- const value = await invoke("nostr_reveal_nsec");
- setNsec(value);
- setNsecStep("revealed");
- } catch (e) {
- toast.error(typeof e === "string" ? e : "Failed to retrieve private key");
- } finally {
- setLoadingNsec(false);
- }
- };
-
- const handleCopyNsec = async () => {
- if (!nsec) return;
- try {
- await navigator.clipboard.writeText(nsec);
- toast.success("nsec copied — paste into a trusted password manager only");
- } catch {
- toast.error("Failed to copy");
- }
- };
-
const handleThemeToggle = (newTheme: "dark" | "light") => {
setTheme(newTheme);
};
@@ -605,6 +129,33 @@ export function SettingsRoute() {
}
};
+ const handleRefreshRecoveryCache = async () => {
+ setRefreshingRecoveryCache(true);
+ try {
+ const status = await withTimeout(
+ invoke("refresh_unilateral_exit_cache"),
+ 330_000,
+ "Recovery package refresh timed out. Try again when the ASP is responding.",
+ );
+ setRecoveryCache(status);
+ if (status.exists && status.failedCount > 0) {
+ toast.warning(`Recovery package partially refreshed; skipped ${status.failedCount} VTXO(s)`);
+ } else if (status.exists) {
+ toast.success("Recovery package refreshed");
+ } else {
+ toast.warning(
+ status.lastError
+ ? "ASP timed out while preparing recovery data"
+ : "No recovery data was cached",
+ );
+ }
+ } catch (e) {
+ toast.error(typeof e === "string" ? e : "Failed to refresh recovery package");
+ } finally {
+ setRefreshingRecoveryCache(false);
+ }
+ };
+
// PIN setup/disable flows render full-screen
if (pinFlow === "setup") {
return (
@@ -746,75 +297,7 @@ export function SettingsRoute() {
{/* Wallet */}
Wallet
- {seedStep === "hidden" && (
-
-
setSeedStep("confirm")}
- className="w-full flex items-center justify-between px-4 py-3.5 text-sm text-left theme-card transition-colors"
- >
- Back Up Seed Phrase
-
-
-
-
- )}
- {seedStep === "confirm" && (
-
-
Reveal seed phrase?
-
Your seed phrase gives full access to your funds. Before continuing:
-
- Make sure no one can see your screen
- Do not screenshot or copy to clipboard
- Write the words down on paper only
-
-
- Type reveal my seed to continue
-
-
setConfirmInput(e.target.value)}
- placeholder="reveal my seed"
- className="w-full rounded-xl theme-input px-4 py-2.5 text-sm outline-none focus:ring-2 focus:ring-yellow-500/50 mb-4 font-mono"
- />
-
- { setSeedStep("hidden"); setConfirmInput(""); }}
- className="flex-1 rounded-xl theme-card-elevated py-2.5 text-sm font-medium theme-text-secondary transition-colors"
- >
- Cancel
-
- void handleRevealSeed()}
- disabled={loadingSeed || confirmInput.trim().toLowerCase() !== "reveal my seed"}
- className="flex-1 rounded-xl bg-yellow-500 py-2.5 text-sm font-bold text-gray-900 transition-colors hover:bg-yellow-400 disabled:opacity-30"
- >
- {loadingSeed ? "Loading..." : "Reveal"}
-
-
-
- )}
- {seedStep === "revealed" && mnemonic && (
-
-
Write these words down on paper — do not copy digitally
-
{mnemonic}
-
Never screenshot, copy to clipboard, or store digitally. Clipboard data can be read by other apps.
-
{
- setSeedStep("hidden");
- setMnemonic(null);
- setConfirmInput("");
- }}
- className="mt-3 rounded-xl theme-card-elevated px-4 py-2 text-xs font-medium theme-text-muted hover:opacity-80 transition-opacity"
- >
- Hide seed phrase
-
-
- )}
+
{/* Network */}
@@ -830,26 +313,79 @@ export function SettingsRoute() {
{settings?.network ?? "—"}
- Connected
+
+ {connectionState === "connected" ? "Connected" : "Offline"}
+