M2 Harness 🚀 — Cost-Aware Hierarchical Coding Agent & Context Firewall

M2 Harness is a high-throughput, cost-aware Autonomous Worker and Context Firewall architecture. It enables Frontier Reasoners (M1) (such as Claude 3.7 Sonnet, Gemini 2.0 Pro, GPT-4o, Cursor, or Google Antigravity) to delegate noisy, token-heavy tool loops (deep searches, test iterations, multi-file refactoring) to a Cheap Worker (M2) (DeepSeek V4-Flash, OpenCode Zen, Claude Haiku, or local Ollama), filtering raw context by 80%–98% (CCR) before returning verified structured evidence to M1.

🏛️ Comprehensive Architecture

flowchart TD
    User([User Prompt / IDE Action]) --> M1[M1 Frontier Reasoner & Orchestrator]
    
    subgraph M1_Layer ["M1 Frontier Cognitive Layer (Claude 3.7 / Gemini 2.0 Pro)"]
        M1 --> Router{Tri-Modal Execution Router}
    end

    subgraph Path_A ["Path A: Standard Delegated Worker (85%+ of Tasks)"]
        Router -->|Heavy Search / Multi-file / Tests| Runtime[M2 Authoritative Runtime State Machine]
        Runtime --> StateMachine[INIT ➔ EXECUTING ➔ VERIFYING ➔ COMPLETED]
        
        subgraph Worker_Subsystems ["M2 Worker Subsystems"]
            StateMachine --> L0[Zero-Token L0 Layer: Polyglot AST & Git Diff]
            StateMachine --> Sandbox[Execution Sandbox & Symlink Jail]
            StateMachine --> Memory[Active Working Memory: Facts / Hypotheses / Actions]
            StateMachine --> Firewall[Context Firewall & Budget Manager: 80-98% CCR]
            StateMachine --> Providers[Model-Agnostic Providers: DeepSeek / Zen / LiteLLM]
        end
        
        subgraph Hard_Gates ["Hard Verification Gates"]
            StateMachine --> Verifier[CompositeVerifier: Syntax / Tests / Lint / Scope]
            Verifier --> Integrity[IntegrityOracle: Anti-Tampering Guard]
        end
        
        Hard_Gates --> ResultContract[Structured ResultContract JSON]
    end

    subgraph Path_B ["Path B: Direct Precision Fallback"]
        Router -->|Subtle Race / Exact Bytecode / Review| DirectEdit[Direct Tool Execution & File Edits]
    end

    subgraph Path_C ["Path C: Autonomous Diagnostic Loop"]
        Router -->|Investigate Bug / TDD Repro| DiagnosticLoop[M2 Diagnostic Hypothesis Loop]
        DiagnosticLoop --> TestOracles[Independent Test & AST Oracles]
        TestOracles --> DiagnosticFix[Minimal Verified Patch]
    end

    subgraph Observability ["Observability & Event Bus"]
        EventBus[Canonical EventBus V2: 16 Lifecycle Events + Secret Redaction]
        Telemetry[Telemetry V2: P50-P99 Latency + M1/M2 Attribution + Cache Hit Rate]
        HUD[Live Webview HUD Dashboard :4040]
    end

    Runtime -.-> EventBus
    EventBus -.-> Telemetry
    EventBus -.-> HUD

    ResultContract --> Synthesis[M1 Final Synthesis & Structured User Response]
    DirectEdit --> Synthesis
    DiagnosticFix --> Synthesis

⚡ Tri-Modal Execution Flow

sequenceDiagram
    autonumber
    actor User
    participant M1 as M1 Frontier (Orchestrator)
    participant M2 as M2 Worker (Runtime Engine)
    participant L0 as Zero-Token L0 Tools
    participant Sandbox as Sandbox & Tools
    participant Gates as Hard Verification Gates
    participant Bus as Canonical EventBus

    User->>M1: "Refactor dispatcher to async and fix broken tests"
    M1->>Bus: TASK_CREATED
    M1->>M2: delegate_to_m2(task_description)
    
    M2->>L0: l0_ast_workspace_outline() [0 tokens]
    L0-->>M2: Module symbol tree
    M2->>Sandbox: Multi-turn tool execution (read/edit/test)
    Sandbox-->>M2: 50,000 chars raw terminal output
    
    M2->>M2: Context Firewall compresses output (97.4% CCR)
    M2->>Gates: CompositeVerifier (AST + Pytest + Diff Complexity)
    Gates-->>M2: Verified PASS (Score: 0.96, Integrity: Intact)
    
    M2->>Bus: TASK_COMPLETED (Redacted payload)
    M2-->>M1: ResultContract JSON (Status: SUCCESS, Confidence: 0.95, Evidence)
    M1-->>User: Final concise synthesis + Auto-collapsing trace

🌟 Core Pillars

💰 Token Economics & Benchmark Comparison

📦 Installation

pip install m2-harness

Or install in development mode from source:

git clone https://github.com/HamzaDevv/hierarchical-coding-agent.git
cd hierarchical-coding-agent
pip install -e ".[dev]"

🩺 Diagnostics (m2 doctor)

Verify your environment health, Tree-sitter parsers, sandbox containment, and providers in one sub-100ms command:

m2 doctor

=========================================================================
   🩺 M2 WORKER DIAGNOSTIC HEALTH REPORT (m2 doctor)                    
=========================================================================
  [✓ PASS] Python Environment     : Python 3.13.3 with all dependencies ready
  [✓ PASS] Git & Workspace        : Workspace writable and valid Git repository
  [✓ PASS] L0 AST Engine          : L0 zero-token AST parser operational
  [✓ PASS] Security Sandbox       : Execution sandbox path jail and env sanitization active
  [✓ PASS] LLM Providers          : Providers ready (Replay, Zen, DeepSeek, Gemini)
  [✓ PASS] Deterministic Replay   : Deterministic replay fixtures and schema v2.0 verified
-------------------------------------------------------------------------
  Summary: 6 Passed | 0 Warnings | 0 Failures
  Overall Status: ✅ READY FOR PRODUCTION
=========================================================================

Use --strict in CI/CD pipelines:

m2 doctor --strict --json

🚀 CLI Command Matrix

# 1. Execute an autonomous coding task
m2 "Find all references to ResultContract and outline their symbols"

# 2. Instant zero-token AST code outline (0 LLM tokens)
m2 outline

# 3. Instant zero-token git diff summary (0 LLM tokens)
m2 diff

# 4. Scaffold cognitive rule files (AGENTS.md, .cursorrules) into project
m2 init

# 5. Launch local Webview HUD live dashboard
m2 hud --port 4040

# 6. Replay a recorded execution trace 100% offline
m2 replay tests/replay/golden_task --mode semantic

# 7. Run M2-Bench benchmark evaluation
m2 bench run --suite dev --baselines C

# 8. Manage multi-provider configurations
m2 config set model deepseek/deepseek-chat
m2 config get

🔌 Model Context Protocol (FastMCP) Setup

M2 exposes a high-performance FastMCP server. Add it to your AI coding environment in seconds:

Claude Desktop / Claude Code (~/.claude.json or claude_desktop_config.json)

{
  "mcpServers": {
    "m2-worker-agent": {
      "command": "m2-mcp-server",
      "env": {
        "DEEPSEEK_API_KEY": "sk-...",
        "WORKSPACE_ROOT": "/path/to/your/project"
      }
    }
  }
}

Cursor (.cursor/mcp.json)

{
  "mcpServers": {
    "m2-worker-agent": {
      "command": "uvx",
      "args": ["--from", "m2-harness", "m2-mcp-server"],
      "env": {
        "DEEPSEEK_API_KEY": "sk-..."
      }
    }
  }
}

Google Antigravity (~/.gemini/settings.json)

{
  "mcpServers": {
    "m2-worker-agent": {
      "command": "m2-mcp-server",
      "env": {
        "WORKSPACE_ROOT": "${workspaceFolder}"
      }
    }
  }
}

🐍 Python SDK Quickstart

from m1_m2_agent import M1OrchestratorAgent, TaskContract

# Initialize Orchestrator
agent = M1OrchestratorAgent(workspace_root=".")

# Route and execute task through Context Firewall
result = agent.route_and_execute(
    objective="Analyze src/m1_m2_agent/events/bus.py and verify async subscription logic"
)

# Access structured result contract
print(f"Status: {result['contract']['status']}")
print(f"Confidence: {result['contract']['confidence']}")
print(f"Evidence: {result['contract']['evidence']}")

# Ingest telemetry KPIs
kpis = agent.get_telemetry_report()
print(f"Context Compression Ratio: {kpis['context_compression_ratio']}%")
print(f"P50 Latency: {kpis['latency_p50_s']}s")

📚 Technical Documentation

• 📐 Architecture Guide — System design, tri-modal paths, and L0 design
• ⚙️ Runtime & Event Subsystem — State machine lifecycle and canonical EventBus
• 🛡️ Context Firewall & Working Memory — Token compactor & structured memory
• ⚡ Deterministic Replay — Tri-level replay, versioned traces, semantic hashing
• 🧪 M2-Bench & Multi-Oracle Evaluation — Evaluator, oracles, anti-tampering
• 🌐 Model Providers Guide — Configuration for DeepSeek, OpenCode Zen, LiteLLM

📄 License

Licensed under the Apache License, Version 2.0.