Quickstart

npm install commune-ai

pip install commune-mail

# Add to your MCP config:
# command: "uvx", args: ["commune-mcp"]

import { CommuneClient } from 'commune-ai';

const commune = new CommuneClient({
  apiKey: process.env.COMMUNE_API_KEY,
});

from commune import CommuneClient

client = CommuneClient(api_key="comm_...")
# Or set COMMUNE_API_KEY env var and omit api_key

{
  "mcpServers": {
    "commune": {
      "command": "uvx",
      "args": ["commune-mcp"],
      "env": {
        "COMMUNE_API_KEY": "comm_..."
      }
    }
  }
}

const inbox = await commune.inboxes.create({
  localPart: 'support',
});

console.log(inbox.address);
// → support@yourdomain.com

inbox = client.inboxes.create(local_part="support")
print(inbox.address)
# → support@yourdomain.com

create_inbox(local_part="support")

curl -X POST https://api.commune.email/v1/inboxes \
  -H "Authorization: Bearer comm_..." \
  -H "Content-Type: application/json" \
  -d '{
    "local_part": "support",
    "name": "Support Agent"
  }'

const result = await commune.messages.send({
  to: 'customer@example.com',
  subject: 'Your order is confirmed',
  html: '<p>Hi! Your order #12345 has been confirmed.</p>',
  text: 'Hi! Your order #12345 has been confirmed.',
});

console.log(result.thread_id);  // thread_abc123

result = client.messages.send(
    to="customer@example.com",
    subject="Your order is confirmed",
    html="<p>Hi! Your order #12345 has been confirmed.</p>",
    text="Hi! Your order #12345 has been confirmed.",
)

print(result.thread_id)  # thread_abc123

send_email(
  to="customer@example.com",
  subject="Your order is confirmed",
  body="Hi! Your order #12345 has been confirmed."
)

curl -X POST https://api.commune.email/v1/messages/send \
  -H "Authorization: Bearer comm_..." \
  -H "Content-Type: application/json" \
  -d '{
    "to": "customer@example.com",
    "subject": "Your order is confirmed",
    "html": "<p>Hi! Your order #12345 has been confirmed.</p>"
  }'

await commune.inboxes.setWebhook(inbox.domainId, inbox.id, {
  endpoint: 'https://your-server.com/webhooks/email',
  events: ['inbound'],
});

client.inboxes.set_webhook(
    domain_id=inbox.domain_id,
    inbox_id=inbox.id,
    endpoint="https://your-server.com/webhooks/email",
    events=["inbound"],
)

curl -X PUT https://api.commune.email/v1/domains/DOMAIN_ID/inboxes/INBOX_ID \
  -H "Authorization: Bearer comm_..." \
  -H "Content-Type: application/json" \
  -d '{
    "webhook": {
      "endpoint": "https://your-server.com/webhooks/email",
      "events": ["inbound"]
    }
  }'

import express from 'express';
import { CommuneClient } from 'commune-ai';
import Anthropic from '@anthropic-ai/sdk';

const app = express();
const commune = new CommuneClient({ apiKey: process.env.COMMUNE_API_KEY });
const anthropic = new Anthropic();

app.post('/webhooks/email', express.json(), async (req, res) => {
  const { message } = req.body;
  if (message.direction !== 'inbound') return res.json({ ok: true });

  // Generate reply
  const response = await anthropic.messages.create({
    model: 'claude-sonnet-4-6',
    max_tokens: 1024,
    system: 'You are a helpful customer support agent. Reply concisely and helpfully.',
    messages: [{ role: 'user', content: message.content }],
  });

  const replyHtml = response.content[0].type === 'text'
    ? `<p>${response.content[0].text}</p>`
    : '';

  const sender = message.participants.find(p => p.role === 'sender')?.identity;

  // Reply in the same thread
  await commune.messages.send({
    to: sender,
    subject: `Re: ${message.metadata.subject}`,
    html: replyHtml,
    thread_id: message.thread_id,
  });

  res.json({ ok: true });
});

app.listen(3000);

from flask import Flask, request, jsonify
from commune import CommuneClient
import anthropic

app = Flask(__name__)
commune = CommuneClient()
claude = anthropic.Anthropic()

@app.route("/webhooks/email", methods=["POST"])
def handle_email():
    data = request.json
    message = data["message"]
    if message["direction"] != "inbound":
        return jsonify(ok=True)

    # Generate reply
    response = claude.messages.create(
        model="claude-sonnet-4-6",
        max_tokens=1024,
        system="You are a helpful customer support agent. Reply concisely and helpfully.",
        messages=[{"role": "user", "content": message["content"]}],
    )

    reply_text = response.content[0].text
    sender = next(p["identity"] for p in message["participants"] if p["role"] == "sender")

    # Reply in the same thread
    commune.messages.send(
        to=sender,
        subject=f"Re: {message['metadata']['subject']}",
        html=f"<p>{reply_text}</p>",
        thread_id=message["thread_id"],
    )

    return jsonify(ok=True)