How do I handle inbound emails with my agent?

1
from flask import Flask, request
2
from agentmail import AgentMail
3
4
app = Flask(__name__)
5
client = AgentMail()
6
7
@app.route("/webhooks", methods=["POST"])
8
def handle_webhook():
9
    payload = request.json
10
    
11
    if payload["event_type"] == "message.received":
12
        message = payload["message"]
13
        
14
        # Your agent processes the email here
15
        reply_text = your_agent.process(message)
16
        
17
        # Reply in the same thread
18
        client.inboxes.messages.reply(
19
            inbox_id=message["inbox_id"],
20
            message_id=message["message_id"],
21
            text=reply_text
22
        )
23
    
24
    return "OK", 200

1
client.webhooks.create(
2
    url="https://your-domain.ngrok-free.app/webhooks",
3
    events=["message.received"],
4
)

1
import asyncio
2
from agentmail import AsyncAgentMail, Subscribe, Subscribed, MessageReceivedEvent
3
4
client = AsyncAgentMail()
5
6
async def main():
7
    async with client.websockets.connect() as socket:
8
        await socket.send_subscribe(Subscribe(
9
            inbox_ids=["agent@agentmail.to"]
10
        ))
11
12
        async for event in socket:
13
            if isinstance(event, Subscribed):
14
                print(f"Subscribed to: {event.inbox_ids}")
15
            elif isinstance(event, MessageReceivedEvent):
16
                print(f"New email from: {event.message.from_}")
17
                print(f"Subject: {event.message.subject}")
18
19
asyncio.run(main())

1
from agentmail import AgentMail, Subscribe, MessageReceivedEvent
2
3
client = AgentMail()
4
5
with client.websockets.connect() as socket:
6
    socket.send_subscribe(Subscribe(
7
        inbox_ids=["agent@agentmail.to"]
8
    ))
9
10
    for event in socket:
11
        if isinstance(event, MessageReceivedEvent):
12
            print(f"New email from: {event.message.from_}")