Webhooks

// On inbox creation
const inbox = await commune.inboxes.create({
  domainId: 'domain_id',
  localPart: 'support',
  webhook: {
    endpoint: 'https://your-server.com/webhook/email',
    events: ['inbound'],
  },
});

// On existing inbox
await commune.inboxes.setWebhook('domain_id', 'inbox_id', {
  endpoint: 'https://your-server.com/webhook/email',
  events: ['inbound'],
});

inbox = client.inboxes.create(
    local_part="support",
    webhook={"endpoint": "https://your-server.com/webhook/email"},
)

# Or update existing
client.inboxes.set_webhook(
    domain_id="domain_id",
    inbox_id="inbox_id",
    endpoint="https://your-server.com/webhook/email",
)

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/webhook/email",
      "events": ["inbound"]
    }
  }'

import express from 'express';
import { CommuneClient } from 'commune-ai';

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

app.post('/webhook/email', express.json(), async (req, res) => {
  const { message, extractedData, security } = req.body;

  // Check security
  if (security?.spam?.flagged) {
    console.log('Spam detected, ignoring');
    return res.json({ ok: true });
  }

  if (security?.prompt_injection?.detected) {
    console.log('Prompt injection detected, handling carefully');
  }

  // Process the message
  const sender = message.participants.find(p => p.role === 'sender')?.identity;
  console.log(`From: ${sender}`);
  console.log(`Subject: ${message.metadata.subject}`);
  console.log(`Extracted: ${JSON.stringify(extractedData)}`);

  // Reply
  await commune.messages.send({
    to: sender,
    subject: `Re: ${message.metadata.subject}`,
    html: '<p>Thanks for reaching out! We will get back to you soon.</p>',
    thread_id: message.thread_id,
  });

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

app.listen(3000);

from flask import Flask, request
from commune import CommuneClient

app = Flask(__name__)
client = CommuneClient(api_key="comm_...")

@app.route("/webhook/email", methods=["POST"])
def handle_email():
    data = request.json
    message = data["message"]
    security = data.get("security", {})
    extracted = data.get("extractedData", {})

    # Check security
    if security.get("spam", {}).get("flagged"):
        return {"ok": True}

    # Process
    sender = next(
        p["identity"] for p in message["participants"]
        if p["role"] == "sender"
    )

    # Reply
    client.messages.send(
        to=sender,
        subject=f"Re: {message['metadata']['subject']}",
        html="<p>Thanks! We'll get back to you soon.</p>",
        thread_id=message["thread_id"],
    )

    return {"ok": True}