Give Zapier AI Actions Real Email With Human Oversight

const response = await fetch('https://api.multimail.dev/v1/send_email', {
  method: 'POST',
  headers: {
    'Authorization': `Bearer ${process.env.MM_API_KEY}`,
    'Content-Type': 'application/json',
  },
  body: JSON.stringify({
    from: '[email protected]',
    to: inputData.contact_email,
    subject: `Follow-up: ${inputData.deal_name}`,
    body: inputData.generated_body,
    oversight_mode: 'gated_send',
    tags: ['crm', 'zapier-ai'],
    metadata: {
      zap_id: inputData.zap_id,
      deal_id: inputData.deal_id,
    },
  }),
});

const result = await response.json();
if (!response.ok) {
  throw new Error(`MultiMail error: ${result.error}`);
}

"cm">// Return message_id so downstream Zap steps can reference it
output = { message_id: result.message_id, status: result.status };

import requests

def fetch_unread_via_zapier(zapier_ai_action_id: str, zapier_token: str, mailbox: str) -> dict:
    """Trigger a Zapier AI Action that proxies MultiMail check_inbox."""
    resp = requests.post(
        f"https://actions.zapier.com/api/v1/dynamic/exposed/{zapier_ai_action_id}/execute/",
        headers={"X-API-Key": zapier_token},
        json={
            "instructions": f"Fetch unread emails from {mailbox}",
            "mailbox": mailbox,
            "limit": 10,
            "filter": "unread",
        },
        timeout=15,
    )
    resp.raise_for_status()
    data = resp.json()
    "cm"># The Zap's MultiMail step returns structured messages
    return data.get("results", [])

"cm"># Usage in agent loop
messages = fetch_unread_via_zapier(
    zapier_ai_action_id="01JABCD123",
    zapier_token="sk-zapier-...",
    mailbox="[email protected]",
)
for msg in messages:
    print(msg["subject"], msg["sender"], msg["thread_id"])

"cm">// Zapier Catch Hook receives MultiMail webhook events
"cm">// Configure webhook URL in MultiMail dashboard under Settings > Webhooks
const event = inputData.event;       "cm">// 'approval.granted' | 'approval.denied'
const messageId = inputData.message_id;
const decisionNote = inputData.note; "cm">// Human reviewer's comment if any

if (event === 'approval.granted') {
  // Message will be delivered by MultiMail automatically
  // Continue Zap path: update CRM, notify Slack, etc.
  output = {
    action: 'continue',
    message_id: messageId,
    note: decisionNote || 'Approved',
  };
} else if (event === 'approval.denied') {
  // Log denial and halt downstream steps
  output = {
    action: 'halt',
    message_id: messageId,
    reason: decisionNote || 'Denied by reviewer',
  };
} else {
  // Unknown event — surface for debugging
  output = { action: 'unknown', event };
}

"cm">// Zapier Code step — parse MultiMail inbound webhook payload
"cm">// MultiMail fires this when mail arrives at your mailbox
const payload = JSON.parse(inputData.raw_body || '{}');

const email = {
  message_id:   payload.message_id,
  thread_id:    payload.thread_id,
  from:         payload.from?.address,
  from_name:    payload.from?.name,
  subject:      payload.subject,
  body_text:    payload.body?.text,
  received_at:  payload.received_at,
  "cm">// Reputation fields MultiMail attaches automatically
  sender_score: payload.sender?.reputation_score,
  tags:         (payload.tags || []).join(','),
};

"cm">// Fail loudly if required fields are missing
if (!email.message_id || !email.from) {
  throw new Error('Invalid MultiMail webhook payload — missing message_id or from');
}

output = email;

"cm">// inputData.message_id and inputData.decision come from
"cm">// a preceding Zapier approval step or Slack interactive message handler
const { message_id, decision, reviewer_note } = inputData;

const response = await fetch(`https:"cm">//api.multimail.dev/v1/decide_email`, {
  method: 'POST',
  headers: {
    'Authorization': `Bearer ${process.env.MM_API_KEY}`,
    'Content-Type': 'application/json',
  },
  body: JSON.stringify({
    message_id,
    decision,       "cm">// 'approve' | 'deny'
    note: reviewer_note || '',
  }),
});

const result = await response.json();
if (!response.ok) {
  throw new Error(`decide_email failed: ${result.error}`);
}

output = { status: result.status, message_id: result.message_id };