SIGN UPLOG IN
X (Twitter)LinkedInGitHubDiscordYouTube

How to integrate Unione MCP with CrewAI

Connect CrewAI to Unione MCP. Check your current unione email balance, cancel a scheduled email by job id, and more using natural language, with authentication handled for you.

Get started for freeGet a demo
Unione logoUnione
Api Key

UniOne is an email delivery service with a flexible Web API and SMTP API for transactional and marketing emails. It streamlines reliable, scalable email sending for developers and businesses.

32 Tools

Introduction

This guide walks you through connecting Unione to CrewAI using the Composio tool router. By the end, you'll have a working Unione agent that can schedule and resend emails, manage templates, check delivery statistics, validate email addresses, and handle suppression lists through natural language commands.

This guide will help you understand how to give your CrewAI agent real control over a Unione account through Composio's Unione MCP server.

Before we dive in, let's take a quick look at the key ideas and tools involved.

Also integrate Unione with

Claude CodeClaude CoworkOpenAI Agents SDKClaude Agent SDKCodexOpenClawHermesAtomic AgentGoogle ADKLangChainVercel AI SDKMastra AILlamaIndexPydantic AIAutoGen

TL;DR

Here's what you'll learn:
  • Get a Composio API key and configure your Unione connection
  • Set up CrewAI with an MCP enabled agent
  • Create a Tool Router session or standalone MCP server for Unione
  • Build a conversational loop where your agent can execute Unione operations

What is CrewAI?

CrewAI is a powerful framework for building multi-agent AI systems. It provides primitives for defining agents with specific roles, creating tasks, and orchestrating workflows through crews.

Key features include:

  • Agent Roles: Define specialized agents with specific goals and backstories
  • Task Management: Create tasks with clear descriptions and expected outputs
  • Crew Orchestration: Combine agents and tasks into collaborative workflows
  • MCP Integration: Connect to external tools through Model Context Protocol

What is the Unione MCP server, and what's possible with it?

The Unione MCP server is an implementation of the Model Context Protocol that connects your AI agent and assistants like Claude, Cursor, etc directly to your Unione account. It provides structured and secure access to your Unione email delivery service, so your agent can send transactional or marketing emails, manage sending domains, monitor delivery events, check account balance, and automate email operations on your behalf.

  • Automated email sending and scheduling: Have your agent send transactional or marketing emails and even schedule deliveries right from your Unione account.
  • Domain verification and management: Easily manage sender domains, trigger domain verifications, and handle DNS/DKIM checks to keep your emails deliverable.
  • Event monitoring and export: Let your agent fetch specific email events, retrieve delivery metrics, or export comprehensive email event logs for auditing and analytics.
  • Account balance and plan checks: Quickly access your current email balance and subscription plan details, ensuring you stay within your sending limits.
  • Email job and pricing insights: Retrieve detailed information about specific email jobs and get up-to-date pricing for cost management before sending campaigns.

What is the Composio tool router, and how does it fit here?

What is Composio SDK?

Composio's Composio SDK helps agents find the right tools for a task at runtime. You can plug in multiple toolkits (like Gmail, HubSpot, and GitHub), and the agent will identify the relevant app and action to complete multi-step workflows. This can reduce token usage and improve the reliability of tool calls. Read more here: Getting started with Composio SDK

The tool router generates a secure MCP URL that your agents can access to perform actions.

How the Composio SDK works

The Composio SDK follows a three-phase workflow:

  1. Discovery: Searches for tools matching your task and returns relevant toolkits with their details.
  2. Authentication: Checks for active connections. If missing, creates an auth config and returns a connection URL via Auth Link.
  3. Execution: Executes the action using the authenticated connection.

Step-by-step Guide

Step by step08 STEPS
1

Prerequisites

Before starting, make sure you have:
  • Python 3.9 or higher
  • A Composio account and API key
  • A Unione connection authorized in Composio
  • An OpenAI API key for the CrewAI LLM
  • Basic familiarity with Python
2

Getting API Keys for OpenAI and Composio

OpenAI API Key
  • Go to the OpenAI dashboard and create an API key. You'll need credits to use the models, or you can connect to another model provider.
  • Keep the API key safe.
Composio API Key
  • Log in to the Composio dashboard.
  • Navigate to your API settings and generate a new API key.
  • Store this key securely as you'll need it for authentication.
3

Install dependencies

bash
pip install composio crewai crewai-tools[mcp] python-dotenv
What's happening:
  • composio connects your agent to Unione via MCP
  • crewai provides Agent, Task, Crew, and LLM primitives
  • crewai-tools[mcp] includes MCP helpers
  • python-dotenv loads environment variables from .env
4

Set up environment variables

bash
COMPOSIO_API_KEY=your_composio_api_key_here
USER_ID=your_user_id_here
OPENAI_API_KEY=your_openai_api_key_here

Create a .env file in your project root.

What's happening:

  • COMPOSIO_API_KEY authenticates with Composio
  • USER_ID scopes the session to your account
  • OPENAI_API_KEY lets CrewAI use your chosen OpenAI model
5

Import dependencies

python
import os
from composio import Composio
from crewai import Agent, Task, Crew
from crewai_tools import MCPServerAdapter
import dotenv

dotenv.load_dotenv()

COMPOSIO_API_KEY = os.getenv("COMPOSIO_API_KEY")
COMPOSIO_USER_ID = os.getenv("COMPOSIO_USER_ID")

if not COMPOSIO_API_KEY:
    raise ValueError("COMPOSIO_API_KEY is not set")
if not COMPOSIO_USER_ID:
    raise ValueError("COMPOSIO_USER_ID is not set")
What's happening:
  • CrewAI classes define agents and tasks, and run the workflow
  • MCPServerHTTP connects the agent to an MCP endpoint
  • Composio will give you a short lived Unione MCP URL
6

Create a Composio Tool Router session for Unione

python
composio_client = Composio(api_key=COMPOSIO_API_KEY)
session = composio_client.create(user_id=COMPOSIO_USER_ID, toolkits=["unione"])

url = session.mcp.url
What's happening:
  • You create a Unione only session through Composio
  • Composio returns an MCP HTTP URL that exposes Unione tools
7

Initialize the MCP Server

python
server_params = {
    "url": url,
    "transport": "streamable-http",
    "headers": {"x-api-key": COMPOSIO_API_KEY},
}

with MCPServerAdapter(server_params) as tools:
    agent = Agent(
        role="Search Assistant",
        goal="Help users search the internet effectively",
        backstory="You are a helpful assistant with access to search tools.",
        tools=tools,
        verbose=False,
        max_iter=10,
    )
What's Happening:
  • Server Configuration: The code sets up connection parameters including the MCP server URL, streamable HTTP transport, and Composio API key authentication.
  • MCP Adapter Bridge: MCPServerAdapter acts as a context manager that converts Composio MCP tools into a CrewAI-compatible format.
  • Agent Setup: Creates a CrewAI Agent with a defined role (Search Assistant), goal (help with internet searches), and access to the MCP tools.
  • Configuration Options: The agent includes settings like verbose=False for clean output and max_iter=10 to prevent infinite loops.
  • Dynamic Tool Usage: Once created, the agent automatically accesses all Composio Search tools and decides when to use them based on user queries.
8

Create a CLI Chatloop and define the Crew

python
print("Chat started! Type 'exit' or 'quit' to end.\n")

conversation_context = ""

while True:
    user_input = input("You: ").strip()

    if user_input.lower() in ["exit", "quit", "bye"]:
        print("\nGoodbye!")
        break

    if not user_input:
        continue

    conversation_context += f"\nUser: {user_input}\n"
    print("\nAgent is thinking...\n")

    task = Task(
        description=(
            f"Conversation history:\n{conversation_context}\n\n"
            f"Current request: {user_input}"
        ),
        expected_output="A helpful response addressing the user's request",
        agent=agent,
    )

    crew = Crew(agents=[agent], tasks=[task], verbose=False)
    result = crew.kickoff()
    response = str(result)

    conversation_context += f"Agent: {response}\n"
    print(f"Agent: {response}\n")
What's Happening:
  • Interactive CLI Setup: The code creates an infinite loop that continuously prompts for user input and maintains the entire conversation history in a string variable.
  • Input Validation: Empty inputs are ignored to prevent processing blank messages and keep the conversation clean.
  • Context Building: Each user message is appended to the conversation context, which preserves the full dialogue history for better agent responses.
  • Dynamic Task Creation: For every user input, a new Task is created that includes both the full conversation history and the current request as context.
  • Crew Execution: A Crew is instantiated with the agent and task, then kicked off to process the request and generate a response.
  • Response Management: The agent's response is converted to a string, added to the conversation context, and displayed to the user, maintaining conversational continuity.

Complete Code

Here's the complete code to get you started with Unione and CrewAI:

python
from crewai import Agent, Task, Crew, LLM
from crewai_tools import MCPServerAdapter
from composio import Composio
from dotenv import load_dotenv
import os

load_dotenv()

GOOGLE_API_KEY = os.getenv("GOOGLE_API_KEY")
COMPOSIO_API_KEY = os.getenv("COMPOSIO_API_KEY")
COMPOSIO_USER_ID = os.getenv("COMPOSIO_USER_ID")

if not GOOGLE_API_KEY:
    raise ValueError("GOOGLE_API_KEY is not set in the environment.")
if not COMPOSIO_API_KEY:
    raise ValueError("COMPOSIO_API_KEY is not set in the environment.")
if not COMPOSIO_USER_ID:
    raise ValueError("COMPOSIO_USER_ID is not set in the environment.")

# Initialize Composio and create a session
composio = Composio(api_key=COMPOSIO_API_KEY)
session = composio.create(
    user_id=COMPOSIO_USER_ID,
    toolkits=["unione"],
)
url = session.mcp.url

# Configure LLM
llm = LLM(
    model="gpt-5",
    api_key=os.getenv("OPENAI_API_KEY"),
)

server_params = {
    "url": url,
    "transport": "streamable-http",
    "headers": {"x-api-key": COMPOSIO_API_KEY},
}

with MCPServerAdapter(server_params) as tools:
    agent = Agent(
        role="Search Assistant",
        goal="Help users with internet searches",
        backstory="You are an expert assistant with access to Composio Search tools.",
        tools=tools,
        llm=llm,
        verbose=False,
        max_iter=10,
    )

    print("Chat started! Type 'exit' or 'quit' to end.\n")

    conversation_context = ""

    while True:
        user_input = input("You: ").strip()

        if user_input.lower() in ["exit", "quit", "bye"]:
            print("\nGoodbye!")
            break

        if not user_input:
            continue

        conversation_context += f"\nUser: {user_input}\n"
        print("\nAgent is thinking...\n")

        task = Task(
            description=(
                f"Conversation history:\n{conversation_context}\n\n"
                f"Current request: {user_input}"
            ),
            expected_output="A helpful response addressing the user's request",
            agent=agent,
        )

        crew = Crew(agents=[agent], tasks=[task], verbose=False)
        result = crew.kickoff()
        response = str(result)

        conversation_context += f"Agent: {response}\n"
        print(f"Agent: {response}\n")

Conclusion

You now have a CrewAI agent connected to Unione through Composio's Tool Router. The agent can perform Unione operations through natural language commands.

Next steps:

  • Add role-specific instructions to customize agent behavior
  • Plug in more toolkits for multi-app workflows
  • Chain tasks for complex multi-step operations
TOOLS

Supported Tools

Every Unione action and event your agent gets out of the box.

Delete Event Dump

Tool to delete an event dump file and remove it from the queue or storage.

Delete Template

Tool to delete a template by ID.

Delete Webhook

Tool to delete a webhook event notification handler by its URL.

UniOne Email Balance

Retrieves account information and billing-period email usage from UniOne, including emails included and sent.

Cancel Scheduled Email

Tool to cancel a scheduled transactional email by its job ID.

UniOne Email Domain Management

Manage UniOne sender domains: obtain DNS verification records, trigger ownership or DKIM checks, list domains, or delete a domain.

Get Email Event

Tool to retrieve details of a specific email event by its ID.

Get Email Send Job

Tool to retrieve detailed information about a specific email send job.

UniOne Email List (Export)

Tool to export email events within a specified time frame.

Resend Sent Email

Tool to resend a previously sent email by its job ID.

UniOne Email Resubscribe

Send a resubscription link to a previously unsubscribed recipient or one blocked due to complaints.

Resume Paused Email

Tool to resume a paused transactional email by its job ID.

UniOne Email SMTP Configuration

Construct SMTP configuration details from the connection's region and API key, including a derived host, ports, username and password.

UniOne Email Statistics

Retrieve daily and total email statistics for an inclusive date range, including sent, delivered, bounced, opened, and clicked counts.

UniOne Email Unsubscribe

Add an email address to the UniOne suppression list with an unsubscribed cause, suppressing future sends in the applicable account or project.

Batch Email Validation

Validates a list of email addresses using UniOne's single-address checks.

Remove Email from Suppression List

Remove deletable suppression records for an email address from the UniOne suppression list.

Retry Email Validation

Tool to retry an email validation request.

UniOne Email Webhook Types

Collects the distinct spam-block and email-status event types configured on the webhooks returned by one webhook-list request.

Create Event Dump

Tool to create an asynchronous CSV event dump.

UniOne Event Dump List

Tool to retrieve the full list of event dumps.

Get Event Dump

Retrieve an event dump's status and available download URLs by dump ID.

Get Email Suppression Details

Tool to check if an email is suppressed and retrieve the reason and date.

Get Template

Tool to get template properties by ID.

Get Webhook Configuration

Retrieves a UniOne webhook configuration by its URL.

Schedule Email

Tool to schedule a transactional email up to 24 hours ahead.

Suppression List

Tool to return the suppression list since a given date.

Delete Tag

Tool to delete a specific tag.

UniOne Tag List

Tool to retrieve all user-defined tags.

UniOne Template List

Tool to list email templates.

Set Template

Tool to set or update an email template.

Set Webhook

Tool to set or edit a webhook event notification handler.

FRAMEWORKS

How to build Unione MCP Agent with another framework

Claude Code logo

Claude Code

Use Unione MCP with Claude Code

Claude Cowork logo

Claude Cowork

Use Unione MCP with Claude Cowork

OpenAI Agents SDK logo

OpenAI Agents SDK

Use Unione MCP with OpenAI Agents SDK

Claude Agent SDK logo

Claude Agent SDK

Use Unione MCP with Claude Agent SDK

Codex logo

Codex

Use Unione MCP with Codex

OpenClaw logo

OpenClaw

Use Unione MCP with OpenClaw

Hermes logo

Hermes

Use Unione MCP with Hermes

Atomic Agent logo

Atomic Agent

Use Unione MCP with Atomic Agent

Google ADK logo

Google ADK

Use Unione MCP with Google ADK

LangChain logo

LangChain

Use Unione MCP with LangChain

Vercel AI SDK logo

Vercel AI SDK

Use Unione MCP with Vercel AI SDK

Mastra AI logo

Mastra AI

Use Unione MCP with Mastra AI

LlamaIndex logo

LlamaIndex

Use Unione MCP with LlamaIndex

Pydantic AI logo

Pydantic AI

Use Unione MCP with Pydantic AI

AutoGen logo

AutoGen

Use Unione MCP with AutoGen

FAQ

Frequently asked questions

With a standalone Unione MCP server, the agents and LLMs can only access a fixed set of Unione tools tied to that server. However, with the Composio Tool Router, agents can dynamically load tools from Unione and many other apps based on the task at hand, all through a single MCP endpoint.

Yes, you can. CrewAI fully supports MCP integration. You get structured tool calling, message history handling, and model orchestration while Tool Router takes care of discovering and serving the right Unione tools.

Yes, absolutely. You can configure which Unione scopes and actions are allowed when connecting your account to Composio. You can also bring your own OAuth credentials or API configuration so you keep full control over what the agent can do.

All sensitive data such as tokens, keys, and configuration is fully encrypted at rest and in transit. Composio is SOC 2 Type 2 compliant and follows strict security practices so your Unione data and credentials are handled as safely as possible.

Start with Unione.It takes 30 seconds.

Managed auth, hosted MCP servers, and every Unione tool your agent needs.Free to start.

Start building