Agent-Aware Email for Composio Integrations

from composio import ComposioToolSet, Action
import requests

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

toolset = ComposioToolSet()

"cm"># Define custom MultiMail actions
@toolset.register_action("multimail_send_email")
def send_email(to: str, subject: str, body: str, mailbox_id: str) -> dict:
    """Send an email via MultiMail with agent oversight.
    In gated_send mode, emails are queued for human approval."""
    resp = requests.post(f"{MULTIMAIL_API}/send", headers=HEADERS, json={
        "mailbox_id": mailbox_id,
        "to": to,
        "subject": subject,
        "body": body
    })
    return resp.json()

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

@toolset.register_action("multimail_reply_email")
def reply_email(message_id: str, body: str) -> dict:
    """Reply to an email within its thread via MultiMail."""
    resp = requests.post(f"{MULTIMAIL_API}/reply", headers=HEADERS, json={
        "message_id": message_id,
        "body": body
    })
    return resp.json()

from composio_langchain import ComposioToolSet
from langchain.agents import create_tool_calling_agent, AgentExecutor
from langchain_openai import ChatOpenAI
from langchain_core.prompts import ChatPromptTemplate

toolset = ComposioToolSet()

"cm"># Get MultiMail tools alongside other Composio integrations
tools = toolset.get_tools(
    actions=[
        "multimail_send_email",
        "multimail_check_inbox",
        "multimail_reply_email"
    ]
)

llm = ChatOpenAI(model="gpt-4o")
prompt = ChatPromptTemplate.from_messages([
    ("system", "You are an email assistant using MultiMail. "
     "All outbound emails use gated_send mode — they are queued "
     "for human approval before delivery."),
    ("human", "{input}"),
    ("placeholder", "{agent_scratchpad}")
])

agent = create_tool_calling_agent(llm, tools, prompt)
executor = AgentExecutor(agent=agent, tools=tools)
result = executor.invoke({"input": "Check my inbox and summarize"})

from composio_crewai import ComposioToolSet
from crewai import Agent, Task, Crew

toolset = ComposioToolSet()
tools = toolset.get_tools(
    actions=[
        "multimail_send_email",
        "multimail_check_inbox",
        "multimail_reply_email"
    ]
)

email_agent = Agent(
    role="Email Manager",
    goal="Handle email communications with oversight",
    backstory="You manage email via MultiMail. All outbound emails "
              "use gated_send mode and require human approval.",
    tools=tools
)

email_task = Task(
    description="Check the inbox and draft replies to any "
                "unanswered customer inquiries.",
    agent=email_agent,
    expected_output="Summary of inbox and drafted replies"
)

crew = Crew(agents=[email_agent], tasks=[email_task])
result = crew.kickoff()
print(result)