diff options
| author | Adam Soltys <[email protected]> | 2026-09-13 20:44:48 -0700 |
|---|---|---|
| committer | Adam Soltys <[email protected]> | 2026-09-13 20:44:48 -0700 |
| commit | d8a361bdcfaa8cc5b39d9675e74b0e1d2e42be2c (patch) | |
| tree | 9709aa57f0e9138a23fef25ae3cb528e4c30068f /lib/payments.ts | |
| parent | 287fdb2b14b48d769e43a223c5c33049ff470880 (diff) | |
| download | coinos-server-d8a361bdcfaa8cc5b39d9675e74b0e1d2e42be2c.tar.gz coinos-server-d8a361bdcfaa8cc5b39d9675e74b0e1d2e42be2c.zip | |
security: drop the admin endpoint surface and land pending hardening
Removes the admin-gated endpoints and the account flags they set, plus a
batch of hardening that had accumulated uncommitted in the tree. These were
deployed and verified together, so they land as one change.
admin surface:
- drop POST /hidepay, POST /unlimit and GET /users, their handlers, and
the now-unused admin preValidation export
- `unlimited` was only ever written, never read; `hidepay` only appeared
in output projections. Both flags go, along with their whitelist,
public-fields and type entries.
request log:
- redactBody now recurses. It only masked top-level keys, so a body that
nests credentials one level down wrote them to the log in plaintext,
and pin fields were not on the list at all.
payments:
- sendOnchain/build gate `aid` through requireAccount, so a caller can
only spend from an account it owns
- sendOnchain signs only a tx we composed, matched against a short-lived
per-account build receipt
- raise xpay retry_for to 60s; route-finding preferred a drained zero-fee
hop and burned the whole budget on it. check()'s reversal window keeps
its 2x margin.
ecash / invoices / webhooks:
- resolve a token's mint through the IP-pinning fetcher instead of plain
fetch, closing an unauthenticated SSRF path into the internal network
- reject non-positive amounts before the balance write
- /sign requires the caller to own the address, rather than signing under
any address the hot wallet controls
- webhook delivery no longer disables TLS verification; the body carries
the merchant's shared secret
registration:
- refuse a username the v3 registrar holds unless the caller's own nostr
key is the holder (lib/names.ts)
liquid:
- honour the deposit kill switch at invoice generation and at credit
elements image:
- pin 23.3.4 and verify the release tarball checksum
Co-Authored-By: Claude Opus 5 (1M context) <[email protected]>
Claude-Session: https://claude.ai/code/session_0112TGi9GGNWqji1XQ5jZRzc
Diffstat (limited to 'lib/payments.ts')
| -rw-r--r-- | lib/payments.ts | 62 |
1 files changed, 55 insertions, 7 deletions
diff --git a/lib/payments.ts b/lib/payments.ts index b26b443f..bd706b71 100644 --- a/lib/payments.ts +++ b/lib/payments.ts @@ -1,6 +1,7 @@ import config from "$config"; import { existsSync } from "fs"; import api from "$lib/api"; +import { requireAccount } from "$lib/auth"; import { archive, db, g, ga, gf, s, sa } from "$lib/db"; import { assertWithinSpendLimit } from "$lib/spend-budget"; @@ -325,6 +326,13 @@ export const credit = async ({ }) => { amount = Number.parseInt(amount) || 0; + // Kill switch (see routes/payments.ts confirm): no Liquid credits at all + // while `liquid:deposits:disabled` is set. + if (type === PaymentType.liquid && (await g("liquid:deposits:disabled"))) { + warn("liquid credit blocked (disabled)", hash, amount, ref); + return; + } + let inv = await getInvoice(hash); if (!inv && type === PaymentType.bolt12) { const { invoices } = await ln.listinvoices({ invstring: hash }); @@ -626,7 +634,8 @@ export const decode = async (hex) => { const inflight = {}; export const sendOnchain = async (params) => { let { aid, hex, rate, user, signed } = params; - if (!aid) aid = user.id; + aid = await requireAccount({ aid, user }); + const supplied = !!hex; if (!hex) ({ hex } = await build(params)); const { tx, type } = await decode(hex); @@ -636,6 +645,25 @@ export const sendOnchain = async (params) => { let { txid } = tx; let locked = false; + // Only sign a transaction WE composed for this account. build() leaves a + // short-lived receipt keyed by txid; caller-supplied hex must match one. + // Otherwise the hot wallet signs whatever raw tx is posted to /bitcoin/send + // and the only thing between an arbitrary tx and the chain is the debit math + // below (plus the weSpent credit-side guard in /confirm) — this is the outer + // layer, so an unrecognized tx never reaches signRawTransactionWithWallet + // and never locks our UTXOs on the way to failing. + // + // Receipts survive client-side signing: build() returns an unsigned segwit + // tx and witness data doesn't change the txid, so the self-custody path + // (which posts back hex it finalized itself) matches the same receipt. They + // are not single-use — a replay of the identical tx is already stopped by + // inflight/lockUnspent/testMempoolAccept, and burning the receipt would + // break a legitimate retry after a transient failure. + if (supplied) { + const builder = await db.get(`build:${txid}`); + if (builder !== aid) fail("unrecognized tx"); + } + try { if (inflight[txid]) fail("payment in flight"); inflight[txid] = true; @@ -986,7 +1014,20 @@ export const sendLightning = async ({ // bolt11: pr.replace(/\s/g, "").toLowerCase(), amount_msat: amount_msat ? undefined : amount * 1000, maxfee: fee * 1000, - retry_for: 30, + // 30s wasn't enough to get past a drained zero-fee hop. Route-finding + // prefers free channels, so xpay would spend the whole budget retrying + // one 0-base/0-ppm channel that is permanently empty in our direction + // and time out ("64 attempts, temporary_channel_failure for the same + // scid") without ever trying the paths that work — Strike/Zap payments + // failed this way for every user. xpay is in ln.ts's NO_TIMEOUT set and + // nothing in front of it (fastify, Caddy, the UI fetch) imposes a + // deadline, so the longer budget runs to completion. + // + // COUPLED TO check(): that reversal sweep must keep skipping payments + // for at least twice this window, or it reverses a payment xpay is + // still driving and we refund one that settles (the LEAKED DEBIT + // losses). Change both together. + retry_for: 60, layers: ["prefer-kappa"], }); @@ -1164,7 +1205,7 @@ export const build = async ({ user, }) => { const type = await getAddressType(address); - if (!aid) aid = user.id; + aid = await requireAccount({ aid, user }); const node = aid === user.id ? rpc(config[type]) : rpc({ ...config[type], wallet: aid }); @@ -1241,7 +1282,12 @@ export const build = async ({ } const inputs = []; - const { vin } = await node.decodeRawTransaction(tx.hex); + const { vin, txid: built } = await node.decodeRawTransaction(tx.hex); + + // Receipt for sendOnchain(): this account composed this exact tx. Bound to + // aid so one account can't replay another's build, and short-lived so a hex + // can't be banked for later. + await db.set(`build:${built}`, aid, { EX: 3600 }); for (const { txid, vout } of vin) { const rawTx = await node.getRawTransaction(txid); @@ -1318,13 +1364,15 @@ export const check = async () => { } const p = await getPayment(pr); // Skip payments sendLightning may still be actively driving. xpay retries - // for 30s (retry_for: 30), during which listpays can momentarily show all + // for 60s (retry_for: 60), during which listpays can momentarily show all // attempts "failed" before the winning part lands. The old 10s threshold // let check() reverse/refund such a payment mid-flight; it then completed, // and sendLightning's finalize threw on the deleted record — refunding a // payment that actually settled (the LEAKED DEBIT losses). Wait well past // the retry window so sendLightning has finished finalize()/reverse() and - // removed it from `pending` before check() ever touches it. + // removed it from `pending` before check() ever touches it. This is 2x + // retry_for, the same margin the 60s threshold gave the old 30s window — + // raise it with retry_for if that ever changes again. // No record anywhere (main db or archive) means there's nothing left to // reconcile — the debit was already reversed or the entry is a stale // stray. Drop it: sendLightning now refuses to re-pay an invoice while @@ -1334,7 +1382,7 @@ export const check = async () => { await db.sRem("pending", pr); continue; } - if (Date.now() - p.created < 60000) continue; + if (Date.now() - p.created < 120000) continue; const { pays } = await ln.listpays(pr); const failed = !pays.length || pays.every((p) => p.status === "failed"); |
