Email Infrastructure Built for Web3's Security Requirements

import multimail

client = multimail.Client(
    api_key="mm_live_...",
    oversight_mode="gated_send"
)

"cm"># Called by agent after detecting confirmed on-chain transfer
def send_transfer_confirmation(to_address: str, user_email: str, amount: str, token: str, tx_hash: str):
    result = client.send_email(
        mailbox="[email protected]",
        to=user_email,
        subject=f"{token} Transfer Confirmed",
        body=(
            f"Your transfer of {amount} {token} has been confirmed on-chain.\n\n"
            f"Transaction: {tx_hash}\n"
            f"To address: {to_address}\n\n"
            "If you did not initiate this transfer, contact support immediately."
        ),
        tags=["transaction", "confirmation", token.lower()],
        metadata={
            "tx_hash": tx_hash,
            "token": token,
            "amount": amount
        }
    )
    "cm"># result.status == "pending" — waits for human approval
    return result.message_id

"cm"># Compliance reviewer approves pending messages
def approve_pending():
    pending = client.list_pending(limit=50)
    for msg in pending.messages:
        "cm"># Review msg.subject, msg.body, msg.metadata before approving
        client.decide_email(message_id=msg.id, decision="approve")

import multimail
import requests

client = multimail.Client(
    api_key="mm_live_...",
    oversight_mode="gated_all"
)

def send_account_restriction_notice(user_email: str, restriction_type: str, case_id: str):
    """
    Sends OFAC-adjacent account restriction notice.
    gated_all ensures compliance team reviews before delivery.
    All sends are logged with case_id for audit trail.
    """
    result = client.send_email(
        mailbox="[email protected]",
        to=user_email,
        subject="Important Notice Regarding Your Account",
        body=(
            "We are writing to inform you that your account has been placed under review "
            f"({restriction_type}) in accordance with our regulatory compliance obligations.\n\n"
            f"Case reference: {case_id}\n\n"
            "Access to certain services may be limited during this review. "
            "You may receive a follow-up request for additional documentation. "
            "For questions, reply to this message."
        ),
        tags=["compliance", "ofac-review", restriction_type],
        metadata={
            "case_id": case_id,
            "restriction_type": restriction_type,
            "requires_legal_review": True
        }
    )
    return result.message_id

def get_audit_log(message_id: str):
    """Retrieve full send record including approver and timestamp."""
    return client.read_email(message_id=message_id)

import multimail
from datetime import datetime, timezone

client = multimail.Client(
    api_key="mm_live_...",
    oversight_mode="autonomous"  "cm"># Templates pre-approved at setup
)

def broadcast_security_incident(
    incident_type: str,
    affected_systems: list[str],
    user_emails: list[str],
    incident_id: str
):
    """
    Sends pre-approved security alert to affected users.
    autonomous mode fires immediately — appropriate only for
    templates that have been reviewed and approved in advance.
    """
    sent_ids = []
    timestamp = datetime.now(timezone.utc).isoformat()

    for email in user_emails:
        result = client.send_email(
            mailbox="[email protected]",
            to=email,
            subject=f"Security Notice: {incident_type}",
            body=(
                f"We detected a security incident affecting: {&"cm">#039;, '.join(affected_systems)}.\n\n"
                f"Detected at: {timestamp}\n"
                f"Incident ID: {incident_id}\n\n"
                "Our team is actively responding. As a precaution:\n"
                "- Review recent account activity\n"
                "- Do not share seed phrases or private keys with anyone, including support staff\n"
                "- We will never ask for your private key via email\n\n"
                "We will send a follow-up within 2 hours with full details."
            ),
            tags=["security", "incident", incident_type.lower().replace(" ", "-")],
            metadata={
                "incident_id": incident_id,
                "incident_type": incident_type,
                "broadcast_timestamp": timestamp
            }
        )
        sent_ids.append(result.message_id)

    return sent_ids

import multimail

client = multimail.Client(api_key="mm_live_...")

def process_phishing_reports():
    """
    Reads inbound abuse reports, tags by severity,
    and sends acknowledgment replies.
    """
    inbox = client.check_inbox(
        mailbox="[email protected]",
        limit=25,
        unread_only=True
    )

    for msg in inbox.messages:
        email = client.read_email(message_id=msg.id)

        "cm"># Tag for triage
        severity = "high" if any(
            keyword in email.body.lower()
            for keyword in ["wallet", "seed phrase", "private key", "recovery"]
        ) else "standard"

        client.tag_email(
            message_id=msg.id,
            tags=["phishing-report", f"severity-{severity}"]
        )

        "cm"># Send acknowledgment
        client.reply_email(
            message_id=msg.id,
            body=(
                "Thank you for reporting this. Our security team has received your report "
                f"(reference: {msg.id}).\n\n"
                "We investigate all phishing reports and use them to protect the community. "
                "If you believe your account was compromised, reset your access immediately and "
                "do not use any links from the suspicious message."
            )
        )

        if severity == "high":
            "cm"># Escalate to security team mailbox
            client.send_email(
                mailbox="[email protected]",
                to="[email protected]",
                subject=f"High-severity phishing report: {msg.id}",
                body=f"Escalated report from {email.from_address}.\n\nOriginal message ID: {msg.id}\n\nBody preview:\n{email.body[:500]}",
                tags=["escalation", "phishing", "high-severity"]
            )