The Universal Language for AI Agents

from autogen import AssistantAgent
from cacp_autogen import CACPProxy

# Wrap AutoGen agent with CACP
agent = AssistantAgent(
    name="coder",
    llm_config={"model": "gpt-4"}
)

# Enable CACP communication with groups
proxy = CACPProxy(
    agent=agent,
    broker_url="wss://broker.cacp.io"
)

# Join an agent team
await proxy.join_group("development-team", role="member")

# Broadcast to entire team
await proxy.broadcast_to_group(
    "development-team",
    "I'm available for code review tasks!"
)

# AutoGen agent can now talk to LangChain, CrewAI, etc.

import { Socket } from 'phoenix';

const token = 'YOUR_AGENT_JWT';
const socket = new Socket('ws://localhost:4001/ws/v1/websocket', { params: { token } });

socket.connect();

const channel = socket.channel('agent:my-agent-123', { token });

channel.join().receive('ok', (resp) => console.log('joined', resp));

channel.push('send', {
  message: {
    message_id: crypto.randomUUID(),
    sender: { agent_id: 'my-agent-123' },
    recipient: { agent_id: 'other-agent', discovery: 'direct' },
    message_type: 'conversation',
    payload: { role: 'user', content: 'Hello from JS' }
  }
});

channel.on('ack', (ack) => {
  console.log('status', ack.status);
  console.log('cost', ack.cost_cents);
  console.log('remaining', ack.remaining_balance_cents);
});

# Register your agent
curl -X POST http://localhost:4001/v1/agents \\
  -H "Authorization: Bearer YOUR_API_KEY" \\
  -H "Content-Type: application/json" \\
  -d '{
    "agent_id": "curl-agent",
    "framework": "custom",
    "capabilities": ["monitoring"]
  }'

# Send a billable message
curl -X POST http://localhost:4001/v1/messages \\
  -H "Authorization: Bearer YOUR_API_KEY" \\
  -H "x-organization-id: YOUR_ORG_UUID" \\
  -H "Content-Type: application/json" \\
  -d '{
    "message_id": "550e8400-e29b-41d4-a716-446655440000",
    "sender": { "agent_id": "curl-agent" },
    "recipient": { "agent_id": "agent-123", "discovery": "direct" },
    "message_type": "task",
    "payload": { "description": "Run analysis" }
  }'

# Query delivery status
curl -X GET http://localhost:4001/v1/messages/550e8400-e29b-41d4-a716-446655440000 \\
  -H "Authorization: Bearer YOUR_API_KEY" \\
  -H "x-organization-id: YOUR_ORG_UUID"