Email Infrastructure for Fintech AI Agents

from multimail import MultiMailClient

client = MultiMailClient(api_key="$MULTIMAIL_API_KEY")

"cm"># Transaction confirmation — sent immediately under gated_send
client.send_email(
    from_address="[email protected]",
    to=["[email protected]"],
    subject="Payment confirmed: $247.00 to Acme Corp",
    body=(
        "Your payment of $247.00 to Acme Corp was processed successfully.\n"
        "Reference: TXN-20260419-8821\n"
        "If you did not authorize this transaction, reply to this email or "
        "call 1-800-555-0100 immediately."
    ),
    tags=["transactional", "payment-confirmation"],
)

"cm"># Fraud alert — routed to approval queue under gated_send
"cm"># Compliance officer reviews via decide_email before delivery
client.send_email(
    from_address="[email protected]",
    to=["[email protected]"],
    subject="Unusual activity detected on your account",
    body=(
        "We detected a login attempt from an unrecognized device in Minsk, BY.\n"
        "If this was you, no action is needed.\n"
        "If not, secure your account at https://app.payments.multimail.dev/secure"
    ),
    tags=["fraud-alert", "high-risk"],
)

from multimail import MultiMailClient

client = MultiMailClient(api_key="$MULTIMAIL_API_KEY")

def handle_kyc_decision(customer_email: str, status: str, reason: str | None = None):
    if status == "approved":
        subject = "Identity verification complete — your account is active"
        body = (
            "Your identity has been verified. You can now access all account features.\n"
            "Log in at https://app.yourfintech.com"
        )
    elif status == "pending_documents":
        subject = "Additional documents needed to complete verification"
        body = (
            f"We need the following to complete your verification:\n{reason}\n\n"
            "Upload documents at https://app.yourfintech.com/kyc/upload"
        )
    else:
        "cm"># Adverse action — route through gated_all mailbox for compliance approval
        subject = "Account application update"
        body = (
            "We were unable to verify your identity at this time.\n"
            "You have the right to request the reasons for this decision.\n"
            "Contact us at [email protected]"
        )

    result = client.send_email(
        from_address="[email protected]",
        to=[customer_email],
        subject=subject,
        body=body,
        tags=["kyc", f"kyc-{status}"],
    )
    return result["message_id"]

"cm"># Poll inbound KYC mailbox for document submissions
inbox = client.check_inbox(
    mailbox="[email protected]",
    filters={"unread": True, "tags": ["kyc-submission"]},
)

for email in inbox["emails"]:
    msg = client.read_email(message_id=email["message_id"])
    "cm"># Tag as processed to avoid duplicate handling
    client.tag_email(message_id=email["message_id"], tags=["kyc-processed"])

from multimail import MultiMailClient

client = MultiMailClient(api_key="$MULTIMAIL_API_KEY")

def process_fraud_alert_queue(reviewer_id: str):
    "cm"># Fetch all fraud alerts pending human approval
    pending = client.list_pending(
        mailbox="[email protected]",
        tags=["fraud-alert"],
    )

    for item in pending["messages"]:
        msg_id = item["message_id"]
        msg = client.read_email(message_id=msg_id)

        risk_score = score_fraud_alert(msg["body"])  "cm"># your risk model

        if risk_score >= 0.8:
            "cm"># High confidence — approve and send immediately
            client.decide_email(
                message_id=msg_id,
                decision="approve",
                reviewer=reviewer_id,
                notes="High-confidence fraud signal. Approved for immediate delivery.",
            )
        elif risk_score < 0.3:
            "cm"># Low signal — cancel, do not send
            client.cancel_message(message_id=msg_id)
        else:
            "cm"># Escalate for senior review — leave in queue with new tag
            client.tag_email(
                message_id=msg_id,
                tags=["escalated", "senior-review-required"],
            )

def score_fraud_alert(body: str) -> float:
    "cm"># Integrate your risk model here
    return 0.85

from multimail import MultiMailClient

client = MultiMailClient(api_key="$MULTIMAIL_API_KEY")

def draft_support_reply(thread_id: str, agent_draft: str) -> dict:
    "cm"># Retrieve the full thread for context
    thread = client.get_thread(thread_id=thread_id)
    last_message = thread["messages"][-1]

    "cm"># Agent composes a reply — held in queue under gated_all
    "cm"># No message reaches the customer until a human approves via decide_email
    result = client.reply_email(
        message_id=last_message["message_id"],
        body=agent_draft,
        from_address="[email protected]",
        tags=["support", "agent-drafted", "pending-review"],
    )

    return {
        "queued_message_id": result["message_id"],
        "status": result["status"],  "cm"># "pending_approval" under gated_all
        "thread_id": thread_id,
    }

"cm"># Read unresolved dispute tickets and queue agent-drafted replies
inbox = client.check_inbox(
    mailbox="[email protected]",
    filters={"unread": True, "tags": ["dispute"]},
)

for email in inbox["emails"]:
    draft = generate_agent_reply(email)  "cm"># your LLM call here
    queued = draft_support_reply(
        thread_id=email["thread_id"],
        agent_draft=draft,
    )
    print(f"Queued reply {queued[&"cm">#039;queued_message_id']} for compliance approval")