Process Invoices Automatically From Your Inbox

import requests

API = "https://api.multimail.dev/v1"
HEADERS = {"Authorization": "Bearer mm_live_xxx"}

"cm"># Check AP mailbox for new invoices
inbox = requests.get(
    f"{API}/mailboxes/{AP_MAILBOX_ID}/inbox",
    headers=HEADERS,
    params={"status": "unread", "limit": 30}
).json()

for msg in inbox["emails"]:
    email = requests.get(
        f"{API}/emails/{msg[&"cm">#039;id']}", headers=HEADERS
    ).json()

    # Download PDF attachment if present
    for attachment in email.get("attachments", []):
        if attachment["content_type"] == "application/pdf":
            pdf_data = requests.get(
                f"{API}/emails/{email[&"cm">#039;id']}/attachments/{attachment['id']}",
                headers=HEADERS
            ).content

    # Extract invoice fields using your AI model
    invoice = extract_invoice_data(email["text_body"], pdf_data)
    # Returns: {vendor, invoice_number, po_number, line_items, total, due_date}
    print(f"Invoice {invoice[&"cm">#039;invoice_number']} from {invoice['vendor']}: ${invoice['total']}")

import requests

API = "https://api.multimail.dev/v1"
HEADERS = {"Authorization": "Bearer mm_live_xxx"}

def process_invoice(email: dict, invoice: dict):
    po = lookup_purchase_order(invoice["po_number"])

    if not po:
        "cm"># No matching PO — flag and notify
        requests.post(f"{API}/reply", headers=HEADERS, json={
            "in_reply_to": email["id"],
            "text_body": (
                f"Thank you for invoice {invoice[&"cm">#039;invoice_number']}. "
                f"We could not locate a matching purchase order for "
                f"PO"cm"># {invoice['po_number']}. Please verify the PO "
                f"number and resubmit or contact our AP team."
            )
        })
        tag_invoice(email["id"], "missing-po")
        return

    discrepancies = validate_line_items(invoice["line_items"], po)

    if discrepancies:
        # Send discrepancy details to vendor
        detail = "\n".join(
            f"- {d[&"cm">#039;item']}: invoiced ${d['invoiced']} vs PO ${d['expected']}"
            for d in discrepancies
        )
        requests.post(f"{API}/reply", headers=HEADERS, json={
            "in_reply_to": email["id"],
            "text_body": (
                f"Invoice {invoice[&"cm">#039;invoice_number']} has discrepancies "
                f"against PO"cm"># {invoice['po_number']}:\n\n{detail}\n\n"
                f"Please review and resubmit a corrected invoice."
            )
        })
        tag_invoice(email["id"], "discrepancy")
    else:
        # Confirmed — send receipt and queue for payment
        requests.post(f"{API}/reply", headers=HEADERS, json={
            "in_reply_to": email["id"],
            "text_body": (
                f"Invoice {invoice[&"cm">#039;invoice_number']} for ${invoice['total']} "
                f"has been validated against PO"cm"># {invoice['po_number']} and "
                f"queued for payment by {invoice[&"cm">#039;due_date']}."
            )
        })
        tag_invoice(email["id"], "confirmed")

"cm">// Invoice processing agent using MultiMail MCP tools

async function processInvoices() {
  const inbox = await mcp.check_inbox({
    mailbox_id: "ap-mailbox-id",
    status: "unread"
  });

  for (const msg of inbox.emails) {
    const email = await mcp.read_email({ email_id: msg.id });

    "cm">// Download and parse invoice attachment
    const attachment = email.attachments?.find(
      (a: any) => a.content_type === "application/pdf"
    );
    let invoiceData;
    if (attachment) {
      const pdf = await mcp.download_attachment({
        email_id: email.id,
        attachment_id: attachment.id
      });
      invoiceData = await extractInvoiceFromPDF(pdf);
    } else {
      invoiceData = await extractInvoiceFromText(email.text_body);
    }

    "cm">// Validate against PO database
    const validation = await validateAgainstPO(invoiceData);

    "cm">// Tag with processing status
    await mcp.tag_email({
      email_id: email.id,
      tags: ["invoice", `status:${validation.status}`, `vendor:${invoiceData.vendor}`]
    });

    "cm">// Send appropriate response (auto-sends under monitored mode)
    await mcp.reply_email({
      email_id: email.id,
      text_body: validation.status === "confirmed"
        ? `Invoice ${invoiceData.invoice_number} validated and queued for payment.`
        : `Invoice ${invoiceData.invoice_number} requires review: ${validation.reason}`
    });
  }
}