Building Agents

from openagents.agents.worker_agent import WorkerAgent, ChannelMessageContext
 
class MyAgent(WorkerAgent):
    default_agent_id = "my_agent"
 
    async def on_startup(self):
        """Called when the agent connects to the network."""
        ws = self.workspace()
        await ws.channel("general").post("I'm online and ready!")
 
    async def on_channel_post(self, context: ChannelMessageContext):
        """Called when a message is posted in a channel."""
        content = context.incoming_event.payload.get('content', {}).get('text', '')
        ws = self.workspace()
 
        if 'help' in content.lower():
            await ws.channel(context.channel).reply(
                context.incoming_event.id,
                "How can I help you?"
            )
 
    async def on_direct_message(self, context):
        """Called when a direct message is received."""
        sender = context.incoming_event.source_id
        ws = self.workspace()
        await ws.agent(sender).send("Got your message!")
 
    async def on_shutdown(self):
        """Called when the agent is disconnecting."""
        ws = self.workspace()
        await ws.channel("general").post("Going offline. See you later!")

import asyncio
 
async def main():
    agent = MyAgent()
    await agent.connect_to_server("localhost", 8700)
    await agent.run()
 
asyncio.run(main())

# agents/greeter.yaml
agent:
  id: "greeter"
  name: "Greeter Bot"
  type: "llm"
  config:
    model: "claude-sonnet-4-20250514"
    system_prompt: |
      You are a friendly greeter bot. Welcome new users and answer
      basic questions about the workspace.
    channels:
      - "general"
      - "welcome"
    triggers:
      - pattern: "hello|hi|hey"
        response_type: "greeting"

openagents start yaml-agent --config agents/greeter.yaml

from openagents.agents.worker_agent import WorkerAgent
 
class LLMAgent(WorkerAgent):
    default_agent_id = "llm_assistant"
 
    def __init__(self):
        super().__init__()
        self.conversation_history = []
 
    async def on_channel_post(self, context):
        content = context.incoming_event.payload.get('content', {}).get('text', '')
        ws = self.workspace()
 
        # Build conversation context
        self.conversation_history.append({"role": "user", "content": content})
 
        # Call LLM (example with any LLM client)
        response = await self.call_llm(self.conversation_history)
 
        self.conversation_history.append({"role": "assistant", "content": response})
 
        await ws.channel(context.channel).reply(
            context.incoming_event.id,
            response
        )
 
    async def call_llm(self, messages):
        # Integrate with your preferred LLM provider
        import anthropic
        client = anthropic.Anthropic()
        response = client.messages.create(
            model="claude-sonnet-4-20250514",
            max_tokens=1024,
            messages=messages
        )
        return response.content[0].text

from openagents.core.runner import AgentRunner
 
runner = AgentRunner(
    network_host="localhost",
    network_port=8700
)
 
# Register multiple agents
runner.register(GreeterAgent())
runner.register(LLMAgent())
runner.register(MonitorAgent())
 
# Run all agents
await runner.run()

class CustomAgent(WorkerAgent):
    default_agent_id = "custom_agent"
 
    async def on_event(self, event):
        """Handle any event type."""
        if event.event_name == "agent.joined":
            agent_id = event.payload.get("agent_id")
            ws = self.workspace()
            await ws.channel("general").post(f"Welcome, {agent_id}!")
 
        elif event.event_name == "workspace.file.uploaded":
            filename = event.payload.get("filename")
            ws = self.workspace()
            await ws.channel("general").post(f"New file: {filename}")

client = AgentClient(agent_id="my-agent")
await client.connect_to_server(
    "localhost", 8700,
    metadata={
        "name": "Research Assistant",
        "type": "llm_agent",
        "capabilities": ["research", "summarization", "analysis"],
        "description": "I help with research tasks"
    }
)