Email Tools for OpenAI Agents SDK

import requests
from agents import function_tool

MULTIMAIL_API = "https://api.multimail.dev/v1"
HEADERS = {"Authorization": "Bearer mm_live_your_api_key"}

@function_tool
def send_email(to: str, subject: str, body: str, mailbox_id: str) -> str:
    """Send an email through MultiMail. In gated_send mode, queues for human approval."""
    resp = requests.post(f"{MULTIMAIL_API}/send", headers=HEADERS, json={
        "mailbox_id": mailbox_id, "to": to,
        "subject": subject, "body": body
    })
    return str(resp.json())

@function_tool
def check_inbox(mailbox_id: str, limit: int = 10) -> str:
    """Check the inbox for recent messages."""
    resp = requests.get(
        f"{MULTIMAIL_API}/mailboxes/{mailbox_id}/inbox",
        headers=HEADERS, params={"limit": limit}
    )
    return str(resp.json())

@function_tool
def reply_email(message_id: str, body: str) -> str:
    """Reply to an email by message ID, maintaining thread context."""
    resp = requests.post(f"{MULTIMAIL_API}/reply", headers=HEADERS, json={
        "message_id": message_id, "body": body
    })
    return str(resp.json())

from agents import Agent, Runner, GuardrailFunctionOutput, InputGuardrail
from pydantic import BaseModel

class EmailSafetyCheck(BaseModel):
    is_safe: bool
    reasoning: str

guardrail_agent = Agent(
    name="Email Safety",
    instructions="Check if the user&"cm">#039;s email request is appropriate. "
    "Flag requests to send spam, phishing, or abusive content.",
    output_type=EmailSafetyCheck
)

async def email_guardrail(ctx, agent, input_text):
    result = await Runner.run(guardrail_agent, input_text, context=ctx.context)
    return GuardrailFunctionOutput(
        output_info=result.final_output,
        tripwire_triggered=not result.final_output.is_safe
    )

email_agent = Agent(
    name="Email Assistant",
    instructions="You are an email assistant using MultiMail. The mailbox "
    "uses gated_send mode, so sent emails queue for human approval. "
    "Use the provided tools to check inbox, send, and reply to emails.",
    tools=[send_email, check_inbox, reply_email],
    input_guardrails=[InputGuardrail(guardrail_function=email_guardrail)]
)

result = await Runner.run(email_agent, "Check my inbox and summarize new messages")
print(result.final_output)

from agents import Agent, Runner

triage_agent = Agent(
    name="Triage",
    instructions="You triage inbound emails. Check the inbox and classify "
    "each email. Hand off urgent emails to the Urgent Responder and "
    "routine emails to the Auto Responder.",
    tools=[check_inbox],
    handoffs=["urgent_responder", "auto_responder"]
)

urgent_responder = Agent(
    name="Urgent Responder",
    instructions="You handle urgent emails. Draft thoughtful replies "
    "using reply_email. These will go through gated_send approval.",
    tools=[reply_email, send_email]
)

auto_responder = Agent(
    name="Auto Responder",
    instructions="You handle routine emails with standard replies. "
    "Use reply_email to respond with appropriate templates.",
    tools=[reply_email]
)

"cm"># The SDK handles handoffs automatically based on agent decisions
result = await Runner.run(triage_agent, "Process today&"cm">#039;s inbox")
print(result.final_output)