How do I use Commune with the OpenAI Agents SDK?

pip install openai-agents commune-mail

COMMUNE_API_KEY=comm_...
COMMUNE_INBOX_ID=inbox_...

import os
from commune import CommuneClient

client = CommuneClient(api_key=os.environ["COMMUNE_API_KEY"])
INBOX_ID = os.environ["COMMUNE_INBOX_ID"]

from agents import function_tool

@function_tool
def send_email(to: str, subject: str, body: str) -> str:
    """Send an email from the agent's inbox."""
    result = client.messages.send(
        inbox_id=INBOX_ID,
        to=to,
        subject=subject,
        text=body,
    )
    return f"Sent. Message ID: {result.id}"


@function_tool
def read_inbox(limit: int = 10) -> str:
    """Read the most recent messages in the agent's inbox."""
    messages = client.messages.list(inbox_id=INBOX_ID, limit=limit)
    if not messages:
        return "Inbox is empty."
    lines = []
    for m in messages:
        lines.append(f"[{m.id}] From: {m.from_address} | Subject: {m.subject}")
    return "\n".join(lines)


@function_tool
def get_thread(message_id: str) -> str:
    """Fetch all messages in a thread by any message ID in that thread."""
    thread = client.messages.get_thread(inbox_id=INBOX_ID, message_id=message_id)
    parts = []
    for m in thread:
        parts.append(
            f"---\nFrom: {m.from_address}\nSubject: {m.subject}\n\n{m.text}\n"
        )
    return "\n".join(parts)

from agents import Agent

inbox = client.inboxes.get(inbox_id=INBOX_ID)

email_agent = Agent(
    name="EmailAgent",
    instructions=(
        f"You are an email assistant. Your inbox address is {inbox.email}. "
        "Use send_email to send messages, read_inbox to check for new mail, "
        "and get_thread to read a full conversation before replying."
    ),
    tools=[send_email, read_inbox, get_thread],
    model="gpt-4o",
)

from agents import Runner

result = Runner.run_sync(
    email_agent,
    "Check my inbox and reply to any unanswered questions from the last 5 emails.",
)

print(result.final_output)

from fastapi import FastAPI, Request
from agents import Agent, Runner

app = FastAPI()

@app.post("/webhook/email")
async def handle_inbound(request: Request):
    payload = await request.json()
    message = payload["message"]

    # Pull full thread context before handing to the agent
    thread = client.messages.get_thread(
        inbox_id=INBOX_ID,
        message_id=message["id"],
    )
    thread_text = "\n\n".join(
        f"From: {m['fromAddress']}\n{m['text']}" for m in thread
    )

    prompt = (
        f"A new reply arrived in your inbox.\n\n"
        f"Thread so far:\n{thread_text}\n\n"
        f"Latest message from {message['fromAddress']}:\n{message['text']}\n\n"
        "Read the thread, then send an appropriate reply."
    )

    await Runner.run(email_agent, prompt)
    return {"ok": True}