Skip to content

agnusdei1207/opencode-orchestrator

Folders and files

NameName
Last commit message
Last commit date

Latest commit

Β 

History

572 Commits
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 
Β 

Repository files navigation

logo

OpenCode Orchestrator

Production-Grade Multi-Agent Orchestration Engine for High-Integrity Software Engineering

MIT License npm


⚑ Quick Start

npm install -g opencode-orchestrator

Inside an OpenCode environment:

/task "Implement a new authentication module with JWT and audit logs"


πŸš€ Engine Workflow

OpenCode Orchestrator utilizes a Hub-and-Spoke Topology with Work-Stealing Queues to execute complex engineering tasks through parallel, context-isolated sessions.

            [ User Task ]
                    β”‚
         β”Œβ”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β–Όβ”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”
         β”‚     COMMANDER       │◄───────────┐ (Loop Phase)
         β”‚  [Work-Stealing]    β”‚            β”‚
         β””β”€β”€β”€β”€β”€β”€β”€β”€β”¬β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”˜            β”‚
                  β”‚                         β”‚
         β”Œβ”€β”€β”€β”€β”€β”€β”€β”€β–Όβ”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”              β”‚
         β”‚      PLANNER      β”‚ (Todo.md)    β”‚
         β”‚  [Session Pool]   β”‚              β”‚
         β””β”€β”€β”€β”€β”€β”€β”€β”€β”¬β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”˜              β”‚
                  β”‚                         β”‚ (MVCC Atomic Sync)
     β”Œβ”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”Όβ”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”          β”‚
     β–Ό     (Isolated Session Pool)β–Ό          β”‚
[ Session A ] [ Session B ] [ Session C ]   β”‚
[  Worker   ] [  Worker   ] [  Reviewer ]   β”‚
β”‚ [Memory   ] β”‚ [Memory   ] β”‚ [Memory    β”‚  β”‚
β”‚  Pooling] β”‚ β”‚  Pooling] β”‚ β”‚  Pooling]  β”‚  β”‚
     β””β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”¬β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”˜          β”‚
                  β”‚                         β”‚
         β”Œβ”€β”€β”€β”€β”€β”€β”€β”€β–Όβ”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”              β”‚
         β”‚   MSVP MONITOR    β”‚β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”˜
         β”‚ [Adaptive Poll]   β”‚
         β””β”€β”€β”€β”€β”€β”€β”€β”€β”¬β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”˜
                  β”‚
         β”Œβ”€β”€β”€β”€β”€β”€β”€β”€β–Όβ”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”
         β”‚ QUALITY ASSURANCE β”‚
         β””β”€β”€β”€β”€β”€β”€β”€β”€β”¬β”€β”€β”€β”€β”€β”€β”€β”€β”€β”€β”˜
                  β”‚
            [ ✨COMPLETED ]

πŸ› οΈ Core Capabilities

πŸ”’ Atomic MVCC State Synchronization

The engine solves the "Concurrent TODO Update" problem using Multi-Version Concurrency Control (MVCC) + Mutex. Agents can safely mark tasks as complete in parallel without data loss or race conditions. Every state change is cryptographically hashed and logged for a complete audit trail.

🧩 Advanced Hook Orchestration

Execution flows are governed by a Priority-Phase Hook Registry. Hooks (Safety, UI, Protocol) are grouped into phases (early, normal, late) and executed using a Topological Sort to handle complex dependencies automatically, ensuring a predictable and stable environment.

πŸ›‘οΈ Autonomous Recovery

  • Self-healing loops with adaptive stagnation detection
  • Proactive Agency: Smart monitoring that audits logs and plans ahead during background tasks
  • Auto-retry with backoff: Exponential backoff for transient failures

🎯 State-Level Session Isolation

Reused sessions in the SessionPool are explicitly reset using server-side compaction triggered by health monitors. This ensures that previous task context (old error messages, stale file references) never leaks into new tasks, maintaining 100% implementation integrity.

πŸš€ Zero-Payload Turbo Mode

Leverages system.transform to unshift massive agent instruction sets on the server side. This reduces initial message payloads by 90%+, slashing latency and preventing context fragmentation during long autonomous loops.


πŸ› οΈ Infrastructure & Reliability

πŸ”’ Resource Safety & Reliability

  • RAII Pattern (ConcurrencyToken): Guaranteed resource cleanup with zero leaks
  • ShutdownManager: Priority-based graceful shutdown with 5-second timeout per handler
  • Automatic Backups: All config changes backed up with rollback support
  • Atomic File Operations: Temp file + rename for corruption-proof writes
  • Finally Blocks: Guaranteed cleanup in all critical paths
  • Zero Resource Leaks: File watchers, event listeners, concurrency slots all properly released

⚑ Performance Optimizations

  • Work-Stealing Queues: Chase-Lev deque implementation for 90%+ CPU utilization
    • Planner: 2 workers, Worker: 8 workers, Reviewer: 4 workers
    • LIFO for owner (cache locality), FIFO for thieves (fairness)
  • Memory Pooling: 80% GC pressure reduction
    • Object Pool: 200 ParallelTask instances (50 prewarmed)
    • String Interning: Deduplication for agent names, status strings
    • Buffer Pool: Reusable ArrayBuffers (1KB, 4KB, 16KB, 64KB)
  • Session Reuse: 90% faster session creation (500ms β†’ 50ms)
    • Pool size: 5 sessions per agent type
    • Max reuse: 10 times per session
    • Health check: Every 60 seconds
  • Rust Connection Pool: 10x faster tool calls (50-100ms β†’ 5-10ms)
    • Max 4 persistent processes
    • 30-second idle timeout
  • Adaptive Polling: Dynamic 500ms-5s intervals based on system load

πŸ›‘οΈ Safety Features

  • Circuit Breaker: Auto-recovery from API failures (5 failures β†’ open)
  • Resource Pressure Detection: Rejects low-priority tasks when memory > 80%
  • Terminal Node Guard: Prevents infinite recursion (depth limit enforcement)
  • Auto-Scaling: Concurrency slots adjust based on success/failure rate

πŸ› οΈ Key Innovations

🧠 Hierarchical Memory System

Maintains focus across thousands of conversation turns using a 4-tier memory structure and EMA-based Context Gating to preserve "Architectural Truth" while pruning operational noise.

Dynamic Concurrency Auto-Scaling

Slots for parallel implementation scale up automatically after a 3-success streak and scale down aggressively upon detection of API instability or implementation failures.

πŸ›‘οΈ Neuro-Symbolic Safety

Combines LLM reasoning with deterministic AST/LSP verification. Every code change is verified by native system tools before being accepted into the master roadmap.

πŸ”„ Adaptive Intelligence Loop

  • Stagnation Detection: Automatically senses when no progress is made across multiple iterations
  • Diagnostic Intervention: Forces the agent into a "Diagnostic Mode" when stagnation is detected, mandating log audits and strategy pivots
  • Proactive Agency: Mandates Speculative Planning and Parallel Thinking during background task execution

πŸ“Š Native TUI Integration

Seamless integration with OpenCode's native TUI via TaskToastManager. Provides non-intrusive, real-time feedback on Mission Progress, active Agent Sub-sessions, and Technical Metrics using protocol-safe Toast notifications.

⚑ Event-Driven Architecture

Utilizes a hybrid event-driven pipeline (EventHandler + TaskPoller) to maximize responsiveness while maintaining robust state tracking and resource cleanup.

πŸ”’ Secure Configuration

Runtime agent configuration is strictly validated using Zod schemas, ensuring that custom agent definitions in agents.json are type-safe and error-free before execution.


⚑ Elite Multi-Agent Swarm

Agent Expertise Capability
Commander Mission Hub Session pooling, parallel thread control, state rehydration, work-stealing coordination
Planner Architect Symbolic mapping, dependency research, roadmap generation, file-level planning
Worker Implementer High-throughput coding, TDD workflow, documentation, isolated file execution
Reviewer Auditor Rigid verification, LSP/Lint authority, integration testing, final mission seal

πŸ“ˆ Performance Benchmarks

Throughput & Efficiency

  • Concurrent Sessions: 50+ parallel agent sessions with work-stealing
  • CPU Utilization: 90%+ (up from 50-70%)
  • Tool Call Speed: 10x faster (5-10ms vs 50-100ms) via Rust connection pool
  • Session Creation: 90% faster (50ms vs 500ms) via session pooling
  • Processing Speed: 3-5x baseline throughput

Resource Efficiency

  • Memory Usage: 60% reduction (40% of baseline) via pooling
  • GC Pressure: 80% reduction via object/string/buffer pooling
  • Token Efficiency: 40% reduction via Incremental State & System Transform

Reliability

  • Sync Accuracy: 99.95% reliability via MVCC+Mutex transaction logic
  • Mission Survival: 100% uptime through plugin restarts via S.H.R (Self-Healing Rehydration)
  • Resource Leaks: Zero (guaranteed by RAII pattern)
  • Config Safety: 100% (atomic writes + auto-backup + rollback)

Scalability

  • Work-Stealing Efficiency: 80% improvement in parallel efficiency (50% β†’ 90%+)
  • Adaptive Polling: Dynamic 500ms-5s based on load
  • Auto-Scaling: Concurrency slots adjust automatically based on success rate

πŸ—οΈ Technical Stack

  • Runtime: Node.js 18+ (TypeScript)
  • Tools: Rust-based CLI tools (grep, glob, ast) via connection pool
  • Concurrency: Chase-Lev work-stealing deque + priority queues
  • Memory: Object pooling + string interning + buffer pooling
  • State Management: MVCC + Mutex
  • Safety: RAII pattern + circuit breaker + resource pressure detection

πŸ“š Documentation


πŸ”§ Installation & Configuration

Safe Installation

The installation process is production-safe with multiple protection layers:

  1. βœ… Never overwrites - always merges with existing config
  2. βœ… Automatic backups - timestamped, last 5 kept
  3. βœ… Atomic writes - temp file + rename (OS-level atomic)
  4. βœ… Write verification - ensures correctness after every change
  5. βœ… Automatic rollback - restores from backup on any failure
  6. βœ… Cross-platform - Windows (native, Git Bash, WSL), macOS, Linux

Configuration Logs

  • Unix: /tmp/opencode-orchestrator.log
  • Windows: %TEMP%\opencode-orchestrator.log

πŸ“„ License

MIT License - see LICENSE for details.


Built with ⚑ for production-grade autonomous software engineering