Email Infrastructure for Food Delivery at Operational Speed

import multimail
from multimail import Multimail

client = Multimail(api_key="$MULTIMAIL_API_KEY")

def handle_order_confirmed(event: dict):
    order = event["order"]
    "cm"># Pull current order state — never use cached data from order creation
    items_summary = ", ".join(
        f"{item[&"cm">#039;quantity']}x {item['name']}" for item in order["items"]
    )
    allergen_note = order.get("allergen_flags", [])
    body = f"""Your order "cm">#{order['id']} is confirmed.

Items: {items_summary}
Estimated delivery: {order[&"cm">#039;eta_minutes']} minutes
Delivery address: {order[&"cm">#039;delivery_address']}
"""
    if allergen_note:
        body += f"\nAllergen info on file: {&"cm">#039;, '.join(allergen_note)}"

    client.send_email(
        from_address=f"orders@{order[&"cm">#039;brand_domain']}",
        to=order["customer_email"],
        subject=f"Order "cm">#{order['id']} confirmed — arriving in {order['eta_minutes']} min",
        body=body,
        metadata={"order_id": order["id"], "event": "order_confirmed"}
    )

import multimail
from multimail import Multimail
from enum import Enum

client = Multimail(api_key="$MULTIMAIL_API_KEY")

STATUS_SUBJECTS = {
    "out_for_delivery": "Your order is on the way",
    "arriving_soon": "Your order arrives in ~5 minutes",
    "delivered": "Your order has been delivered",
}

STATUS_BODIES = {
    "out_for_delivery": lambda o: f"Order "cm">#{o['id']} has been picked up by {o['courier_name']} and is heading your way.",
    "arriving_soon": lambda o: f"Order "cm">#{o['id']} is about 5 minutes away. Head to the door.",
    "delivered": lambda o: f"Order "cm">#{o['id']} was delivered at {o['delivered_at']}. Enjoy your meal.",
}

def handle_delivery_status(event: dict):
    order = event["order"]
    status = event["status"]
    if status not in STATUS_SUBJECTS:
        return  # Ignore internal statuses not surfaced to customers

    client.send_email(
        from_address=f"updates@{order[&"cm">#039;brand_domain']}",
        to=order["customer_email"],
        subject=STATUS_SUBJECTS[status],
        body=STATUS_BODIES[status](order),
        metadata={"order_id": order["id"], "delivery_status": status}
    )

import multimail
from multimail import Multimail
import stripe

client = Multimail(api_key="$MULTIMAIL_API_KEY")
stripe.api_key = "sk_live_your_stripe_key"

def send_refund_confirmation(order_id: str, customer_email: str, refund_id: str):
    "cm"># Verify the refund is actually succeeded before sending
    refund = stripe.Refund.retrieve(refund_id)
    if refund.status != "succeeded":
        raise ValueError(
            f"Refund {refund_id} status is &"cm">#039;{refund.status}', not 'succeeded'. "
            "Deferring email until refund clears."
        )

    amount = refund.amount / 100  # cents to dollars
    currency = refund.currency.upper()

    # gated_send: human reviews before customer receives this
    client.send_email(
        from_address="[email protected]",
        to=customer_email,
        subject=f"Refund of {currency} {amount:.2f} processed for order "cm">#{order_id}",
        body=(
            f"Your refund of {currency} {amount:.2f} for order "cm">#{order_id} has been processed.\n\n"
            f"Refund ID: {refund_id}\n"
            "Funds typically appear within 3–5 business days depending on your bank."
        ),
        oversight_mode="gated_send",
        metadata={"order_id": order_id, "refund_id": refund_id}
    )

import multimail
from multimail import Multimail

client = Multimail(api_key="$MULTIMAIL_API_KEY")

def run_reengagement_campaign(recipients: list[dict], brand_slug: str):
    sent = 0
    skipped = 0

    for recipient in recipients:
        "cm"># Check inbox for prior unsubscribe or opt-out signal
        inbox = client.check_inbox(
            mailbox=f"unsubscribes@{brand_slug}.multimail.dev",
            query=recipient["email"],
            limit=1
        )
        if inbox.get("total", 0) > 0:
            skipped += 1
            continue  "cm"># Respect prior opt-out

        client.send_email(
            from_address=f"offers@{brand_slug}.multimail.dev",
            to=recipient["email"],
            subject="We miss you — here&"cm">#039;s 20% off your next order",
            body=(
                f"Hi {recipient[&"cm">#039;first_name']},\n\n"
                "It&"cm">#039;s been a while. Use code WELCOME20 for 20% off your next order.\n\n"
                "To stop receiving emails, reply with UNSUBSCRIBE."
            ),
            headers={
                "List-Unsubscribe": f"<mailto:unsubscribes@{brand_slug}.multimail.dev>",
                "List-Unsubscribe-Post": "List-Unsubscribe=One-Click"
            },
            metadata={"campaign": "reengagement_20pct", "recipient_id": recipient["id"]}
        )
        sent += 1

    return {"sent": sent, "skipped_suppressed": skipped}

import multimail
from multimail import Multimail

client = Multimail(api_key="$MULTIMAIL_API_KEY")

COMPLAINT_KEYWORDS = ["refund", "wrong order", "missing", "late", "cold", "cancel", "allerg"]

def triage_support_inbox(mailbox: str):
    inbox = client.check_inbox(mailbox=mailbox, limit=50, filter_tag="unread")

    for message in inbox.get("messages", []):
        body_lower = message["snippet"].lower()
        is_complaint = any(kw in body_lower for kw in COMPLAINT_KEYWORDS)

        if is_complaint:
            "cm"># Tag for ops team visibility
            client.tag_email(
                message_id=message["id"],
                tags=["complaint", "needs-human-review"]
            )
            "cm"># Pull full thread for context
            thread = client.get_thread(thread_id=message["thread_id"])

            "cm"># Draft a holding reply — gated_all requires human approval before send
            client.reply_email(
                message_id=message["id"],
                body=(
                    "Thank you for reaching out. A member of our support team "
                    "will review your order and follow up within 2 hours."
                ),
                oversight_mode="gated_all",
                metadata={"thread_id": message["thread_id"], "triage": "complaint"}
            )