flowchart TD
    K["UNIFIED SUPERVISOR<br/>single control plane"] --> B["JARVIS (Body)<br/>agents + tools + execution"]
    K --> P["JARVIS-Prime (Mind)<br/>routing + reasoning"]
    K --> R["ReactorCore (Forge)<br/>training + deployment gates"]

    B <--> P
    P --> R
    R --> P
    B --> R

    P --> T1["Tier 1: GCP Golden Image"]
    T1 -->|"degraded"| T2["Tier 2: Local Apple Silicon"]
    T2 -->|"degraded"| T3["Tier 3: API Fallback"]

    R --> G["Gate + Probation"]
    G -->|"pass"| P
    G -->|"fail"| RB["Rollback"]

flowchart TD
    U["UNIFIED SUPERVISOR<br/>Root Control Plane"] --> W["RootAuthorityWatcher<br/>Policy Brain"]
    U --> O["ProcessOrchestrator<br/>Execution Plane"]
    O --> P["JARVIS-Prime<br/>managed mode"]
    O --> R["Reactor-Core<br/>managed mode"]

    W -->|LifecycleVerdict| O
    O -->|ExecutionResult| W
    P -->|health + drain contract| W
    R -->|health + drain contract| W

    W --> H{"Handshake Gate"}
    H -->|"schema N/N-1 + capability hash pass"| READY["ALIVE/READY"]
    H -->|"contract mismatch"| REJECT["REJECTED"]

    W --> E["Escalation Engine"]
    E --> D["drain"]
    E --> T["SIGTERM"]
    E --> K["process-group SIGKILL"]

flowchart TD
    E["Single Entry Point<br/>python3 unified_supervisor.py"] --> S["Kernel Shell (thin)"]
    S --> R["Domain Controller Registry"]

    R --> L["Lifecycle Controller"]
    R --> H["Health Controller"]
    R --> W["Workflow Controller"]
    R --> M["Resource Controller"]
    R --> X["Self-Healing Controller"]
    R --> A["AGI/Training Controller"]

    L --> C["Contract Boundaries<br/>typed interfaces + DTOs"]
    H --> C
    W --> C
    M --> C
    X --> C
    A --> C

    C --> T["Isolated Domain Tests"]
    C --> O["Cross-Domain Observability"]

%%{init: {'theme': 'dark', 'themeVariables': { 'primaryColor': '#1a1b27', 'primaryTextColor': '#a9b1d6', 'primaryBorderColor': '#70a5fd', 'lineColor': '#545c7e', 'secondaryColor': '#24283b', 'tertiaryColor': '#1a1b27', 'fontSize': '14px', 'fontFamily': 'JetBrains Mono, monospace' }}}%%

flowchart TD
    KERNEL["<b>UNIFIED SUPERVISOR KERNEL</b><br/>Single Entry Point · 50K+ LOC<br/>7-Zone Parallel Initialization"]

    KERNEL -->|"orchestrates"| JARVIS
    KERNEL -->|"routes inference"| PRIME
    KERNEL -->|"triggers training"| REACTOR

    subgraph JARVIS["<b>JARVIS — The Body</b> &nbsp; Python / Rust / Swift &nbsp; :8010"]
        direction TB
        J1["🕸️ Neural Mesh<br/><i>16+ async agents · capability routing</i>"]
        J2["🎙️ Voice & Auth<br/><i>ECAPA-TDNN · full-duplex · wake word</i>"]
        J3["👁️ Vision & Spatial<br/><i>LLaVA · YOLO · Ghost Display · OCR</i>"]
        J4["🍎 macOS Native<br/><i>Swift 203 files · ObjC · Rust · CoreML</i>"]
        J5["🧠 Intelligence<br/><i>RAG · Ouroboros · Google Workspace</i>"]
    end

    subgraph PRIME["<b>JARVIS-Prime — The Mind</b> &nbsp; Python / GGUF &nbsp; :8000-8001"]
        direction TB
        P1["📡 Task-Type Router<br/><i>11 specialist models · 40.4 GB</i>"]
        P2["⚡ Neural Switchboard<br/><i>v98.1 · WebSocket contracts</i>"]
        P3["👁️ LLaVA Vision Server<br/><i>multimodal · OpenAI-compatible API</i>"]
        P4["💭 Reasoning Engine<br/><i>CoT / ToT / self-reflection</i>"]
        P5["📊 Telemetry Capture<br/><i>JSONL · deployment feedback loop</i>"]
    end

    subgraph REACTOR["<b>ReactorCore — The Forge</b> &nbsp; C++ / Python &nbsp; :8090"]
        direction TB
        R1["🔥 Training Pipeline<br/><i>LoRA · DPO · RLHF · FSDP</i>"]
        R2["🚪 Deployment Gate<br/><i>integrity validation · probation monitor</i>"]
        R3["🧬 Model Lineage<br/><i>full provenance chain · append-only JSONL</i>"]
        R4["☁️ GCP Spot Recovery<br/><i>checkpoint persistence · 60% cost savings</i>"]
        R5["⚙️ C++ Kernels<br/><i>CMake · pybind11 · native performance</i>"]
    end

    PRIME -.->|"telemetry + experiences"| REACTOR
    REACTOR -.->|"improved GGUF models"| PRIME
    JARVIS <-.->|"inference requests / responses"| PRIME
    REACTOR -.->|"training signals"| JARVIS

    style KERNEL fill:#1a1b27,stroke:#70a5fd,stroke-width:2px,color:#70a5fd
    style JARVIS fill:#0d1117,stroke:#70a5fd,stroke-width:2px,color:#a9b1d6
    style PRIME fill:#0d1117,stroke:#bf91f3,stroke-width:2px,color:#a9b1d6
    style REACTOR fill:#0d1117,stroke:#bb9af7,stroke-width:2px,color:#a9b1d6

%%{init: {'theme': 'dark', 'themeVariables': { 'primaryColor': '#1a1b27', 'primaryTextColor': '#a9b1d6', 'lineColor': '#545c7e', 'fontSize': '13px', 'fontFamily': 'JetBrains Mono, monospace' }}}%%

flowchart LR
    A["🎤 Voice Input"] --> B["JARVIS Kernel"]
    C["👁️ Screen Capture"] --> B
    D["⌨️ User Command"] --> B
    B --> E["JARVIS-Prime<br/><i>inference routing</i>"]
    E --> F{"Task Type?"}
    F -->|"math"| G["Qwen2.5-7B"]
    F -->|"code"| H["DeepCoder"]
    F -->|"vision"| I["LLaVA"]
    F -->|"simple"| J["Fast 2.2GB"]
    F -->|"complex"| K["Claude API"]
    G & H & I & J & K --> L["Response"]
    L --> B
    E -->|"telemetry"| M["ReactorCore"]
    M -->|"LoRA/DPO training"| N["Improved Model"]
    N -->|"deploy + probation"| E

    style B fill:#1a1b27,stroke:#70a5fd,stroke-width:2px,color:#70a5fd
    style E fill:#1a1b27,stroke:#bf91f3,stroke-width:2px,color:#bf91f3
    style M fill:#1a1b27,stroke:#bb9af7,stroke-width:2px,color:#bb9af7
    style F fill:#24283b,stroke:#545c7e,stroke-width:1px,color:#a9b1d6

%%{init: {'theme': 'dark', 'themeVariables': { 'primaryColor': '#1a1b27', 'primaryTextColor': '#a9b1d6', 'lineColor': '#545c7e', 'fontSize': '13px', 'fontFamily': 'JetBrains Mono, monospace' }}}%%

flowchart LR
    REQ["Inference Request"] --> T1
    T1["☁️ Tier 1: GCP Golden Image<br/><i>11 models · ~30s cold start</i>"]
    T1 -->|"unavailable"| T2["💻 Tier 2: Local Apple Silicon<br/><i>M1 Metal GPU · on-device</i>"]
    T2 -->|"resource constrained"| T3["🔑 Tier 3: Claude API<br/><i>emergency fallback</i>"]
    T1 -->|"✅ success"| RES["Response"]
    T2 -->|"✅ success"| RES
    T3 -->|"✅ success"| RES

    style T1 fill:#1a1b27,stroke:#70a5fd,stroke-width:2px,color:#70a5fd
    style T2 fill:#1a1b27,stroke:#bf91f3,stroke-width:2px,color:#bf91f3
    style T3 fill:#1a1b27,stroke:#bb9af7,stroke-width:2px,color:#bb9af7
    style REQ fill:#24283b,stroke:#545c7e,stroke-width:1px,color:#a9b1d6
    style RES fill:#24283b,stroke:#545c7e,stroke-width:1px,color:#a9b1d6

%%{init: {'theme': 'dark', 'themeVariables': { 'primaryColor': '#1a1b27', 'primaryTextColor': '#a9b1d6', 'lineColor': '#545c7e', 'fontSize': '13px', 'fontFamily': 'JetBrains Mono, monospace' }}}%%

flowchart TD
    AGENT["🤖 Google Workspace Agent<br/><i>execute_task()</i>"]

    AGENT -->|"7 event types"| EMIT["📡 _emit_autonomy_event()<br/><i>strict metadata schema</i>"]
    EMIT -->|"token-bucket<br/>rate limiter"| FWD["🔀 CrossRepoExperienceForwarder<br/><i>forward_autonomy_event()</i>"]

    FWD -->|"ExperienceEvent<br/>(type=METRIC)"| ING["🔬 AutonomyEventIngestor"]

    ING --> V{"Validate<br/>7 required keys?"}
    V -->|"❌ malformed"| Q["🗃️ Quarantine<br/><i>disk-based · 7d retention</i>"]
    V -->|"✅ valid"| D{"Deduplicate<br/>composite key?"}
    D -->|"duplicate"| SKIP["⏭️ Skip"]
    D -->|"unique"| CLS["🏷️ AutonomyEventClassifier"]

    CLS -->|"committed / failed"| TRAIN["🔥 UnifiedPipeline<br/><i>DPO / LoRA training</i>"]
    CLS -->|"infrastructure /<br/>excluded"| EXCLUDE["📊 Metrics Only<br/><i>no training</i>"]

    AGENT <-.->|"autonomy_policy /<br/>action_plan"| PRIME["💭 JARVIS-Prime<br/><i>policy gate</i>"]

    SUP["🛡️ Supervisor Boot"] -->|"check_autonomy_contracts()"| COMPAT{"Schema<br/>Compatible?"}
    COMPAT -->|"✅ pass"| FULL["Full Autonomy Mode"]
    COMPAT -->|"❌ mismatch"| RO["Read-Only Mode"]

    style AGENT fill:#1a1b27,stroke:#70a5fd,stroke-width:2px,color:#70a5fd
    style PRIME fill:#1a1b27,stroke:#bf91f3,stroke-width:2px,color:#bf91f3
    style ING fill:#1a1b27,stroke:#bb9af7,stroke-width:2px,color:#bb9af7
    style TRAIN fill:#1a1b27,stroke:#9ece6a,stroke-width:2px,color:#9ece6a
    style Q fill:#1a1b27,stroke:#f7768e,stroke-width:2px,color:#f7768e
    style SUP fill:#1a1b27,stroke:#e0af68,stroke-width:2px,color:#e0af68

%%{init: {'theme': 'dark', 'themeVariables': { 'primaryColor': '#1a1b27', 'primaryTextColor': '#a9b1d6', 'lineColor': '#545c7e', 'fontSize': '13px', 'fontFamily': 'JetBrains Mono, monospace' }}}%%

flowchart TD
    subgraph SPINE["Unified Event Spine (TrinityEventBus)"]
        FW["👁️ FileWatchGuard<br/><i>watchdog · repo root · debounce 0.3s</i>"]
        PYTEST["🧪 ouroboros_pytest_plugin<br/><i>.jarvis/test_results.json</i>"]
        GITHOOK["🔗 post-commit hook<br/><i>.jarvis/git_events.json</i>"]
        BRIDGES["🔌 Bus Bridges<br/><i>GapSignalBus · EventEmitter · EventChannel</i>"]
        TEB["📡 TrinityEventBus<br/><i>MQTT wildcards · priority queues · WAL · dedup</i>"]
        FW & PYTEST & GITHOOK & BRIDGES --> TEB
    end

    subgraph INTAKE["Zone 6.9 — Event-Driven Intake (sub-second)"]
        B["📋 BacklogSensor<br/><i>fs.changed → backlog.json · instant</i>"]
        T["🧪 TestFailureSensor<br/><i>fs.changed → test_results.json · streak ≥ 2</i>"]
        M["⛏️ OpportunityMiner<br/><i>fs.changed → scan_file() · instant</i>"]
        TODO["📝 TodoScanner<br/><i>fs.changed → scan_file() · instant</i>"]
        V["🎤 VoiceCommandSensor<br/><i>event-driven · always on</i>"]
    end

    subgraph GLS["Zone 6.8 — Governed Loop Service"]
        Q["📥 UnifiedIntakeRouter<br/><i>dedup · priority · human-ack</i>"]
        FSM["🔄 PreemptionFsmEngine<br/><i>IDLE→ACTIVE→PAUSED→TERMINAL</i>"]
        ORCH["🎯 Orchestrator<br/><i>CLASSIFY→ROUTE→EXPAND→GENERATE→VALIDATE→GATE→APPLY→VERIFY→COMPLETE</i>"]
        BUS["📡 SagaMessageBus<br/><i>passive observer · max 500 msgs · TTL 300s</i>"]
    end

    subgraph ROUTING["Adaptive 3-Tier Provider Cascade"]
        DW["🔵 Tier 0: DoubleWord 397B<br/><i>$0.10/$0.40/M · batch API · RateLimitService</i>"]
        CL["🟡 Tier 1: Claude Sonnet<br/><i>$3/$15/M · fallback only during DW downtime</i>"]
        FBACK["🔄 FailbackFSM<br/><i>FailureMode classify · recovery ETA · adaptive probes</i>"]
        DW -->|"timeout/429/5xx"| FBACK
        FBACK -->|"recovery window elapsed"| DW
        FBACK -->|"still in backoff"| CL
    end

    subgraph SAGA["B+ Saga Apply"]
        PRE["1. Preflight: clean worktree"]
        BR["2. Create ephemeral branch"]
        AP["3. Apply patch + commit"]
        LOCK["Two-Tier Lock<br/><i>asyncio.Lock + fcntl.flock</i>"]
        PROM["4. promote_all()<br/><i>git merge --ff-only</i>"]
    end

    TEB --> B & T & M & TODO & V
    B & T & M & TODO & V --> Q
    Q --> FSM --> ORCH
    ORCH -->|"GENERATE"| ROUTING
    DW & CL --> ORCH
    ORCH -->|"APPLY"| PRE
    PRE --> LOCK --> BR --> AP --> PROM
    PROM -->|"SAGA_SUCCEEDED"| BUS

    style SPINE fill:#0d1117,stroke:#7dcfff,stroke-width:2px,color:#a9b1d6
    style INTAKE fill:#0d1117,stroke:#70a5fd,stroke-width:2px,color:#a9b1d6
    style GLS fill:#0d1117,stroke:#bf91f3,stroke-width:2px,color:#a9b1d6
    style ROUTING fill:#0d1117,stroke:#e0af68,stroke-width:2px,color:#a9b1d6
    style SAGA fill:#0d1117,stroke:#9ece6a,stroke-width:2px,color:#a9b1d6
    style TEB fill:#1a1b27,stroke:#7dcfff,stroke-width:2px,color:#7dcfff
    style FBACK fill:#1a1b27,stroke:#f7768e,stroke-width:2px,color:#f7768e
    style LOCK fill:#1a1b27,stroke:#f7768e,stroke-width:2px,color:#f7768e

%%{init: {'theme': 'dark', 'themeVariables': { 'primaryColor': '#1a1b27', 'primaryTextColor': '#a9b1d6', 'lineColor': '#545c7e', 'fontSize': '13px', 'fontFamily': 'JetBrains Mono, monospace' }}}%%

flowchart LR
    REQ["Inference / Training Request"] --> ORCH["Hybrid Orchestrator"]
    ORCH --> SPOT["GCP Spot VM Pool<br/><i>primary cost-optimized execution</i>"]
    ORCH --> LOCAL["Local Apple Silicon Tier<br/><i>low-latency fallback</i>"]
    ORCH --> API["Claude API Tier<br/><i>emergency overflow</i>"]

    SPOT --> PREEMPT{"Preempted?"}
    PREEMPT -->|"no"| RUN["Run Workload"]
    PREEMPT -->|"yes"| RECOVER["Resume From Checkpoint"]
    RECOVER --> RUN

    RUN --> TELE["Telemetry + Cost Signals"]
    TELE --> ORCH
    RUN --> RES["Response / Model Artifact"]
    LOCAL --> RES
    API --> RES

    style ORCH fill:#1a1b27,stroke:#70a5fd,stroke-width:2px,color:#70a5fd
    style SPOT fill:#1a1b27,stroke:#bf91f3,stroke-width:2px,color:#bf91f3
    style LOCAL fill:#1a1b27,stroke:#7dcfff,stroke-width:2px,color:#7dcfff
    style API fill:#1a1b27,stroke:#bb9af7,stroke-width:2px,color:#bb9af7
    style PREEMPT fill:#24283b,stroke:#545c7e,stroke-width:1px,color:#a9b1d6

%%{init: {'theme': 'dark', 'themeVariables': { 'primaryColor': '#1a1b27', 'primaryTextColor': '#a9b1d6', 'lineColor': '#545c7e', 'fontSize': '13px', 'fontFamily': 'JetBrains Mono, monospace' }}}%%

flowchart LR
    SRC["Model + Runtime Source"] --> BUILD["Image Builder Pipeline"]
    BUILD --> BAKE["Bake Golden Image<br/><i>models + deps + startup contracts</i>"]
    BAKE --> VALIDATE["Validation Gate<br/><i>health, integrity, startup SLA</i>"]
    VALIDATE -->|"pass"| REG["Image Registry"]
    VALIDATE -->|"fail"| REJECT["Reject Build"]

    REG --> SCALE["Autoscaled GCP Inference Nodes"]
    SCALE --> PRIME["JARVIS-Prime Router"]
    PRIME --> MON["Observability + Drift Monitoring"]
    MON --> BUILD

    style BUILD fill:#1a1b27,stroke:#70a5fd,stroke-width:2px,color:#70a5fd
    style BAKE fill:#1a1b27,stroke:#bf91f3,stroke-width:2px,color:#bf91f3
    style VALIDATE fill:#1a1b27,stroke:#7dcfff,stroke-width:2px,color:#7dcfff
    style REG fill:#1a1b27,stroke:#bb9af7,stroke-width:2px,color:#bb9af7
    style REJECT fill:#1a1b27,stroke:#f7768e,stroke-width:2px,color:#f7768e

%%{init: {'theme': 'dark', 'themeVariables': { 'primaryColor': '#1a1b27', 'primaryTextColor': '#a9b1d6', 'lineColor': '#545c7e', 'fontSize': '13px', 'fontFamily': 'JetBrains Mono, monospace' }}}%%

flowchart TB
    subgraph CONTROL["🛡️ Control Plane"]
        C1["Policy Engine"]
        C2["Auth + Approval Gates"]
        C3["Secrets + Key Management"]
        C4["Kill Switch + Guardrails"]
    end

    subgraph DATA["📦 Data Plane"]
        D1["JARVIS Runtime Events"]
        D2["Redis + Cloud SQL State"]
        D3["ChromaDB / FAISS Memory"]
        D4["JSONL Telemetry + Lineage"]
    end

    subgraph MODEL["🧠 Model Plane"]
        M1["Prime Inference Router"]
        M2["Tiered Execution (GCP/Local/Claude)"]
        M3["Reactor Training Pipeline"]
        M4["Deployment Gate + Probation"]
    end

    CONTROL -->|"policy constraints"| DATA
    CONTROL -->|"permit / deny"| MODEL
    DATA -->|"context + telemetry"| MODEL
    MODEL -->|"decisions + artifacts"| DATA
    MODEL -->|"health + risk signals"| CONTROL

    style CONTROL fill:#0d1117,stroke:#70a5fd,stroke-width:2px,color:#a9b1d6
    style DATA fill:#0d1117,stroke:#bf91f3,stroke-width:2px,color:#a9b1d6
    style MODEL fill:#0d1117,stroke:#bb9af7,stroke-width:2px,color:#a9b1d6

%%{init: {'theme': 'dark', 'themeVariables': { 'primaryColor': '#1a1b27', 'primaryTextColor': '#a9b1d6', 'primaryBorderColor': '#70a5fd', 'lineColor': '#545c7e', 'secondaryColor': '#24283b', 'tertiaryColor': '#1a1b27', 'fontSize': '13px', 'fontFamily': 'JetBrains Mono, monospace' }}}%%

flowchart TB
    subgraph OBS["📊 UMA Observability"]
        Q["MemoryQuantizer<br/><i>system + process sampling</i>"]
        S["Frozen MemorySnapshot<br/><i>headroom, pressure tier, thrash state</i>"]
        Q --> S
    end

    subgraph BROKER["🧠 MemoryBudgetBroker"]
        B1["Lease Manager<br/><i>grant / deny / preempt</i>"]
        B2["Budget Engine<br/><i>tier multipliers + safety reserve</i>"]
        B3["Recovery Ledger<br/><i>epoch fencing + stale lease reclaim</i>"]
    end

    subgraph CONSUMERS["📦 Lease Holders"]
        M["Model Loaders<br/><i>LLM, vision, speaker ID</i>"]
        A["Agent Runtime<br/><i>mesh workers + queues</i>"]
        D["Ghost Display<br/><i>display:ghost@v1</i>"]
    end

    subgraph CONTROL["🖥️ DisplayPressureController"]
        C1["Policy State Machine<br/><i>one-step downgrade invariant</i>"]
        C2["Shedding Ladder<br/><i>1080p -> 900p -> 720p -> 576p -> off</i>"]
        C3["Flap Guards<br/><i>dwell, cooldown, rate limits</i>"]
    end

    S -->|"pressure tier + headroom"| B2
    B2 --> B1
    B3 --> B1
    B1 -->|"lease outcomes"| M
    B1 -->|"lease outcomes"| A
    B1 -->|"lease outcomes"| D

    B1 -->|"pressure signal"| C1
    C1 --> C2
    C2 -->|"resolution action"| D
    C1 --> C3
    C3 -->|"allow / delay"| C2

    D -->|"amend_lease_bytes"| B1
    B1 -->|"events + decisions"| T["Telemetry Pipeline"]
    T -->|"drift + anomaly feedback"| Q

    style OBS fill:#0d1117,stroke:#70a5fd,stroke-width:2px,color:#a9b1d6
    style BROKER fill:#0d1117,stroke:#bf91f3,stroke-width:2px,color:#a9b1d6
    style CONSUMERS fill:#0d1117,stroke:#bb9af7,stroke-width:2px,color:#a9b1d6
    style CONTROL fill:#0d1117,stroke:#7dcfff,stroke-width:2px,color:#a9b1d6
    style T fill:#24283b,stroke:#545c7e,stroke-width:1px,color:#a9b1d6

%%{init: {'theme': 'dark', 'themeVariables': { 'primaryColor': '#1a1b27', 'primaryTextColor': '#a9b1d6', 'lineColor': '#545c7e', 'fontSize': '13px', 'fontFamily': 'JetBrains Mono, monospace' }}}%%

flowchart LR
    IN["Incoming Action"] --> CLASS["Risk Classifier"]
    CLASS -->|"low risk"| AUTO["Auto Execute"]
    CLASS -->|"medium risk"| SAFE["Safe Mode + Limits"]
    CLASS -->|"high risk"| HITL["Human Approval Required"]

    SAFE --> EXEC["Controlled Execution"]
    HITL -->|"approved"| EXEC
    HITL -->|"denied"| BLOCK["Blocked + Logged"]

    EXEC --> MON["Runtime Monitor"]
    MON -->|"policy violation"| TRIP["Circuit Breaker Trip"]
    TRIP --> FB["Fallback Route / Degrade Gracefully"]
    MON -->|"healthy"| OK["Commit Result"]

    BLOCK --> AUD["Audit Trail"]
    FB --> AUD
    OK --> AUD

    style IN fill:#24283b,stroke:#545c7e,stroke-width:1px,color:#a9b1d6
    style CLASS fill:#1a1b27,stroke:#70a5fd,stroke-width:2px,color:#70a5fd
    style HITL fill:#1a1b27,stroke:#ffb86c,stroke-width:2px,color:#ffb86c
    style TRIP fill:#1a1b27,stroke:#f7768e,stroke-width:2px,color:#f7768e
    style AUD fill:#1a1b27,stroke:#bb9af7,stroke-width:2px,color:#bb9af7

%%{init: {'theme': 'dark', 'themeVariables': { 'primaryColor': '#1a1b27', 'primaryTextColor': '#a9b1d6', 'lineColor': '#545c7e', 'fontSize': '13px', 'fontFamily': 'JetBrains Mono, monospace' }}}%%

flowchart LR
    RUN["Live Inference + Agent Runtime"] --> OTEL["OpenTelemetry Traces/Metrics"]
    RUN --> LOGS["Structured JSONL Logs"]
    RUN --> COST["LangFuse + Helicone + PostHog"]

    OTEL --> HUB["Unified Observability Hub"]
    LOGS --> HUB
    COST --> HUB

    HUB --> ALERT["Anomaly/Regression Detection"]
    ALERT -->|"critical"| ROLLBACK["Auto Rollback / Gate Fail"]
    ALERT -->|"acceptable"| CURATE["Telemetry Curation"]

    CURATE --> TRAIN["Reactor Training (LoRA/DPO/RLHF)"]
    TRAIN --> GATE["Deployment Gate + Probation"]
    GATE -->|"pass"| PRIME["Prime Model Registry"]
    GATE -->|"fail"| ROLLBACK

    PRIME --> RUN

    style RUN fill:#1a1b27,stroke:#70a5fd,stroke-width:2px,color:#70a5fd
    style HUB fill:#1a1b27,stroke:#bf91f3,stroke-width:2px,color:#bf91f3
    style TRAIN fill:#1a1b27,stroke:#bb9af7,stroke-width:2px,color:#bb9af7
    style ROLLBACK fill:#1a1b27,stroke:#f7768e,stroke-width:2px,color:#f7768e