Schedule Emails with Agent Intelligence and Human Control

import httpx
from datetime import datetime, timezone, timedelta

"cm"># Schedule for tomorrow at 9 AM UTC
send_at = (datetime.now(timezone.utc) + timedelta(days=1)).replace(
    hour=9, minute=0, second=0, microsecond=0
)

response = httpx.post(
    "https://api.multimail.dev/v1/send_email",
    headers={"Authorization": "Bearer $MULTIMAIL_API_KEY"},
    json={
        "from": "[email protected]",
        "to": "[email protected]",
        "subject": "Scheduled follow-up for tomorrow at 9:00 AM",
        "body": "Following up on our conversation — wanted to share the report while it&"cm">#039;s fresh for your morning review.",
        "scheduled_at": send_at.isoformat(),
        "oversight_mode": "gated_send"
    }
)

data = response.json()
print(f"Queued: {data[&"cm">#039;message_id']}")
print(f"Scheduled for: {data[&"cm">#039;scheduled_at']}")
print(f"Status: {data[&"cm">#039;status']}")  # 'pending_approval' until reviewed

import httpx

client = httpx.Client(
    base_url="https://api.multimail.dev/v1",
    headers={"Authorization": "Bearer $MULTIMAIL_API_KEY"}
)

"cm"># Show all pending and scheduled messages
pending = client.get("/list_pending").json()

for msg in pending["messages"]:
    print(f"[{msg[&"cm">#039;message_id']}] To: {msg['to']}")
    print(f"  Subject: {msg[&"cm">#039;subject']}")
    print(f"  Scheduled: {msg[&"cm">#039;scheduled_at']}")
    print(f"  Status: {msg[&"cm">#039;status']}")
    print()

# Cancel a specific message if the situation changed before delivery
message_id = "msg_01HX3J9KQRST456"
cancel_resp = client.post(
    "/cancel_message",
    json={
        "message_id": message_id,
        "reason": "Deal closed before send window — no longer relevant"
    }
)
print(f"Cancelled: {cancel_resp.json()[&"cm">#039;cancelled']}")

from multimail_sdk import MultiMailClient
from datetime import datetime, timedelta
import pytz

client = MultiMailClient(api_key="$MULTIMAIL_API_KEY")

def schedule_for_recipient_morning(
    to_email: str,
    recipient_tz: str,
    subject: str,
    body: str
) -> dict:
    tz = pytz.timezone(recipient_tz)
    now_local = datetime.now(tz)

    "cm"># Target next-day 9 AM in recipient's timezone
    target = now_local.replace(hour=9, minute=0, second=0, microsecond=0)
    if target <= now_local:
        target += timedelta(days=1)

    send_at_utc = target.astimezone(pytz.utc)

    return client.send_email(
        from_address="[email protected]",
        to=to_email,
        subject=subject,
        body=body,
        scheduled_at=send_at_utc.isoformat(),
        oversight_mode="gated_send"
    )

result = schedule_for_recipient_morning(
    to_email="[email protected]",
    recipient_tz="America/Chicago",
    subject="Proposal follow-up — three questions before your review",
    body="Wanted to flag three open items in the proposal before your team reviews it Thursday."
)
print(f"Queued {result[&"cm">#039;message_id']} for {result['scheduled_at']}")

from fastapi import FastAPI, Request
import httpx

app = FastAPI()
MULTIMAIL_TOKEN = "$MULTIMAIL_API_KEY"
SAFE_DOMAINS = {"trusted-client.com", "enterprise-prospect.com"}

@app.post("/webhooks/multimail")
async def handle_approval_event(request: Request):
    event = await request.json()

    if event["type"] != "approval.required":
        return {"ok": True}

    msg = event["message"]
    print(f"Review needed: &"cm">#039;{msg['subject']}' → {msg['to']}")
    print(f"Scheduled for: {msg[&"cm">#039;scheduled_at']}")

    recipient_domain = msg["to"].split("@")[-1]
    auto_approve = recipient_domain in SAFE_DOMAINS

    httpx.post(
        "https://api.multimail.dev/v1/decide_email",
        headers={"Authorization": f"Bearer {MULTIMAIL_TOKEN}"},
        json={
            "message_id": msg["message_id"],
            "decision": "approve" if auto_approve else "reject",
            "note": "Auto-approved: matched trusted domain" if auto_approve
                    else "Routed to human reviewer — unknown domain"
        }
    )

    return {"ok": True}

import httpx
from datetime import datetime, timezone, timedelta

"cm"># Schedule a reply for 48 hours from now
follow_up_at = datetime.now(timezone.utc) + timedelta(hours=48)

response = httpx.post(
    "https://api.multimail.dev/v1/reply_email",
    headers={"Authorization": "Bearer $MULTIMAIL_API_KEY"},
    json={
        "thread_id": "thread_01HX7R2MNPQST789",
        "from": "[email protected]",
        "body": "Circling back as promised — happy to set up a 30-minute call to walk through the integration options if that&"cm">#039;s useful.",
        "scheduled_at": follow_up_at.isoformat(),
        "oversight_mode": "gated_send"
    }
)

data = response.json()
print(f"Reply queued: {data[&"cm">#039;message_id']}")
print(f"Thread: {data[&"cm">#039;thread_id']}")
print(f"Delivers at: {data[&"cm">#039;scheduled_at']}")