how to give your CrewAI agent an email address in 5 minutes

from crewai.tools import BaseTool

class MyTool(BaseTool):
    name: str = "my_tool"
    description: str = "What this tool does"

    def _run(self, argument: str) -> str:
        # do the thing
        return "result"

import requests
from crewai.tools import BaseTool

API_BASE = "https://api.lobstermail.ai"


class CreateInboxTool(BaseTool):
    name: str = "create_inbox"
    description: str = (
        "Create a new email inbox for this agent. "
        "Returns the email address and inbox ID. "
        "Call this once before sending or receiving email."
    )

    def _run(self, handle: str = "my-crew-agent") -> str:
        # sign up (idempotent — returns existing token if already registered)
        signup = requests.post(f"{API_BASE}/v1/auth/signup")
        token = signup.json()["token"]

        # store token for other tools
        self._shared_state["lobstermail_token"] = token

        # create the inbox
        resp = requests.post(
            f"{API_BASE}/v1/inboxes",
            headers={"Authorization": f"Bearer {token}"},
            json={"handle": handle},
        )
        inbox = resp.json()

        self._shared_state["inbox_id"] = inbox["id"]
        self._shared_state["inbox_address"] = inbox["address"]

        return f"Inbox created: {inbox['address']} (ID: {inbox['id']})"


class CheckEmailTool(BaseTool):
    name: str = "check_email"
    description: str = (
        "Check the agent's inbox for new emails. "
        "Returns a list of recent messages with sender, subject, and body."
    )

    def _run(self, since: str = "") -> str:
        token = self._shared_state.get("lobstermail_token")
        inbox_id = self._shared_state.get("inbox_id")

        if not token or not inbox_id:
            return "Error: no inbox found. Call create_inbox first."

        params = {}
        if since:
            params["since"] = since

        resp = requests.get(
            f"{API_BASE}/v1/inboxes/{inbox_id}/emails",
            headers={"Authorization": f"Bearer {token}"},
            params=params,
        )
        emails = resp.json().get("emails", [])

        if not emails:
            return "No new emails."

        results = []
        for e in emails:
            results.append(
                f"From: {e['from']}\n"
                f"Subject: {e['subject']}\n"
                f"Body: {e.get('bodyPreview', e.get('body', ''))}\n"
            )
        return "\n---\n".join(results)


class SendEmailTool(BaseTool):
    name: str = "send_email"
    description: str = (
        "Send an email from the agent's inbox. "
        "Requires the recipient address, subject, and body text."
    )

    def _run(self, to: str, subject: str, body: str) -> str:
        token = self._shared_state.get("lobstermail_token")
        address = self._shared_state.get("inbox_address")

        if not token or not address:
            return "Error: no inbox found. Call create_inbox first."

        resp = requests.post(
            f"{API_BASE}/v1/emails/send",
            headers={"Authorization": f"Bearer {token}"},
            json={
                "from": address,
                "to": to,
                "subject": subject,
                "body": body,
            },
        )

        if resp.status_code == 200:
            return f"Email sent to {to}."
        return f"Send failed: {resp.text}"

from crewai import Agent, Task, Crew

# instantiate the tools
create_inbox = CreateInboxTool()
check_email = CheckEmailTool()
send_email = SendEmailTool()

# define the agent
email_agent = Agent(
    role="Email Assistant",
    goal=(
        "Manage your own email inbox. Check for new messages, "
        "summarize them, and send replies when instructed."
    ),
    backstory=(
        "You are an AI assistant with your own email address. "
        "You handle incoming email autonomously and can compose "
        "and send replies on behalf of your team."
    ),
    tools=[create_inbox, check_email, send_email],
    verbose=True,
)

# task: set up the inbox and check for mail
setup_and_check = Task(
    description=(
        "First, create an email inbox with the handle 'crew-assistant'. "
        "Then check for any new emails and summarize what you find."
    ),
    expected_output="A summary of the inbox setup and any received emails.",
    agent=email_agent,
)

crew = Crew(
    agents=[email_agent],
    tasks=[setup_and_check],
    verbose=True,
)

result = crew.kickoff()
print(result)

researcher = Agent(
    role="Lead Researcher",
    goal="Find potential customers and gather their contact info.",
    backstory="You research companies and identify decision-makers.",
    tools=[search_tool, scrape_tool],  # your existing tools
)

outreach_agent = Agent(
    role="Outreach Specialist",
    goal="Send personalized outreach emails to leads.",
    backstory="You craft and send concise, relevant outreach emails.",
    tools=[create_inbox, send_email, check_email],
)

research_task = Task(
    description="Find 5 SaaS founders who recently posted about AI agents.",
    expected_output="A list of names and email addresses.",
    agent=researcher,
)

outreach_task = Task(
    description=(
        "Create an email inbox, then send a short personalized email "
        "to each lead from the research results. Keep it under 3 sentences."
    ),
    expected_output="Confirmation that all outreach emails were sent.",
    agent=outreach_agent,
    context=[research_task],
)

crew = Crew(
    agents=[researcher, outreach_agent],
    tasks=[research_task, outreach_task],
    verbose=True,
)

# modify CreateInboxTool to accept a webhook URL
resp = requests.post(
    f"{API_BASE}/v1/inboxes",
    headers={"Authorization": f"Bearer {token}"},
    json={
        "handle": handle,
        "webhookUrl": "https://your-server.com/webhook/crewai-inbox",
    },
)