Email Infrastructure for Coworking Operations

import httpx
from datetime import datetime

def send_booking_confirmation(
    member_email: str,
    member_name: str,
    room_name: str,
    location: str,
    start_time: datetime,
    end_time: datetime,
    booking_id: str,
    api_key: str,
) -> dict:
    payload = {
        "to": member_email,
        "from": "[email protected]",
        "subject": f"Booking confirmed: {room_name} on {start_time.strftime(&"cm">#039;%b %d, %Y')}",
        "body": (
            f"Hi {member_name},\n\n"
            f"Your booking is confirmed.\n\n"
            f"Room: {room_name}\n"
            f"Location: {location}\n"
            f"Date: {start_time.strftime(&"cm">#039;%A, %B %d, %Y')}\n"
            f"Time: {start_time.strftime(&"cm">#039;%I:%M %p')} – {end_time.strftime('%I:%M %p')}\n"
            f"Booking ID: {booking_id}\n\n"
            f"To modify or cancel, reply to this email or visit your member portal."
        ),
        "metadata": {
            "booking_id": booking_id,
            "location": location,
            "event_type": "booking_confirmation",
        },
    }
    resp = httpx.post(
        "https://api.multimail.dev/v1/send_email",
        json=payload,
        headers={"Authorization": f"Bearer {api_key}"},
        timeout=10,
    )
    resp.raise_for_status()
    return resp.json()

import httpx
from datetime import date, timedelta

API_KEY = "$MULTIMAIL_API_KEY"
BASE = "https://api.multimail.dev/v1"
HEADERS = {"Authorization": f"Bearer {API_KEY}"}

def send_renewal_reminder_if_needed(
    member_email: str,
    member_name: str,
    plan_name: str,
    renewal_date: date,
    mailbox: str = "[email protected]",
) -> str:
    "cm"># Check whether we already sent a renewal notice this cycle
    inbox_resp = httpx.post(
        f"{BASE}/check_inbox",
        json={
            "mailbox": mailbox,
            "query": f"from:{member_email} OR to:{member_email}",
            "since": (date.today() - timedelta(days=7)).isoformat(),
            "limit": 10,
        },
        headers=HEADERS,
        timeout=10,
    )
    inbox_resp.raise_for_status()
    recent = inbox_resp.json().get("messages", [])

    already_sent = any(
        "renewal" in (m.get("subject") or "").lower() for m in recent
    )
    if already_sent:
        return "skipped: renewal notice already sent this cycle"

    send_resp = httpx.post(
        f"{BASE}/send_email",
        json={
            "to": member_email,
            "from": mailbox,
            "subject": f"Your {plan_name} membership renews on {renewal_date.strftime(&"cm">#039;%B %d')}",
            "body": (
                f"Hi {member_name},\n\n"
                f"Your {plan_name} membership renews on {renewal_date.strftime(&"cm">#039;%B %d, %Y')}.\n"
                f"No action is needed if your payment method is current.\n\n"
                f"To update billing details, visit your member portal."
            ),
            "metadata": {"event_type": "renewal_reminder", "plan": plan_name},
        },
        headers=HEADERS,
        timeout=10,
    )
    send_resp.raise_for_status()
    return send_resp.json()["message_id"]

import httpx

API_KEY = "$MULTIMAIL_API_KEY"
BASE = "https://api.multimail.dev/v1"
HEADERS = {"Authorization": f"Bearer {API_KEY}"}

def queue_access_alert(
    member_email: str,
    member_name: str,
    event_type: str,  "cm"># e.g. "keycode_reset", "after_hours_override"
    location: str,
    details: str,
) -> dict:
    """Queue an access alert. Stays in pending until a staff member approves via decide_email."""
    resp = httpx.post(
        f"{BASE}/send_email",
        json={
            "to": member_email,
            "from": "[email protected]",
            "subject": f"Access update: {location}",
            "body": (
                f"Hi {member_name},\n\n"
                f"{details}\n\n"
                f"If you did not request this change, contact the front desk immediately."
            ),
            "oversight_mode": "gated_send",
            "metadata": {
                "event_type": event_type,
                "location": location,
            },
        },
        headers=HEADERS,
        timeout=10,
    )
    resp.raise_for_status()
    return resp.json()  "cm"># includes message_id for use with decide_email


def approve_pending_access_alerts(staff_mailbox: str) -> list[dict]:
    """List and approve all pending access alerts queued for this mailbox."""
    pending_resp = httpx.get(
        f"{BASE}/list_pending",
        params={"mailbox": staff_mailbox},
        headers=HEADERS,
        timeout=10,
    )
    pending_resp.raise_for_status()
    results = []
    for msg in pending_resp.json().get("pending", []):
        if msg.get("metadata", {}).get("event_type") in ("keycode_reset", "after_hours_override"):
            decision = httpx.post(
                f"{BASE}/decide_email",
                json={"message_id": msg["message_id"], "action": "approve"},
                headers=HEADERS,
                timeout=10,
            )
            decision.raise_for_status()
            results.append(decision.json())
    return results

import httpx
from typing import List

API_KEY = "$MULTIMAIL_API_KEY"
BASE = "https://api.multimail.dev/v1"
HEADERS = {"Authorization": f"Bearer {API_KEY}"}


def get_opted_out_members(mailbox: str) -> set[str]:
    """Return emails of members who have unsubscribed."""
    resp = httpx.post(
        f"{BASE}/manage_contacts",
        json={"mailbox": mailbox, "tag": "unsubscribed"},
        headers=HEADERS,
        timeout=10,
    )
    resp.raise_for_status()
    return {c["email"] for c in resp.json().get("contacts", [])}


def send_community_announcement(
    members: List[dict],
    subject: str,
    body: str,
    mailbox: str = "[email protected]",
) -> dict:
    opted_out = get_opted_out_members(mailbox)
    sent, skipped = [], []

    for member in members:
        email = member["email"]
        if email in opted_out:
            skipped.append(email)
            continue

        resp = httpx.post(
            f"{BASE}/send_email",
            json={
                "to": email,
                "from": mailbox,
                "subject": subject,
                "body": body + "\n\nTo unsubscribe from community emails, reply with UNSUBSCRIBE.",
                "metadata": {"event_type": "community_announcement"},
            },
            headers=HEADERS,
            timeout=10,
        )
        if resp.status_code == 200:
            sent.append(email)

    return {"sent": len(sent), "skipped_opted_out": len(skipped)}