Payment Flow

import { parseAbiItem } from 'viem';

async function verifyPayment(txHash: string) {
  // 1. Get transaction receipt
  const receipt = await publicClient.getTransactionReceipt({
    hash: txHash
  });

  if (receipt.status !== 'success') {
    throw new Error('Transaction failed');
  }

  // 2. Parse Transfer event
  const transferEvent = parseAbiItem(
    'event Transfer(address indexed from, address indexed to, uint256 value)'
  );

  const logs = await publicClient.getLogs({
    address: USDC_ADDRESS,
    event: transferEvent,
    fromBlock: receipt.blockNumber,
    toBlock: receipt.blockNumber,
  });

  const transferLog = logs.find(
    log => log.transactionHash === txHash
  );

  if (!transferLog) {
    throw new Error('Transfer event not found');
  }

  // 3. Verify recipient and amount
  const { to, value } = transferLog.args;

  if (to.toLowerCase() !== BACKEND_WALLET.toLowerCase()) {
    throw new Error('Invalid recipient');
  }

  const minAmount = parseUnits('0.03', 6);
  if (value < minAmount) {
    throw new Error('Insufficient payment');
  }

  // 4. Check for replay
  const used = await db.query(
    'SELECT 1 FROM payment_receipts WHERE tx_hash = $1',
    [txHash]
  );

  if (used.rows.length > 0) {
    throw new Error('Transaction already used');
  }

  // 5. Mark transaction as used
  await db.query(
    'INSERT INTO payment_receipts (tx_hash, amount, wallet, created_at) VALUES ($1, $2, $3, NOW())',
    [txHash, value.toString(), receipt.from]
  );

  return { verified: true, amount: value };
}

{
  "agents": ["oracle", "yield"],
  "reasoning": "Query asks for Bitcoin price (oracle) and yield opportunities for BTC (yield agent)"
}

CREATE TABLE x402_payment_logs (
  id UUID PRIMARY KEY,
  agent_id TEXT NOT NULL,
  endpoint TEXT NOT NULL,
  tx_hash TEXT,
  amount_atomic TEXT NOT NULL,
  status INTEGER,
  receipt_ref TEXT,
  facilitator_settlement_id TEXT,
  facilitator_payment_id TEXT,
  request_payload_hash TEXT,
  response_hash TEXT,
  settle_payer TEXT,
  settle_network TEXT,
  settle_tx_hash TEXT,
  created_at TIMESTAMP DEFAULT NOW()
);

CREATE TABLE x402_procurement_receipts (
  id TEXT PRIMARY KEY,
  intent TEXT NOT NULL,
  provider_id TEXT NOT NULL,
  url TEXT NOT NULL,
  method TEXT NOT NULL,
  status INTEGER NOT NULL,
  paid_amount_atomic TEXT NOT NULL,
  response_hash TEXT NOT NULL,
  latency_ms INTEGER NOT NULL,
  success BOOLEAN NOT NULL,
  schema_ok BOOLEAN NOT NULL,
  score DECIMAL NOT NULL,
  tx_hash TEXT,
  pay_to TEXT,
  attempt INTEGER NOT NULL,
  error TEXT,
  created_at TIMESTAMP DEFAULT NOW()
);

GET /treasury/fund/:address

# Requests test USDC from Base Sepolia faucet
{
  "success": true,
  "amount": "10.00 USDC",
  "txHash": "0x..."
}

POST /treasury/send
{
  "to": "0x...",
  "amount": "5.00",
  "token": "USDC",
  "execute": true
}

{
  "success": true,
  "txHash": "0x...",
  "explorer": "https://sepolia.basescan.org/tx/0x..."
}