稳定币基础设施

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40import { chain, ledger, alerts } from './infra';/** * Runs every 15 minutes. Compares what the chain says happened against what our * ledger says happened, in both directions — because the two failure modes are * different problems and only one of them is ours. */export async function reconcile(window: TimeRange) {  const onChain = await chain.transfers(window);     // source of truth for movement  const booked = await ledger.entries(window);       // source of truth for intent  const byHash = new Map(booked.map((e) => [e.txHash, e]));  const breaks: Break[] = [];  for (const transfer of onChain) {    const entry = byHash.get(transfer.hash);    // Money moved that we never booked. This is the serious one: either an    // unauthorised transfer, or a crash between broadcasting and recording.    if (!entry) {      breaks.push({ kind: 'unbooked', hash: transfer.hash, amount: transfer.amount });      continue;    }    // Booked, but for a different amount. Almost always a decimals bug —    // which is why amounts are integers of the smallest unit everywhere.    if (entry.amountMinor !== transfer.amountMinor) {      breaks.push({ kind: 'mismatch', hash: transfer.hash, expected: entry.amountMinor });    }    byHash.delete(transfer.hash);  }  // Whatever is left was booked but never landed: stuck, dropped, or reorged out.  for (const orphan of byHash.values()) {    if (orphan.age > MINUTES_30) breaks.push({ kind: 'unsettled', id: orphan.id });  }  if (breaks.length) await alerts.page('treasury', breaks);  return breaks;}