Files
blackroad-operating-system/agents
Claude 1109603b3f Integrate LEITL Protocol and Cece Cognition Framework into agent system
This commit integrates the LEITL (Live Everyone In The Loop) Protocol and
Cece Cognition Framework into the BlackRoad agent ecosystem, enabling
multi-agent collaboration and advanced reasoning capabilities.

**Changes:**

1. **Cognition Router Integration** (`backend/app/routers/cognition.py`):
   - Fixed import path for orchestration service
   - Exposes full Cece Cognition Framework via REST API
   - Endpoints for single agent execution and multi-agent workflows
   - Supports sequential, parallel, and recursive execution modes

2. **Main App Updates** (`backend/app/main.py`):
   - Added cognition router to imports
   - Registered `/api/cognition` endpoints
   - Added Cognition tag to OpenAPI docs

3. **BaseAgent LEITL Integration** (`agents/base/agent.py`):
   - Added optional LEITL protocol support to base agent class
   - New methods: `enable_leitl()`, `disable_leitl()`, `_leitl_broadcast()`, `_leitl_heartbeat()`
   - Automatic event broadcasting during agent execution lifecycle
   - Events: task.started, task.completed, task.failed
   - Heartbeat support for session keep-alive

4. **AgentRegistry LEITL Support** (`agents/base/registry.py`):
   - Added `enable_leitl_for_all()` - Enable LEITL for all registered agents
   - Added `disable_leitl_for_all()` - Disable LEITL for all agents
   - Added `get_leitl_status()` - Get LEITL status and session IDs
   - Bulk agent session management

**Integration Architecture:**

```
User Request → Cognition API (/api/cognition)
                    ↓
          Orchestration Engine
                    ↓
       ┌────────────┴──────────┐
       ↓                       ↓
  Cece Agent              Other Agents
  (15-step reasoning)     (specialized)
       ↓                       ↓
  LEITL Protocol (if enabled)
       ↓
  Redis PubSub + WebSocket
       ↓
  Other active sessions
```

**New Capabilities:**

1. **Single Agent Execution**: POST /api/cognition/execute
   - Execute Cece, Wasp, Clause, or Codex individually
   - Full reasoning trace and confidence scores

2. **Multi-Agent Workflows**: POST /api/cognition/workflows
   - Orchestrate multiple agents in complex workflows
   - Sequential, parallel, or recursive execution
   - Shared memory and context across agents

3. **LEITL Collaboration**:
   - All agents can now broadcast their activity in real-time
   - Multi-agent sessions can see each other's work
   - Live activity feed via WebSocket
   - Session management with heartbeats

4. **Agent Registry**:
   - Bulk enable/disable LEITL for all agents
   - Query LEITL status across the agent ecosystem
   - Centralized session management

**Testing:**

-  All Python files compile successfully
-  Orchestration engine imports correctly
-  BaseAgent with LEITL integration works
-  AgentRegistry with LEITL support works
-  Cece agent imports and executes
2025-11-18 13:18:06 +00:00
..

BlackRoad Agent Library

The world's largest production-ready AI agent ecosystem.

Overview

The BlackRoad Agent Library contains 200+ pre-built, production-ready AI agents across 10 categories. Each agent is designed to be autonomous, composable, and enterprise-ready.

Agent Categories

🛠️ DevOps & Infrastructure (30 agents)

Agents for deployment, monitoring, infrastructure management, and site reliability.

💻 Software Engineering (30 agents)

Code generation, refactoring, testing, documentation, and debugging agents.

📊 Data & Analytics (25 agents)

Data processing, analysis, visualization, and reporting agents.

🔒 Security & Compliance (20 agents)

Security scanning, compliance checking, audit logging, and threat detection.

💰 Finance & Trading (20 agents)

Portfolio management, trading strategies, risk analysis, and financial reporting.

🎨 Creative & Content (20 agents)

Content generation, image processing, video editing, and creative automation.

🤝 Business Operations (20 agents)

CRM, project management, workflow automation, and business intelligence.

🔬 Research & Development (15 agents)

Experiment management, literature review, data collection, and hypothesis testing.

🌐 Web & API (15 agents)

Web scraping, API integration, data fetching, and webhook management.

🧠 AI & Machine Learning (15 agents)

Model training, inference, optimization, and ML pipeline management.

Architecture

agents/
├── README.md                 # This file
├── base/
│   ├── agent.py             # Base agent class
│   ├── executor.py          # Agent execution engine
│   ├── registry.py          # Agent discovery and registration
│   └── config.py            # Configuration management
├── categories/
│   ├── devops/              # DevOps agents
│   ├── engineering/         # Engineering agents
│   ├── data/                # Data agents
│   ├── security/            # Security agents
│   ├── finance/             # Finance agents
│   ├── creative/            # Creative agents
│   ├── business/            # Business agents
│   ├── research/            # Research agents
│   ├── web/                 # Web agents
│   └── ai_ml/               # AI/ML agents
├── templates/
│   └── agent_template.py    # Template for creating new agents
├── tests/
│   └── test_agents.py       # Comprehensive test suite
└── examples/
    └── quickstart.py        # Getting started examples

Quick Start

Using an Agent

from agents.registry import AgentRegistry
from agents.base.executor import AgentExecutor

# Initialize registry and executor
registry = AgentRegistry()
executor = AgentExecutor()

# Get an agent
agent = registry.get_agent('code-reviewer')

# Execute agent
result = executor.execute(agent, {
    'repository': 'blackboxprogramming/BlackRoad-Operating-System',
    'pr_number': 42
})

print(result)

Creating a Custom Agent

from agents.base.agent import BaseAgent

class MyCustomAgent(BaseAgent):
    """Custom agent for my specific use case."""

    def __init__(self):
        super().__init__(
            name='my-custom-agent',
            description='Does something amazing',
            category='custom',
            version='1.0.0'
        )

    async def execute(self, params):
        """Execute the agent logic."""
        # Your agent logic here
        return {
            'status': 'success',
            'data': 'Agent completed successfully'
        }

Agent Capabilities

Each agent includes:

  • Autonomous execution - Runs independently
  • Error handling - Robust error management
  • Logging - Comprehensive logging
  • Configuration - Environment-based config
  • Validation - Input/output validation
  • Monitoring - Built-in metrics and telemetry
  • Composability - Agents can call other agents
  • Retries - Automatic retry logic
  • Rate limiting - Built-in rate limiting
  • Caching - Intelligent caching strategies

Enterprise Features

Orchestration

The agent system includes an orchestration layer for:

  • Parallel execution - Run multiple agents concurrently
  • Dependency management - Define agent dependencies
  • Workflow pipelines - Chain agents together
  • Event-driven triggers - React to system events

Monitoring & Observability

  • Real-time metrics - Track agent performance
  • Distributed tracing - Trace agent execution
  • Error tracking - Centralized error monitoring
  • Audit logs - Complete execution history

Security

  • Authentication - Secure agent authentication
  • Authorization - Role-based access control
  • Encryption - Encrypted agent communication
  • Secrets management - Secure credential storage

Scaling to 1000+ Agents

The agent system is designed to scale:

  • Horizontal scaling - Distribute across multiple nodes
  • Load balancing - Automatic load distribution
  • Resource management - CPU/memory limits per agent
  • Queue management - Priority-based execution queues

API Integration

Agents integrate with the BlackRoad API:

# Expose agent via API
from fastapi import FastAPI
from agents.api import create_agent_router

app = FastAPI()
app.include_router(create_agent_router())

# POST /api/agents/{agent_name}/execute
# GET /api/agents (list all agents)
# GET /api/agents/{agent_name} (get agent details)

Documentation

Each agent includes:

  • README.md - Agent documentation
  • examples/ - Usage examples
  • tests/ - Unit tests
  • schema.json - Input/output schema

License

Proprietary - BlackRoad Corporation

Support

For agent-related questions: