Accounts Payable pipeline

import { VetoMeow } from "@veto/meow";

const veto = new VetoMeow({ baseUrl: "http://localhost:3005" });

// 1. Upload invoice bytes; the parser extracts vendor + total.
const invoice = await veto.invoices.ingest({
  content_type: "application/pdf",
  bytes_base64: pdfBytes.toString("base64"),
  uploaded_by: "agent_finance_bot"
});

// 2. Upsert the counterparty. First-time payees start quarantined.
const payee = await veto.counterparties.upsert({
  type: "bank_us",
  display_name: invoice.parsed.vendor_name,
  routing_number: "021000021",
  account_last4: "1234",
  account_holder_name: invoice.parsed.vendor_name,
  operator_id: "agent_finance_bot"
});

// 3. Mint the capsule. If the beneficiary is still unverified,
//    the gateway responds 409 with an approval_id.
let mint;
try {
  mint = await veto.capsules.mint({
    entity_id: "ent_acme_llc",
    agent_id: "agent_finance_bot",
    tool: "meow.pay",
    rail_allowlist: ["ach"],
    counterparty_hash: payee.beneficiary_hash,
    amount_ceiling: { currency: "USD", amount: invoice.parsed.total_usd },
    invoice_hash: invoice.content_hash,
    workflow_id: newWorkflowId(),
    ttl_seconds: 900
  });
} catch (e) {
  if (e.code === "approval_required") {
    // Human clicks approve in the dashboard.
    // On approval, retry the mint with approval_ref: e.approval_id.
    throw e;
  }
  throw e;
}

// 4. Consume → forwards to Meow.
const result = await veto.consume({
  jws: mint.jws,
  tool: "meow.pay",
  rail: "ach",
  counterparty_hash: payee.beneficiary_hash,
  amount: { currency: "USD", amount: invoice.parsed.total_usd },
  memo: `invoice ${invoice.parsed.invoice_number}`
});

console.log("paid:", result.upstream.meow_payment_id);