Email oversight for AI agents built on Salesforce

public class CaseEscalationEmailer {
    @future(callout=true)
    public static void sendEscalationEmail(String caseId, String contactEmail, String subject, String body) {
        HttpRequest req = new HttpRequest();
        req.setEndpoint('https://api.multimail.dev/v1/send');
        req.setMethod('POST');
        req.setHeader('Authorization', 'Bearer ' + System.label.MultiMail_API_Key);
        req.setHeader('Content-Type', 'application/json');

        Map<String, Object> payload = new Map<String, Object>{
            'from' => '[email protected]',
            'to' => contactEmail,
            'subject' => subject,
            'text' => body,
            'oversight_mode' => 'gated_send',
            'metadata' => new Map<String, String>{
                'salesforce_case_id' => caseId,
                'source' => 'apex_escalation_trigger'
            }
        };

        req.setBody(JSON.serialize(payload));
        Http http = new Http();
        HttpResponse res = http.send(req);

        if (res.getStatusCode() != 202) {
            System.debug('MultiMail error: ' + res.getBody());
        }
    }
}

import requests

MULTIMAIL_API_KEY = "mm_live_your_key_here"
BASE_URL = "https://api.multimail.dev/v1"
HEADERS = {"Authorization": f"Bearer {MULTIMAIL_API_KEY}", "Content-Type": "application/json"}

def handle_opportunity_closed_won(opportunity: dict):
    contact_email = opportunity["contact_email"]
    account_name = opportunity["account_name"]
    rep_name = opportunity["owner_name"]

    body = (
        f"Hi {account_name} team,\n\n"
        f"Your contract has been processed. {rep_name} will follow up within one business day "
        f"with onboarding details.\n\nThanks,\nAcme Sales Operations"
    )

    response = requests.post(
        f"{BASE_URL}/send",
        headers=HEADERS,
        json={
            "from": "[email protected]",
            "to": contact_email,
            "subject": f"Welcome aboard, {account_name}",
            "text": body,
            "oversight_mode": "gated_send",
            "metadata": {
                "opportunity_id": opportunity["id"],
                "source": "crm_closed_won_agent"
            }
        }
    )
    response.raise_for_status()
    message_id = response.json()["id"]
    print(f"Queued for approval: {message_id}")
    return message_id

def list_pending_approvals():
    response = requests.get(f"{BASE_URL}/pending", headers=HEADERS)
    response.raise_for_status()
    return response.json()["messages"]

from flask import Flask, request, jsonify
import requests

app = Flask(__name__)

SF_INSTANCE_URL = "https://acme.my.salesforce.com"
SF_ACCESS_TOKEN = "your_sf_access_token"

@app.route("/webhooks/multimail", methods=["POST"])
def multimail_webhook():
    event = request.json
    event_type = event.get("type")
    message = event.get("message", {})
    metadata = message.get("metadata", {})

    case_id = metadata.get("salesforce_case_id")
    if not case_id:
        return jsonify({"ok": True})

    if event_type == "message.approved":
        status_note = "Escalation email approved and sent by MultiMail agent."
    elif event_type == "message.rejected":
        status_note = "Escalation email rejected in MultiMail approval queue."
    else:
        return jsonify({"ok": True})

    sf_response = requests.patch(
        f"{SF_INSTANCE_URL}/services/data/v58.0/sobjects/Case/{case_id}",
        headers={
            "Authorization": f"Bearer {SF_ACCESS_TOKEN}",
            "Content-Type": "application/json"
        },
        json={"Description": status_note}
    )
    sf_response.raise_for_status()
    return jsonify({"ok": True})

if __name__ == "__main__":
    app.run(port=8080)

import requests

MULTIMAIL_API_KEY = "mm_live_your_key_here"
BASE_URL = "https://api.multimail.dev/v1"
HEADERS = {"Authorization": f"Bearer {MULTIMAIL_API_KEY}"}

def cancel_pending_email(message_id: str, reason: str) -> bool:
    response = requests.post(
        f"{BASE_URL}/cancel/{message_id}",
        headers={**HEADERS, "Content-Type": "application/json"},
        json={"reason": reason}
    )
    if response.status_code == 200:
        print(f"Cancelled {message_id}: {reason}")
        return True
    elif response.status_code == 409:
        print(f"Message {message_id} already delivered, cannot cancel")
        return False
    response.raise_for_status()