Merge remote-tracking branch 'origin/main' into test/enrich-prd-pipeline

# Conflicts:
#	auditor/audit.ts
#	auditor/checks/inference.ts
#	auditor/checks/kb_query.ts
#	auditor/claim_parser.ts
#	tests/real-world/scrum_master_pipeline.ts

Cargo.lock

@@ -46,7 +46,6 @@ dependencies = [
 name = "aibridge"
 version = "0.1.0"
 dependencies = [
- "async-trait",
  "axum",
  "reqwest",
  "serde",
@@ -4091,7 +4090,6 @@ dependencies = [
  "tracing",
  "tracing-opentelemetry",
  "tracing-subscriber",
- "truth",
  "vectord",
 ]
 
@@ -4680,7 +4678,6 @@ dependencies = [
  "chrono",
  "croner",
  "csv",
- "journald",
  "lopdf",
  "mysql_async",
  "object_store",
@@ -8729,16 +8726,6 @@ dependencies = [
  "wasm-bindgen",
 ]
 
-[[package]]
-name = "truth"
-version = "0.1.0"
-dependencies = [
- "serde",
- "serde_json",
- "tokio",
- "tracing",
-]
-
 [[package]]
 name = "try-lock"
 version = "0.2.5"
@@ -8932,7 +8919,6 @@ dependencies = [
  "object_store",
  "parquet 55.2.0",
  "queryd",
- "reqwest",
  "serde",
  "serde_json",
  "sha2",

Cargo.toml

@@ -14,7 +14,6 @@ members = [
     "crates/ui",
     "crates/lance-bench",
     "crates/vectord-lance",
-    "crates/truth",
 ]
 
 [workspace.dependencies]

config/routing.toml

@@ -1,61 +0,0 @@
-# Phase 40: Routing Engine Configuration
-#
-# Human-editable rules for model → provider routing.
-# Matching order: first match wins.
-
-[[rule]]
-model_pattern = "gpt-4*"
-provider = "openrouter"
-max_tokens = 4096
-temperature = 0.7
-
-[[rule]]
-model_pattern = "claude*"
-provider = "claude"
-max_tokens = 4096
-temperature = 0.7
-
-[[rule]]
-model_pattern = "gemini*"
-provider = "gemini"
-max_tokens = 8192
-temperature = 0.9
-
-[[rule]]
-model_pattern = "qwen3.5*"
-provider = "ollama"
-max_tokens = 4096
-temperature = 0.3
-
-[[rule]]
-model_pattern = "qwen3*"
-provider = "ollama"
-max_tokens = 2048
-temperature = 0.3
-
-[[rule]]
-model_pattern = "gpt-oss*"
-provider = "ollama"
-temperature = 0.1
-
-[[rule]]
-model_pattern = "*"
-provider = "ollama"
-temperature = 0.5
-
-# Fallback chain: if primary fails, try these in order
-fallback = ["ollama", "openrouter"]
-
-# Cost gating (tokens = cents per 1M)
-[cost]
-ollama = 0
-openrouter = 15
-claude = 15
-gemini = 0
-
-# Daily budget per provider (cents)
-[daily_budget]
-ollama = 0
-openrouter = 1000
-claude = 500
-gemini = 0

crates/aibridge/Cargo.toml

@@ -11,4 +11,3 @@ serde = { workspace = true }
 serde_json = { workspace = true }
 tracing = { workspace = true }
 reqwest = { version = "0.12", default-features = false, features = ["json", "rustls-tls"] }
-async-trait = "0.1"

crates/aibridge/src/continuation.rs

@@ -138,17 +138,6 @@ pub struct ContinuableOutcome {
     pub empty_retries: usize,
     pub continuations: usize,
     pub final_complete: bool,
-    /// Sum of `prompt_tokens` across every generator call made to
-    /// produce this outcome — including empty retries and continuations.
-    /// Lets callers (gateway execution loop, observability) stamp
-    /// accurate per-task usage without second-guessing the retry fan-out.
-    pub prompt_tokens: u32,
-    /// Sum of `completion_tokens` across every generator call.
-    pub completion_tokens: u32,
-    /// Total number of generator calls. `1 + empty_retries +
-    /// continuations` in the normal case; the field is explicit so
-    /// callers don't have to re-derive it.
-    pub calls: u32,
 }
 
 fn make_request(opts: &ContinuableOpts, prompt: String, current_max: u32) -> GenerateRequest {
@@ -186,17 +175,11 @@ pub async fn generate_continuable<G: TextGenerator>(
     let mut combined = String::new();
     let mut empty_retries = 0usize;
     let mut continuations = 0usize;
-    let mut prompt_tokens: u32 = 0;
-    let mut completion_tokens: u32 = 0;
-    let mut calls: u32 = 0;
 
     // Phase 21(a) — empty-response backoff loop.
     for retry in 0..opts.max_empty_retries {
         let req = make_request(opts, prompt.to_string(), current_max);
         let resp = generator.generate_text(req).await?;
-        calls += 1;
-        prompt_tokens = prompt_tokens.saturating_add(resp.tokens_evaluated.unwrap_or(0) as u32);
-        completion_tokens = completion_tokens.saturating_add(resp.tokens_generated.unwrap_or(0) as u32);
         if !resp.text.trim().is_empty() {
             combined = resp.text;
             break;
@@ -205,7 +188,9 @@ pub async fn generate_continuable<G: TextGenerator>(
         current_max = (current_max.saturating_mul(2)).min(opts.budget_cap);
     }
 
-    // Phase 21(b) — structural-completion continuation loop.
+    // Phase 21(b) — structural-completion continuation loop. Runs on
+    // the truncated-non-empty case; empty + exhausted retries falls
+    // through with empty combined and final_complete=false.
     for _ in 0..opts.max_continuations {
         if is_structurally_complete(&combined, opts.shape) {
             return Ok(ContinuableOutcome {
@@ -213,22 +198,17 @@ pub async fn generate_continuable<G: TextGenerator>(
                 empty_retries,
                 continuations,
                 final_complete: true,
-                prompt_tokens,
-                completion_tokens,
-                calls,
             });
         }
         if combined.trim().is_empty() {
             // Nothing to continue from — continuing "" is identical to
-            // the initial call and would loop.
+            // the initial call and would loop. Bail so the caller sees
+            // the failure rather than burning N extra calls.
             break;
         }
         let cont_prompt = continuation_prompt(prompt, &combined);
         let req = make_request(opts, cont_prompt, current_max.min(opts.budget_cap));
         let resp = generator.generate_text(req).await?;
-        calls += 1;
-        prompt_tokens = prompt_tokens.saturating_add(resp.tokens_evaluated.unwrap_or(0) as u32);
-        completion_tokens = completion_tokens.saturating_add(resp.tokens_generated.unwrap_or(0) as u32);
         combined.push_str(&resp.text);
         continuations += 1;
     }
@@ -239,9 +219,6 @@ pub async fn generate_continuable<G: TextGenerator>(
         empty_retries,
         continuations,
         final_complete,
-        prompt_tokens,
-        completion_tokens,
-        calls,
     })
 }
 

crates/aibridge/src/lib.rs

@@ -1,8 +1,5 @@
 pub mod client;
 pub mod context;
 pub mod continuation;
-pub mod provider;
-pub mod providers;
-pub mod routing;
 pub mod service;
 pub mod tree_split;

crates/aibridge/src/provider.rs

@@ -1,39 +0,0 @@
-use async_trait::async_trait;
-use crate::client::{GenerateRequest, GenerateResponse, EmbedRequest, EmbedResponse};
-
-#[async_trait]
-pub trait ProviderAdapter: Send + Sync {
-    /// Name for routing (ollama, openrouter, etc.)
-    fn name(&self) -> &str;
-
-    /// Chat completion — returns text, model, token counts
-    async fn chat(&self, req: GenerateRequest) -> Result<GenerateResponse, String>;
-
-    /// Embeddings — returns vectors, model, dimensions
-    async fn embed(&self, req: EmbedRequest) -> Result<EmbedResponse, String>;
-
-    /// Unload model from VRAM (optional, no-op if not supported)
-    async fn unload(&self, _model: &str) -> Result<(), String> {
-        Ok(())
-    }
-
-    /// Health check
-    async fn health(&self) -> Result<serde_json::Value, String>;
-}
-
-/// Routing key extracted from model name.
-/// - "qwen3.5:latest" → "ollama"
-/// - "openrouter/anthropic/claude-3.5-sonnet" → "openrouter"
-/// - "gpt-4o" → "ollama" (default)
-pub fn provider_key(model: &str) -> &'static str {
-    let lower = model.to_lowercase();
-    if lower.starts_with("openrouter/") {
-        "openrouter"
-    } else if lower.starts_with("gemini") {
-        "gemini"
-    } else if lower.starts_with("claude") {
-        "claude"
-    } else {
-        "ollama"  // default: local Ollama
-    }
-}

crates/aibridge/src/providers/mod.rs

@@ -1,2 +0,0 @@
-pub mod ollama;
-pub mod openrouter;

crates/aibridge/src/providers/ollama.rs

@@ -1,37 +0,0 @@
-use async_trait::async_trait;
-use crate::client::{AiClient, GenerateRequest, GenerateResponse, EmbedRequest, EmbedResponse};
-use crate::provider::ProviderAdapter;
-
-pub struct OllamaAdapter {
-    client: AiClient,
-}
-
-impl OllamaAdapter {
-    pub fn new(client: AiClient) -> Self {
-        Self { client }
-    }
-}
-
-#[async_trait]
-impl ProviderAdapter for OllamaAdapter {
-    fn name(&self) -> &str {
-        "ollama"
-    }
-
-    async fn chat(&self, req: GenerateRequest) -> Result<GenerateResponse, String> {
-        self.client.generate(req).await
-    }
-
-    async fn embed(&self, req: EmbedRequest) -> Result<EmbedResponse, String> {
-        self.client.embed(req).await
-    }
-
-    async fn unload(&self, model: &str) -> Result<(), String> {
-        let _: serde_json::Value = self.client.unload_model(model).await?;
-        Ok(())
-    }
-
-    async fn health(&self) -> Result<serde_json::Value, String> {
-        self.client.health().await
-    }
-}

crates/aibridge/src/providers/openrouter.rs

@@ -1,152 +0,0 @@
-use async_trait::async_trait;
-use reqwest::Client;
-use serde::{Deserialize, Serialize};
-use std::time::Duration;
-
-use crate::client::{GenerateRequest, GenerateResponse, EmbedRequest, EmbedResponse};
-use crate::provider::ProviderAdapter;
-
-pub struct OpenRouterAdapter {
-    client: Client,
-    base_url: String,
-    api_key: String,
-    default_model: String,
-}
-
-#[derive(Serialize)]
-struct OpenRouterChatRequest {
-    model: String,
-    messages: Vec<OpenRouterMessage>,
-    temperature: Option<f64>,
-    max_tokens: Option<u32>,
-}
-
-#[derive(Serialize)]
-struct OpenRouterMessage {
-    role: String,
-    content: String,
-}
-
-#[derive(Deserialize)]
-struct OpenRouterChatResponse {
-    choices: Vec<OpenRouterChoice>,
-    usage: OpenRouterUsage,
-    model: String,
-}
-
-#[derive(Deserialize)]
-struct OpenRouterChoice {
-    message: OpenRouterMessageOut,
-}
-
-#[derive(Deserialize)]
-#[allow(dead_code)]
-struct OpenRouterMessageOut {
-    role: String,
-    content: String,
-}
-
-#[derive(Deserialize)]
-#[allow(dead_code)]
-struct OpenRouterUsage {
-    prompt_tokens: Option<u32>,
-    completion_tokens: Option<u32>,
-    total_tokens: Option<u32>,
-}
-
-impl OpenRouterAdapter {
-    pub fn new(base_url: &str, api_key: String, default_model: &str) -> Self {
-        let client = Client::builder()
-            .timeout(Duration::from_secs(180))
-            .build()
-            .expect("failed to build HTTP client");
-        Self {
-            client,
-            base_url: base_url.trim_end_matches('/').to_string(),
-            api_key,
-            default_model: default_model.to_string(),
-        }
-    }
-
-    fn chat_model(&self, model: &str) -> String {
-        // Strip "openrouter/" prefix if present
-        let m = model.trim_start_matches("openrouter/");
-        if m.is_empty() || m == model {
-            self.default_model.clone()
-        } else {
-            m.to_string()
-        }
-    }
-
-    fn to_openrouter_messages(req: &GenerateRequest) -> Vec<OpenRouterMessage> {
-        let mut out = vec![];
-        if let Some(sys) = &req.system {
-            out.push(OpenRouterMessage { role: "system".into(), content: sys.clone() });
-        }
-        out.push(OpenRouterMessage {
-            role: "user".into(),
-            content: req.prompt.clone(),
-        });
-        out
-    }
-}
-
-#[async_trait]
-impl ProviderAdapter for OpenRouterAdapter {
-    fn name(&self) -> &str {
-        "openrouter"
-    }
-
-    async fn chat(&self, req: GenerateRequest) -> Result<GenerateResponse, String> {
-        let model = self.chat_model(req.model.as_deref().unwrap_or(""));
-        let or_req = OpenRouterChatRequest {
-            model: model.clone(),
-            messages: OpenRouterAdapter::to_openrouter_messages(&req),
-            temperature: req.temperature,
-            max_tokens: req.max_tokens,
-        };
-
-        let resp = self.client
-            .post(format!("{}/chat/completions", self.base_url))
-            .header("Authorization", format!("Bearer {}", self.api_key))
-            .header("Content-Type", "application/json")
-            .json(&or_req)
-            .send()
-            .await
-            .map_err(|e| format!("openrouter request failed: {e}"))?;
-
-        let status = resp.status();
-        let body = resp.text().await.unwrap_or_default();
-
-        if !status.is_success() {
-            return Err(format!("openrouter error ({}): {}", status, body));
-        }
-
-        let or_resp: OpenRouterChatResponse = serde_json::from_str(&body)
-            .map_err(|e| format!("openrouter parse error: {e}"))?;
-
-        let choice = or_resp.choices.into_iter().next()
-            .ok_or("no completion choice returned")?;
-        let usage = or_resp.usage;
-
-        Ok(GenerateResponse {
-            text: choice.message.content,
-            model: or_resp.model,
-            tokens_evaluated: usage.prompt_tokens.map(|n| n as u64),
-            tokens_generated: usage.completion_tokens.map(|n| n as u64),
-        })
-    }
-
-    async fn embed(&self, _req: EmbedRequest) -> Result<EmbedResponse, String> {
-        Err("openrouter: embed not implemented".into())
-    }
-
-    async fn health(&self) -> Result<serde_json::Value, String> {
-        // OpenRouter doesn't have a dedicated health endpoint,
-        // so we just return a healthy response if the client works.
-        Ok(serde_json::json!({
-            "status": "ok",
-            "provider": "openrouter",
-        }))
-    }
-}

crates/aibridge/src/routing.rs

@@ -1,93 +0,0 @@
-use serde::{Deserialize, Serialize};
-
-#[derive(Clone, Debug, Deserialize, Serialize)]
-pub struct RoutingRule {
-    pub model_pattern: String,
-    pub provider: String,
-    pub max_tokens: Option<u32>,
-    pub temperature: Option<f64>,
-}
-
-#[derive(Clone, Default)]
-pub struct RoutingEngine {
-    rules: Vec<RoutingRule>,
-    fallback_chain: Vec<String>,
-}
-
-impl RoutingEngine {
-    pub fn new() -> Self {
-        Self::default()
-    }
-
-    pub fn with_rules(mut self, rules: Vec<RoutingRule>) -> Self {
-        self.rules = rules;
-        self
-    }
-
-    pub fn with_fallback(mut self, chain: Vec<String>) -> Self {
-        self.fallback_chain = chain;
-        self
-    }
-
-    pub fn route(&self, model: &str) -> RouteDecision {
-        let lower = model.to_lowercase();
-
-        for rule in &self.rules {
-            if glob_match(&rule.model_pattern.to_lowercase(), &lower) {
-                return RouteDecision {
-                    provider: rule.provider.clone(),
-                    model: model.to_string(),
-                    max_tokens: rule.max_tokens,
-                    temperature: rule.temperature,
-                };
-            }
-        }
-
-        if let Some(first) = self.fallback_chain.first() {
-            RouteDecision {
-                provider: first.clone(),
-                model: model.to_string(),
-                max_tokens: None,
-                temperature: None,
-            }
-        } else {
-            RouteDecision {
-                provider: "ollama".to_string(),
-                model: model.to_string(),
-                max_tokens: None,
-                temperature: None,
-            }
-        }
-    }
-}
-
-#[derive(Clone, Debug)]
-pub struct RouteDecision {
-    pub provider: String,
-    pub model: String,
-    pub max_tokens: Option<u32>,
-    pub temperature: Option<f64>,
-}
-
-fn glob_match(pattern: &str, name: &str) -> bool {
-    if pattern.contains('*') {
-        let parts: Vec<&str> = pattern.split('*').collect();
-        if parts.len() == 2 {
-            return name.starts_with(parts[0]) && name.ends_with(parts[1]);
-        } else if parts.len() == 1 {
-            return name.starts_with(parts[0]) || name.ends_with(parts[1]);
-        }
-    }
-    pattern == name
-}
-
-impl Default for RoutingRule {
-    fn default() -> Self {
-        Self {
-            model_pattern: "*".to_string(),
-            provider: "ollama".to_string(),
-            max_tokens: None,
-            temperature: None,
-        }
-    }
-}

crates/catalogd/src/service.rs

@@ -31,10 +31,6 @@ pub fn router(registry: Registry) -> Router {
         // Phase 17: model profiles
         .route("/profiles", post(create_profile).get(list_profiles))
         .route("/profiles/{id}", get(get_profile).delete(delete_profile))
-        // Phase 41: profile-type routes
-        .route("/profiles/retrieval", get(list_retrieval_profiles))
-        .route("/profiles/memory", get(list_memory_profiles))
-        .route("/profiles/observer", get(list_observer_profiles))
         .with_state(registry)
 }
 
@@ -402,9 +398,6 @@ struct CreateProfileRequest {
     /// indexes to. Defaults to Parquet+HNSW.
     #[serde(default)]
     vector_backend: shared::types::VectorBackend,
-    /// Phase 41: Profile type for routing + activation behavior.
-    #[serde(default)]
-    profile_type: shared::types::ProfileType,
 }
 
 fn default_embed_model_req() -> String { "nomic-embed-text".to_string() }
@@ -424,7 +417,6 @@ async fn create_profile(
         created_by: req.created_by,
         bucket: req.bucket,
         vector_backend: req.vector_backend,
-        profile_type: req.profile_type,
     };
     match registry.put_profile(profile).await {
         Ok(p) => Ok((StatusCode::CREATED, Json(p))),
@@ -436,24 +428,6 @@ async fn list_profiles(State(registry): State<Registry>) -> impl IntoResponse {
     Json(registry.list_profiles().await)
 }
 
-async fn list_retrieval_profiles(State(registry): State<Registry>) -> impl IntoResponse {
-    let all = registry.list_profiles().await;
-    let retrieval: Vec<_> = all.into_iter().filter(|p| p.profile_type == shared::types::ProfileType::Retrieval).collect();
-    Json(retrieval)
-}
-
-async fn list_memory_profiles(State(registry): State<Registry>) -> impl IntoResponse {
-    let all = registry.list_profiles().await;
-    let memory: Vec<_> = all.into_iter().filter(|p| p.profile_type == shared::types::ProfileType::Memory).collect();
-    Json(memory)
-}
-
-async fn list_observer_profiles(State(registry): State<Registry>) -> impl IntoResponse {
-    let all = registry.list_profiles().await;
-    let observer: Vec<_> = all.into_iter().filter(|p| p.profile_type == shared::types::ProfileType::Observer).collect();
-    Json(observer)
-}
-
 async fn get_profile(
     State(registry): State<Registry>,
     Path(id): Path<String>,

crates/gateway/Cargo.toml

@@ -12,7 +12,6 @@ aibridge = { path = "../aibridge" }
 ingestd = { path = "../ingestd" }
 vectord = { path = "../vectord" }
 journald = { path = "../journald" }
-truth = { path = "../truth" }
 tokio = { workspace = true }
 axum = { workspace = true }
 serde = { workspace = true }

crates/gateway/src/access.rs

@@ -94,7 +94,6 @@ impl AccessControl {
     }
 
     /// Get an agent's role.
-    #[allow(dead_code)]
     pub async fn get_role(&self, agent: &str) -> Option<AgentRole> {
         self.roles.read().await.get(agent).cloned()
     }
@@ -114,7 +113,6 @@ impl AccessControl {
     }
 
     /// Determine which fields should be masked for an agent.
-    #[allow(dead_code)]
     pub async fn masked_fields(
         &self,
         agent: &str,
@@ -140,7 +138,6 @@ impl AccessControl {
     }
 
     /// Log a query for audit.
-    #[allow(dead_code)]
     pub async fn log_query(&self, audit: QueryAudit) {
         self.audit_log.write().await.push(audit);
     }
@@ -152,7 +149,6 @@ impl AccessControl {
         log[start..].iter().rev().cloned().collect()
     }
 
-    #[allow(dead_code)]
     pub fn is_enabled(&self) -> bool {
         self.enabled
     }

crates/gateway/src/auth.rs

@@ -5,51 +5,30 @@ use axum::{
     response::Response,
 };
 
-// API key auth middleware. Checks X-API-Key header against configured key.
-// Fixed P5-001 (2026-04-23): previously #[allow(dead_code)] — the function
-// existed but was never layered onto the router, so [auth] enabled=true
-// silently enforced nothing. Now wired via from_fn_with_state in main.rs.
+/// API key auth middleware. Checks X-API-Key header against configured key.
 pub async fn api_key_auth(
-    axum::extract::State(expected): axum::extract::State<ApiKey>,
     request: Request,
     next: Next,
 ) -> Result<Response, StatusCode> {
-    // /health stays public (LB/systemd probes). Every other route is gated.
-    if request.uri().path() == "/health" {
-        return Ok(next.run(request).await);
-    }
+    // Get the expected key from the request extensions (set by the layer)
+    let expected_key = request.extensions().get::<ApiKey>().cloned();
 
-    let provided = request
-        .headers()
-        .get("x-api-key")
-        .and_then(|v| v.to_str().ok());
+    if let Some(expected) = expected_key {
+        let provided = request
+            .headers()
+            .get("x-api-key")
+            .and_then(|v| v.to_str().ok());
 
-    // Constant-time-ish eq on the raw bytes; good enough for a shared-secret
-    // X-API-Key. Timing-attack resistance here matters less than the
-    // equivalent HMAC check would; adopt subtle crate if key-space grows.
-    match provided {
-        Some(key) if eq_ct(key.as_bytes(), expected.0.as_bytes()) => {
-            Ok(next.run(request).await)
-        }
-        _ => {
-            tracing::warn!(
-                path = %request.uri().path(),
-                "unauthorized request: missing or invalid API key",
-            );
-            Err(StatusCode::UNAUTHORIZED)
+        match provided {
+            Some(key) if key == expected.0 => {}
+            _ => {
+                tracing::warn!("unauthorized request: missing or invalid API key");
+                return Err(StatusCode::UNAUTHORIZED);
+            }
         }
     }
-}
 
-fn eq_ct(a: &[u8], b: &[u8]) -> bool {
-    if a.len() != b.len() {
-        return false;
-    }
-    let mut diff: u8 = 0;
-    for (x, y) in a.iter().zip(b.iter()) {
-        diff |= x ^ y;
-    }
-    diff == 0
+    Ok(next.run(request).await)
 }
 
 /// Wrapper type for the API key, stored in request extensions.

crates/gateway/src/execution_loop/kb_context.rs

@@ -1,388 +0,0 @@
-//! KB context loader — reads recent signal from `data/_kb/*.jsonl` for
-//! a given sig_hash + task_class and returns a compact summary.
-//!
-//! This is the "pipe to the overviewer" from the 2026-04-23 session:
-//! the overseer tier (T3, gpt-oss:120b) consumes this context before
-//! generating a correction, so its suggestions are informed by
-//! historical cost / latency / outcome / prior-correction patterns
-//! across ALL profiles that have run this task class — not just the
-//! single current loop.
-//!
-//! Hot-swap profiles read the SAME pool. When a profile activates and
-//! starts iterating, its KB context is the shared surface — one
-//! profile's learning becomes every profile's starting point.
-//!
-//! Best-effort throughout: missing files, corrupt rows, empty
-//! directories all produce an empty KbContext. The overseer works
-//! fine with no history; we just can't seed it then.
-
-use serde::Serialize;
-use std::path::Path;
-use tokio::io::AsyncBufReadExt;
-
-/// Compact summary returned to the overseer. Bounded size — recent
-/// outcomes + corrections plus rolled-up rates. Goal is to fit in a
-/// prompt without eating the overseer's context budget.
-#[derive(Debug, Clone, Default, Serialize)]
-pub struct KbContext {
-    pub sig_hash: String,
-    pub task_class: String,
-    pub recent_outcomes: Vec<OutcomeSummary>,
-    pub recent_corrections: Vec<CorrectionSummary>,
-    pub success_rate: Option<f64>,
-    pub avg_turns: Option<f64>,
-    pub avg_latency_ms: Option<u64>,
-    pub total_observed: u32,
-}
-
-#[derive(Debug, Clone, Serialize)]
-pub struct OutcomeSummary {
-    pub created_at: String,
-    pub ok: bool,
-    pub polarity: String,
-    pub turns: u32,
-    pub latency_ms: u64,
-    pub total_tokens: u64,
-    pub error: Option<String>,
-}
-
-#[derive(Debug, Clone, Serialize)]
-pub struct CorrectionSummary {
-    pub created_at: String,
-    pub reason: String,
-    pub correction_preview: String,   // first 300 chars
-    pub applied_at_turn: u32,
-}
-
-const OUTCOMES_PATH: &str = "data/_kb/outcomes.jsonl";
-const CORRECTIONS_PATH: &str = "data/_kb/overseer_corrections.jsonl";
-const RECENT_OUTCOME_LIMIT: usize = 5;
-const RECENT_CORRECTION_LIMIT: usize = 3;
-const AGGREGATE_WINDOW: usize = 50;
-
-impl KbContext {
-    /// Build context from the default KB paths.
-    pub async fn load_for(sig_hash: &str, task_class: &str) -> Self {
-        Self::load_from(
-            sig_hash, task_class,
-            Path::new(OUTCOMES_PATH), Path::new(CORRECTIONS_PATH),
-        ).await
-    }
-
-    /// Path-taking variant — tests inject tmp files without touching
-    /// the real KB directory (same pattern as append_outcomes_row_at).
-    pub async fn load_from(
-        sig_hash: &str,
-        task_class: &str,
-        outcomes_path: &Path,
-        corrections_path: &Path,
-    ) -> Self {
-        let mut ctx = KbContext {
-            sig_hash: sig_hash.to_string(),
-            task_class: task_class.to_string(),
-            ..Default::default()
-        };
-
-        // Scan outcomes — matches on sig_hash primary, task_class
-        // secondary (so different geos for the same task_class still
-        // contribute to aggregate rates even though they won't make
-        // the top-5 recent). The bounded window keeps scan cost
-        // linear in file size — we're reading tail only.
-        let outcome_rows = tail_matching(
-            outcomes_path, AGGREGATE_WINDOW * 4,
-            |row| {
-                let row_sig = row.get("sig_hash").and_then(|v| v.as_str()).unwrap_or("");
-                let row_tc = row.get("task_class").and_then(|v| v.as_str()).unwrap_or("");
-                row_sig == sig_hash || row_tc == task_class
-            },
-        ).await;
-
-        // Recent outcomes: exact sig_hash match first (strongest
-        // signal), then task_class fallback up to the limit.
-        let mut exact: Vec<OutcomeSummary> = Vec::new();
-        let mut loose: Vec<OutcomeSummary> = Vec::new();
-        for row in &outcome_rows {
-            let row_sig = row.get("sig_hash").and_then(|v| v.as_str()).unwrap_or("");
-            let summary = summarize_outcome(row);
-            if row_sig == sig_hash { exact.push(summary); }
-            else { loose.push(summary); }
-        }
-        ctx.recent_outcomes = exact.into_iter().rev().take(RECENT_OUTCOME_LIMIT).collect();
-        if ctx.recent_outcomes.len() < RECENT_OUTCOME_LIMIT {
-            let need = RECENT_OUTCOME_LIMIT - ctx.recent_outcomes.len();
-            ctx.recent_outcomes.extend(loose.into_iter().rev().take(need));
-        }
-
-        // Aggregate rates across the full matched window (both
-        // sig_hash and task_class matches — gives a stable rate even
-        // on sparse sig_hash history).
-        let window = outcome_rows.iter().rev().take(AGGREGATE_WINDOW);
-        let mut ok_count = 0u32;
-        let mut total = 0u32;
-        let mut turn_sum = 0u32;
-        let mut latency_sum = 0u64;
-        for row in window {
-            total += 1;
-            if row.get("ok").and_then(|v| v.as_bool()).unwrap_or(false) { ok_count += 1; }
-            turn_sum += row.get("turns").and_then(|v| v.as_u64()).unwrap_or(0) as u32;
-            latency_sum += row.get("usage")
-                .and_then(|u| u.get("latency_ms"))
-                .and_then(|v| v.as_u64()).unwrap_or(0);
-        }
-        if total > 0 {
-            ctx.total_observed = total;
-            ctx.success_rate = Some(ok_count as f64 / total as f64);
-            ctx.avg_turns = Some(turn_sum as f64 / total as f64);
-            ctx.avg_latency_ms = Some(latency_sum / total as u64);
-        }
-
-        // Overseer corrections. Prefer sig_hash match; fall back to
-        // task_class. The overseer reading its OWN prior corrections
-        // is the main point — if the last 3 attempts produced
-        // corrections X, Y, Z, the new correction should acknowledge
-        // those patterns rather than suggest X for the fourth time.
-        let correction_rows = tail_matching(
-            corrections_path, RECENT_CORRECTION_LIMIT * 4,
-            |row| {
-                let row_sig = row.get("sig_hash").and_then(|v| v.as_str()).unwrap_or("");
-                let row_tc = row.get("task_class").and_then(|v| v.as_str()).unwrap_or("");
-                row_sig == sig_hash || row_tc == task_class
-            },
-        ).await;
-        let mut c_exact: Vec<CorrectionSummary> = Vec::new();
-        let mut c_loose: Vec<CorrectionSummary> = Vec::new();
-        for row in &correction_rows {
-            let row_sig = row.get("sig_hash").and_then(|v| v.as_str()).unwrap_or("");
-            let summary = summarize_correction(row);
-            if row_sig == sig_hash { c_exact.push(summary); }
-            else { c_loose.push(summary); }
-        }
-        ctx.recent_corrections = c_exact.into_iter().rev().take(RECENT_CORRECTION_LIMIT).collect();
-        if ctx.recent_corrections.len() < RECENT_CORRECTION_LIMIT {
-            let need = RECENT_CORRECTION_LIMIT - ctx.recent_corrections.len();
-            ctx.recent_corrections.extend(c_loose.into_iter().rev().take(need));
-        }
-
-        ctx
-    }
-
-    /// Compact string form for the overseer prompt. Deterministic
-    /// ordering + bounded length so prompt caching stays stable
-    /// across iterations on the same task.
-    pub fn to_prompt_section(&self) -> String {
-        let mut s = String::new();
-        s.push_str("## Knowledge Base Context\n");
-        if let (Some(rate), Some(turns), Some(lat)) = (self.success_rate, self.avg_turns, self.avg_latency_ms) {
-            s.push_str(&format!(
-                "Across {} prior similar runs: success_rate={:.1}%, avg_turns={:.1}, avg_latency_ms={}\n",
-                self.total_observed, rate * 100.0, turns, lat,
-            ));
-        } else {
-            s.push_str("No prior similar runs recorded.\n");
-        }
-
-        if !self.recent_outcomes.is_empty() {
-            s.push_str(&format!("\nRecent {} outcomes:\n", self.recent_outcomes.len()));
-            for o in &self.recent_outcomes {
-                let err = o.error.as_deref().map(|e| format!(" — {}", truncate(e, 80))).unwrap_or_default();
-                s.push_str(&format!(
-                    "  [{}] ok={} turns={} tokens={} lat={}ms{}\n",
-                    &o.created_at[..19.min(o.created_at.len())],
-                    o.ok, o.turns, o.total_tokens, o.latency_ms, err,
-                ));
-            }
-        }
-
-        if !self.recent_corrections.is_empty() {
-            s.push_str(&format!("\nRecent {} overseer corrections (yours — don't repeat):\n", self.recent_corrections.len()));
-            for c in &self.recent_corrections {
-                s.push_str(&format!(
-                    "  [{}] turn={} reason={} correction={}\n",
-                    &c.created_at[..19.min(c.created_at.len())],
-                    c.applied_at_turn,
-                    truncate(&c.reason, 40),
-                    truncate(&c.correction_preview, 200),
-                ));
-            }
-        }
-
-        s
-    }
-}
-
-fn summarize_outcome(row: &serde_json::Value) -> OutcomeSummary {
-    OutcomeSummary {
-        created_at: row.get("created_at").and_then(|v| v.as_str()).unwrap_or("").to_string(),
-        ok: row.get("ok").and_then(|v| v.as_bool()).unwrap_or(false),
-        polarity: row.get("polarity").and_then(|v| v.as_str()).unwrap_or("").to_string(),
-        turns: row.get("turns").and_then(|v| v.as_u64()).unwrap_or(0) as u32,
-        latency_ms: row.get("usage").and_then(|u| u.get("latency_ms"))
-            .and_then(|v| v.as_u64()).unwrap_or(0),
-        total_tokens: row.get("usage").and_then(|u| u.get("total_tokens"))
-            .and_then(|v| v.as_u64()).unwrap_or(0),
-        error: row.get("error").and_then(|v| v.as_str()).map(String::from),
-    }
-}
-
-fn summarize_correction(row: &serde_json::Value) -> CorrectionSummary {
-    let preview = row.get("correction").and_then(|v| v.as_str()).unwrap_or("");
-    CorrectionSummary {
-        created_at: row.get("created_at").and_then(|v| v.as_str()).unwrap_or("").to_string(),
-        reason: row.get("reason").and_then(|v| v.as_str()).unwrap_or("").to_string(),
-        correction_preview: truncate(preview, 300),
-        applied_at_turn: row.get("applied_at_turn").and_then(|v| v.as_u64()).unwrap_or(0) as u32,
-    }
-}
-
-fn truncate(s: &str, n: usize) -> String {
-    if s.len() <= n { s.to_string() } else { format!("{}…", &s[..n]) }
-}
-
-/// Read a JSONL file from the tail, returning at most `limit` rows
-/// that match `filter`. Missing file returns empty. Corrupt lines are
-/// skipped. Limit is honored from the tail — a full-file scan with an
-/// in-memory ring would be wasteful for large outcomes histories, but
-/// we cap at reading the whole file and filtering post-hoc for now
-/// (reverse-seek line iteration is a real engineering task and the
-/// file is bounded by ingest rate; revisit when it bites).
-async fn tail_matching<F>(
-    path: &Path,
-    limit: usize,
-    filter: F,
-) -> Vec<serde_json::Value>
-where
-    F: Fn(&serde_json::Value) -> bool,
-{
-    let Ok(file) = tokio::fs::File::open(path).await else { return Vec::new(); };
-    let reader = tokio::io::BufReader::new(file);
-    let mut lines = reader.lines();
-    let mut matches: Vec<serde_json::Value> = Vec::new();
-    while let Ok(Some(line)) = lines.next_line().await {
-        let Ok(v) = serde_json::from_str::<serde_json::Value>(&line) else { continue };
-        if filter(&v) {
-            matches.push(v);
-            if matches.len() > limit {
-                // Keep the most-recent window only — drop from the
-                // front as we go rather than buffering everything.
-                matches.remove(0);
-            }
-        }
-    }
-    matches
-}
-
-#[cfg(test)]
-mod tests {
-    use super::*;
-    use tokio::io::AsyncWriteExt;
-
-    async fn write_fixture(path: &Path, rows: Vec<serde_json::Value>) {
-        if let Some(dir) = path.parent() {
-            tokio::fs::create_dir_all(dir).await.unwrap();
-        }
-        let mut f = tokio::fs::OpenOptions::new()
-            .create(true).write(true).truncate(true).open(path).await.unwrap();
-        for r in rows {
-            let mut line = serde_json::to_string(&r).unwrap();
-            line.push('\n');
-            f.write_all(line.as_bytes()).await.unwrap();
-        }
-    }
-
-    fn tmp_path(name: &str) -> std::path::PathBuf {
-        let nanos = std::time::SystemTime::now().duration_since(std::time::UNIX_EPOCH).unwrap().as_nanos();
-        std::env::temp_dir().join(format!("lh_kb_ctx_{}_{}_{}", std::process::id(), nanos, name))
-    }
-
-    #[tokio::test]
-    async fn empty_files_produce_empty_context() {
-        let op = tmp_path("outcomes.jsonl");
-        let cp = tmp_path("corrections.jsonl");
-        let ctx = KbContext::load_from("sig123", "staffing.fill", &op, &cp).await;
-        assert!(ctx.recent_outcomes.is_empty());
-        assert!(ctx.recent_corrections.is_empty());
-        assert!(ctx.success_rate.is_none());
-        assert_eq!(ctx.total_observed, 0);
-    }
-
-    #[tokio::test]
-    async fn exact_sig_hash_matches_take_priority() {
-        let op = tmp_path("outcomes.jsonl");
-        let cp = tmp_path("corrections.jsonl");
-        write_fixture(&op, vec![
-            // Other sig_hash, same task_class — loose match
-            serde_json::json!({
-                "sig_hash": "other", "task_class": "staffing.fill",
-                "ok": false, "polarity": "failure_pattern", "turns": 1,
-                "usage": {"latency_ms": 1000, "total_tokens": 100},
-                "created_at": "2026-04-22T10:00:00Z",
-            }),
-            // Exact sig_hash — should lead
-            serde_json::json!({
-                "sig_hash": "sig123", "task_class": "staffing.fill",
-                "ok": true, "polarity": "success_confirmation", "turns": 3,
-                "usage": {"latency_ms": 2000, "total_tokens": 500},
-                "created_at": "2026-04-23T10:00:00Z",
-            }),
-        ]).await;
-        write_fixture(&cp, vec![]).await;
-
-        let ctx = KbContext::load_from("sig123", "staffing.fill", &op, &cp).await;
-        assert_eq!(ctx.recent_outcomes.len(), 2);
-        assert_eq!(ctx.recent_outcomes[0].created_at, "2026-04-23T10:00:00Z");
-        assert_eq!(ctx.recent_outcomes[0].ok, true);
-        assert_eq!(ctx.total_observed, 2);
-        assert!((ctx.success_rate.unwrap() - 0.5).abs() < 0.001);
-    }
-
-    #[tokio::test]
-    async fn corrupt_rows_are_skipped() {
-        let op = tmp_path("outcomes.jsonl");
-        let cp = tmp_path("corrections.jsonl");
-        // Mix valid + invalid — invalid should be silently skipped.
-        if let Some(dir) = op.parent() { tokio::fs::create_dir_all(dir).await.unwrap(); }
-        tokio::fs::write(&op, "not json\n{\"sig_hash\":\"sig1\",\"task_class\":\"tc\",\"ok\":true,\"turns\":1,\"usage\":{}}\ngarbage\n").await.unwrap();
-        write_fixture(&cp, vec![]).await;
-        let ctx = KbContext::load_from("sig1", "tc", &op, &cp).await;
-        assert_eq!(ctx.recent_outcomes.len(), 1);
-    }
-
-    #[tokio::test]
-    async fn corrections_preview_is_truncated() {
-        let op = tmp_path("outcomes.jsonl");
-        let cp = tmp_path("corrections.jsonl");
-        let long = "x".repeat(500);
-        write_fixture(&op, vec![]).await;
-        write_fixture(&cp, vec![serde_json::json!({
-            "sig_hash": "sig1", "task_class": "tc",
-            "reason": "abort", "correction": long, "applied_at_turn": 3,
-            "created_at": "2026-04-23T10:00:00Z",
-        })]).await;
-        let ctx = KbContext::load_from("sig1", "tc", &op, &cp).await;
-        assert_eq!(ctx.recent_corrections.len(), 1);
-        // 300-char cap + 3-byte UTF-8 ellipsis character = 303-byte worst case.
-        assert!(ctx.recent_corrections[0].correction_preview.len() <= 303);
-    }
-
-    #[test]
-    fn prompt_section_is_stable_for_empty_context() {
-        let ctx = KbContext::default();
-        let s = ctx.to_prompt_section();
-        assert!(s.contains("No prior similar runs recorded"));
-    }
-
-    #[test]
-    fn prompt_section_reports_aggregate_rates() {
-        let ctx = KbContext {
-            total_observed: 10,
-            success_rate: Some(0.7),
-            avg_turns: Some(4.2),
-            avg_latency_ms: Some(45000),
-            ..Default::default()
-        };
-        let s = ctx.to_prompt_section();
-        assert!(s.contains("success_rate=70.0%"));
-        assert!(s.contains("avg_turns=4.2"));
-        assert!(s.contains("avg_latency_ms=45000"));
-    }
-}

crates/gateway/src/main.rs

@@ -1,7 +1,6 @@
 mod access;
 mod access_service;
 mod auth;
-mod execution_loop;
 mod observability;
 mod tools;
 mod v1;
@@ -154,11 +153,6 @@ async fn main() {
             agent_handle: agent_handle.clone(),
             index_registry: index_reg.clone(),
             schedules: sched_store,
-            // P9-001 fix 2026-04-23: journal reference flows into ingest so
-            // successful uploads emit a record_ingest event. Journal is Clone
-            // (Arc<RwLock> inside) so the /journal nest below still sees the
-            // same buffer + persistence.
-            journal: Some(journal.clone()),
         }))
         .nest("/vectors", vectord::service::router(vectord::service::VectorState {
             store: store.clone(),
@@ -224,19 +218,14 @@ async fn main() {
             },
         }));
 
-    // Auth middleware (if enabled) — P5-001 fix 2026-04-23:
-    // previously only inserted the ApiKey as an extension and never layered
-    // the middleware, so auth.enabled=true enforced nothing. Now wraps the
-    // router with from_fn_with_state, which calls api_key_auth on every
-    // request. /health is exempted inside the middleware (LB probes).
+    // Auth middleware (if enabled)
     if config.auth.enabled {
         if let Some(ref key) = config.auth.api_key {
-            tracing::info!("API key auth enabled — enforcing on all routes except /health");
+            tracing::info!("API key auth enabled");
             let api_key = auth::ApiKey(key.clone());
-            app = app.layer(axum::middleware::from_fn_with_state(
-                api_key,
-                auth::api_key_auth,
-            ));
+            app = app.layer(axum::Extension(api_key));
+            // Note: auth middleware applied per-route in production
+            // For now, the ApiKey extension is available for handlers to check
         } else {
             tracing::warn!("auth enabled but no api_key set — all requests allowed");
         }

crates/gateway/src/tools/registry.rs

@@ -67,7 +67,6 @@ pub struct ToolRegistry {
 }
 
 impl ToolRegistry {
-    #[allow(dead_code)]
     pub fn new() -> Self {
         let registry = Self {
             tools: Arc::new(RwLock::new(HashMap::new())),

crates/gateway/src/tools/service.rs

@@ -7,7 +7,7 @@ use axum::{
 };
 use serde::Deserialize;
 
-use super::registry::{ToolInvocation, ToolRegistry};
+use super::registry::{Permission, ToolInvocation, ToolRegistry};
 use crate::tools::ToolState;
 
 pub fn router(state: ToolState) -> Router {

crates/gateway/src/v1/mod.rs

@@ -14,8 +14,6 @@
 pub mod ollama;
 pub mod ollama_cloud;
 pub mod langfuse_trace;
-pub mod respond;
-pub mod truth;
 
 use axum::{
     Router,
@@ -48,25 +46,13 @@ pub struct Usage {
     pub prompt_tokens: u64,
     pub completion_tokens: u64,
     pub total_tokens: u64,
-    #[serde(default)]
-    pub by_provider: std::collections::HashMap<String, ProviderUsage>,
-}
-
-#[derive(Default, Clone, Serialize)]
-pub struct ProviderUsage {
-    pub requests: u64,
-    pub prompt_tokens: u64,
-    pub completion_tokens: u64,
-    pub total_tokens: u64,
 }
 
 pub fn router(state: V1State) -> Router {
     Router::new()
         .route("/chat", post(chat))
-        .route("/respond", post(respond::respond))
         .route("/usage", get(usage))
         .route("/sessions", get(sessions))
-        .route("/context", get(truth::context))
         .with_state(state)
 }
 
@@ -149,22 +135,18 @@ async fn chat(
     let start_time = chrono::Utc::now();
     let start_instant = std::time::Instant::now();
 
-    let (resp, used_provider) = match provider.as_str() {
-        "ollama" | "local" | "" => {
-            let r = ollama::chat(&state.ai_client, &req)
-                .await
-                .map_err(|e| (StatusCode::BAD_GATEWAY, format!("ollama local: {e}")))?;
-            (r, "ollama".to_string())
-        }
+    let resp = match provider.as_str() {
+        "ollama" | "local" | "" => ollama::chat(&state.ai_client, &req)
+            .await
+            .map_err(|e| (StatusCode::BAD_GATEWAY, format!("ollama local: {e}")))?,
         "ollama_cloud" | "cloud" => {
             let key = state.ollama_cloud_key.as_deref().ok_or((
                 StatusCode::SERVICE_UNAVAILABLE,
-                "OLLAMA_CLOUD_KEY not configured".to_string(),
+                "OLLAMA_CLOUD_KEY not configured — set env or populate /root/llm_team_config.json".to_string(),
             ))?;
-            let r = ollama_cloud::chat(key, &req)
+            ollama_cloud::chat(key, &req)
                 .await
-                .map_err(|e| (StatusCode::BAD_GATEWAY, format!("ollama cloud: {e}")))?;
-            (r, "ollama_cloud".to_string())
+                .map_err(|e| (StatusCode::BAD_GATEWAY, format!("ollama cloud: {e}")))?
         }
         other => {
             return Err((
@@ -186,7 +168,7 @@ async fn chat(
             .map(|c| c.message.content.clone())
             .unwrap_or_default();
         lf.emit_chat(langfuse_trace::ChatTrace {
-            provider: used_provider.clone(),
+            provider: provider.clone(),
             model: resp.model.clone(),
             input: req.messages.clone(),
             output,
@@ -201,19 +183,12 @@ async fn chat(
         });
     }
 
-    // Phase 40: per-provider usage tracking
     {
         let mut u = state.usage.write().await;
         u.requests += 1;
         u.prompt_tokens += resp.usage.prompt_tokens as u64;
         u.completion_tokens += resp.usage.completion_tokens as u64;
         u.total_tokens += resp.usage.total_tokens as u64;
-
-        let provider_usage = u.by_provider.entry(used_provider).or_default();
-        provider_usage.requests += 1;
-        provider_usage.prompt_tokens += resp.usage.prompt_tokens as u64;
-        provider_usage.completion_tokens += resp.usage.completion_tokens as u64;
-        provider_usage.total_tokens += resp.usage.total_tokens as u64;
     }
 
     Ok(Json(resp))

crates/gateway/src/v1/respond.rs

@@ -1,150 +0,0 @@
-//! `/v1/respond` — the **execution** API (distinct from `/v1/chat`, the
-//! completion API).
-//!
-//! This is the consolidation move called out in the 2026-04-23 session:
-//! lift the proven pipeline from `tests/multi-agent/orchestrator.ts`
-//! (executor → reviewer → escalate → validate → seal playbook →
-//! write-through to KB) into the gateway, so the production path has
-//! the intelligence the tests already proved.
-//!
-//! `/v1/chat` stays a naive completion proxy for callers that want one.
-//! `/v1/respond` is where the loop lives. Every orchestrator-style
-//! caller migrates here and the TS harnesses become thin clients.
-//!
-//! This file holds the HTTP surface + request/response shapes. The loop
-//! itself lives in `execution_loop::ExecutionLoop`.
-
-use axum::{extract::State, http::StatusCode, Json};
-use serde::{Deserialize, Serialize};
-
-use super::V1State;
-use crate::execution_loop::{ExecutionLoop, LogEntry, RespondOutcome};
-
-/// A structured task — mirrors `TaskSpec` in `tests/multi-agent/agent.ts`.
-/// Kept deliberately open so non-staffing task classes (code-gen,
-/// DevOps-long-horizon) can land without a schema fight.
-#[derive(Deserialize, Debug, Clone)]
-pub struct RespondRequest {
-    /// Task class — routes to the right truth rules + validator. For the
-    /// staffing substrate: `staffing.fill`, `staffing.rescue`,
-    /// `staffing.sms_draft`. Truth-layer lookup is a no-op until a rule
-    /// set is registered for the class.
-    pub task_class: String,
-
-    /// Human-readable operation description — becomes the playbook
-    /// `operation` field on seal, and the primary signal for
-    /// playbook_memory embedding.
-    pub operation: String,
-
-    /// Free-form structured context. Passed to the executor prompt and
-    /// to the playbook seeder. Staffing tasks expect
-    /// `{target_role, target_count, target_city, target_state, approach_hint}`
-    /// but nothing here validates that — the validator crate will (Phase 43).
-    #[serde(default)]
-    pub spec: serde_json::Value,
-
-    /// Executor model. Defaults to the hot-path local model if omitted.
-    /// See orchestrator.ts:28 (`EXECUTOR_MODEL = "qwen3.5:latest"`).
-    #[serde(default)]
-    pub executor_model: Option<String>,
-
-    /// Reviewer model. Defaults to the hot-path local reviewer.
-    /// See orchestrator.ts:29 (`REVIEWER_MODEL = "qwen3:latest"`).
-    #[serde(default)]
-    pub reviewer_model: Option<String>,
-
-    /// Hard cap on executor turns. Default matches orchestrator.ts:30
-    /// (`MAX_TURNS = 12`). Cloud escalation counts as a turn.
-    #[serde(default)]
-    pub max_turns: Option<u32>,
-}
-
-#[derive(Serialize)]
-pub struct RespondResponse {
-    /// `ok` = consensus reached, playbook sealed. `failed` = loop ran
-    /// out of turns or hit the drift cap. `blocked` = truth-layer
-    /// veto (Phase 42 rule citation in `error`).
-    pub status: &'static str,
-
-    /// The final artifact — for staffing fills, `{fills: [{candidate_id, name}]}`.
-    /// Empty on failure / block.
-    pub artifact: serde_json::Value,
-
-    /// Structured cross-turn log. Same shape as orchestrator.ts LogEntry
-    /// so existing tooling (kb extractors, fact_extractor.ts) reads it
-    /// without change.
-    pub log: Vec<LogEntry>,
-
-    /// Iteration count actually used. ≤ max_turns. Stamped on
-    /// outcomes.jsonl per the indicator audit (2026-04-23).
-    pub iterations: u32,
-
-    /// Error message on non-ok status. Truth-rule citations land here
-    /// when `status == "blocked"`.
-    #[serde(default, skip_serializing_if = "Option::is_none")]
-    pub error: Option<String>,
-}
-
-pub async fn respond(
-    State(state): State<V1State>,
-    Json(req): Json<RespondRequest>,
-) -> Result<Json<RespondResponse>, (StatusCode, String)> {
-    if req.operation.is_empty() {
-        return Err((StatusCode::BAD_REQUEST, "operation must be non-empty".into()));
-    }
-    if req.task_class.is_empty() {
-        return Err((StatusCode::BAD_REQUEST, "task_class must be non-empty".into()));
-    }
-
-    let mut loop_runner = ExecutionLoop::new(state, req);
-    let outcome = loop_runner.run().await.map_err(|e| {
-        (StatusCode::INTERNAL_SERVER_ERROR, format!("execution loop: {e}"))
-    })?;
-
-    let (status, error) = match &outcome {
-        RespondOutcome::Ok { .. } => ("ok", None),
-        RespondOutcome::Failed { reason, .. } => ("failed", Some(reason.clone())),
-        RespondOutcome::Blocked { reason, .. } => ("blocked", Some(reason.clone())),
-    };
-
-    Ok(Json(RespondResponse {
-        status,
-        artifact: outcome.artifact(),
-        log: outcome.into_log(),
-        iterations: loop_runner.turns_used(),
-        error,
-    }))
-}
-
-#[cfg(test)]
-mod tests {
-    use super::*;
-
-    #[test]
-    fn respond_request_parses_minimal() {
-        let raw = r#"{
-            "task_class": "staffing.fill",
-            "operation": "fill: Welder x2 in Toledo, OH"
-        }"#;
-        let r: RespondRequest = serde_json::from_str(raw).unwrap();
-        assert_eq!(r.task_class, "staffing.fill");
-        assert_eq!(r.executor_model, None);
-        assert_eq!(r.max_turns, None);
-    }
-
-    #[test]
-    fn respond_request_parses_full() {
-        let raw = r#"{
-            "task_class": "staffing.fill",
-            "operation": "fill: Welder x2 in Toledo, OH",
-            "spec": {"target_role": "Welder", "target_count": 2, "target_city": "Toledo", "target_state": "OH"},
-            "executor_model": "qwen3.5:latest",
-            "reviewer_model": "qwen3:latest",
-            "max_turns": 12
-        }"#;
-        let r: RespondRequest = serde_json::from_str(raw).unwrap();
-        assert_eq!(r.executor_model.as_deref(), Some("qwen3.5:latest"));
-        assert_eq!(r.max_turns, Some(12));
-        assert_eq!(r.spec["target_count"], 2);
-    }
-}

crates/gateway/src/v1/truth.rs

@@ -1,49 +0,0 @@
-use axum::{routing::get, Router};
-use serde::Serialize;
-use truth::default_truth_store;
-
-#[allow(dead_code)]
-pub fn truth_router() -> Router {
-    Router::new()
-        .route("/context", get(context))
-}
-
-#[derive(Serialize)]
-pub struct ContextResponse {
-    pub task_classes: Vec<String>,
-    pub rules: Vec<RuleInfo>,
-}
-
-#[derive(Serialize)]
-pub struct RuleInfo {
-    pub id: String,
-    pub task_class: String,
-    pub description: String,
-}
-
-pub async fn context() -> axum::Json<ContextResponse> {
-    let store = default_truth_store();
-    
-    let task_classes: Vec<String> = vec![
-        "staffing.fill".to_string(),
-        "staffing.rescue".to_string(),
-        "staffing.sms_draft".to_string(),
-        "staffing.any".to_string(),
-    ];
-    
-    let mut rules = Vec::new();
-    for tc in &task_classes {
-        for rule in store.get_rules(tc) {
-            rules.push(RuleInfo {
-                id: rule.id.clone(),
-                task_class: rule.task_class.clone(),
-                description: rule.description.clone(),
-            });
-        }
-    }
-    
-    axum::Json(ContextResponse {
-        task_classes,
-        rules,
-    })
-}

crates/ingestd/Cargo.toml

@@ -8,7 +8,6 @@ shared = { path = "../shared" }
 storaged = { path = "../storaged" }
 catalogd = { path = "../catalogd" }
 vectord = { path = "../vectord" }
-journald = { path = "../journald" }
 tokio = { workspace = true }
 axum = { workspace = true, features = ["multipart"] }
 lopdf = { workspace = true }

crates/ingestd/src/schema_evolution.rs

@@ -2,11 +2,9 @@
 /// When a source changes format (columns renamed, added, removed, type changed),
 /// the system detects the diff and can auto-map using AI or heuristic matching.
 
-#[allow(unused_imports)]
 use arrow::datatypes::{DataType, Schema, SchemaRef};
 use serde::{Deserialize, Serialize};
 use std::collections::HashMap;
-#[allow(unused_imports)]
 use std::sync::Arc;
 
 /// A detected change between two schema versions.

crates/ingestd/src/service.rs

@@ -1,4 +1,3 @@
-#[allow(unused_imports)]
 use axum::{
     Json, Router,
     extract::{Multipart, Path, Query, State},
@@ -34,11 +33,6 @@ pub struct IngestState {
     /// Scheduled-ingest registry. The scheduler task runs against this
     /// store; HTTP CRUD endpoints write through it.
     pub schedules: schedule::ScheduleStore,
-    /// Event journal for ADR-012 mutation history. Optional for back-compat
-    /// with callers (like scheduled ingest tests) that don't wire it yet.
-    /// When present, successful ingests emit a record_ingest event — closes
-    /// P9-001 on the file-upload path. (2026-04-23)
-    pub journal: Option<journald::journal::Journal>,
 }
 
 /// Push `DatasetAppended` triggers for every HNSW index bound to this
@@ -142,22 +136,6 @@ async fn ingest_file(
         Ok(result) => {
             if !result.deduplicated {
                 notify_agent_on_append(&state, &result.dataset_name).await;
-                // P9-001 fix (2026-04-23): emit a mutation event on every
-                // non-deduplicated ingest. Dedup no-ops don't need events
-                // (ADR-020 register() is already idempotent on same fingerprint).
-                if let Some(ref journal) = state.journal {
-                    if let Err(e) = journal.record_ingest(
-                        &result.dataset_name,
-                        result.rows as usize,
-                        "ingest_api",
-                        &filename,
-                    ).await {
-                        tracing::warn!(
-                            "journal record_ingest failed for '{}': {}",
-                            result.dataset_name, e,
-                        );
-                    }
-                }
             }
             if result.deduplicated {
                 Ok((StatusCode::OK, Json(result)))
@@ -652,108 +630,3 @@ async fn run_schedule_now(
     }
     Ok(Json(outcome))
 }
-
-// ─── Tests ───
-
-#[cfg(test)]
-mod journal_integration_tests {
-    //! P9-001 integration test: prove that a successful ingest produces a
-    //! journal.record_ingest event. Block 2 on PR #10 was "journal event
-    //! verified live" being unbacked by the diff. This test makes the
-    //! verification committed and reproducible.
-
-    use journald::journal::{Event, Journal};
-    use object_store::memory::InMemory;
-    use std::sync::Arc;
-
-    // Helper: build a bare Journal against an in-memory object store.
-    // Flush threshold 1 so every recorded event is persisted immediately.
-    fn test_journal() -> Journal {
-        let store: Arc<dyn object_store::ObjectStore> = Arc::new(InMemory::new());
-        Journal::new(store, 1)
-    }
-
-    #[tokio::test]
-    async fn journal_record_ingest_increments_counter() {
-        // Arrange — fresh journal, counter starts at zero.
-        let journal = test_journal();
-        let stats0 = journal.stats().await;
-        assert_eq!(stats0.total_events_created, 0);
-        assert_eq!(stats0.buffer_events, 0);
-
-        // Act — simulate what the /ingest/file success path does.
-        journal
-            .record_ingest("test_dataset", 42, "ingest_api", "probe.csv")
-            .await
-            .expect("record_ingest should succeed");
-
-        // Assert — counter advanced, event exists. With threshold=1 the
-        // event flushed to store; with threshold>N it would be in-buffer.
-        let stats1 = journal.stats().await;
-        assert_eq!(stats1.total_events_created, 1, "counter should reflect one recorded event");
-
-        // Assert — the event is retrievable by entity.
-        let history = journal
-            .get_entity_history("batch:42")
-            .await
-            .expect("history lookup");
-        assert_eq!(history.len(), 1, "one event should be visible in history");
-        let ev = &history[0];
-        assert_eq!(ev.action, "ingest");
-        assert_eq!(ev.entity_type, "test_dataset");
-        assert_eq!(ev.actor, "ingest_api");
-        assert!(
-            ev.new_value.contains("probe.csv"),
-            "new_value should carry source filename, got: {}",
-            ev.new_value
-        );
-    }
-
-    #[tokio::test]
-    async fn optional_journal_field_none_is_valid_back_compat() {
-        // IngestState.journal is Option<Journal>. Back-compat path: when
-        // the field is None, the ingest handler MUST still succeed — the
-        // journal call is fire-and-forget, never load-bearing.
-        //
-        // This test asserts the type shape: Option<Journal> is what we
-        // expect. If a refactor makes it mandatory, this test forces an
-        // explicit re-consideration.
-        let none_journal: Option<Journal> = None;
-        assert!(none_journal.is_none());
-
-        let some_journal: Option<Journal> = Some(test_journal());
-        assert!(some_journal.is_some());
-    }
-
-    #[tokio::test]
-    async fn journal_record_event_fields_match_adr_012_schema() {
-        // ADR-012 locks the event schema: entity_type, entity_id, field,
-        // action, old_value, new_value, actor, source, workspace_id plus
-        // the auto-assigned event_id + timestamp. This test pins the
-        // field names so a future refactor can't silently drop one.
-        let journal = test_journal();
-        let base = Event {
-            event_id: String::new(),
-            timestamp: chrono::Utc::now(),
-            entity_type: "candidate".into(),
-            entity_id: "CAND-0001".into(),
-            field: "phone".into(),
-            action: "update".into(),
-            old_value: "555-0000".into(),
-            new_value: "555-9999".into(),
-            actor: "recruiter".into(),
-            source: "api".into(),
-            workspace_id: "ws-x".into(),
-        };
-        journal.record(base).await.expect("record should accept full-schema event");
-        let h = journal
-            .get_entity_history("CAND-0001")
-            .await
-            .expect("lookup");
-        assert_eq!(h.len(), 1);
-        assert_eq!(h[0].field, "phone");
-        assert_eq!(h[0].old_value, "555-0000");
-        assert_eq!(h[0].new_value, "555-9999");
-        assert_eq!(h[0].workspace_id, "ws-x");
-    }
-}

crates/journald/src/journal.rs

@@ -5,7 +5,7 @@
 /// Storage: events buffer in memory, flush to Parquet periodically.
 /// Query: load Parquet files, filter by entity/field/actor/time.
 
-use arrow::array::{ArrayRef, RecordBatch, StringArray};
+use arrow::array::{ArrayRef, RecordBatch, StringArray, UInt64Array};
 use arrow::datatypes::{DataType, Field, Schema};
 use chrono::{DateTime, Utc};
 use object_store::ObjectStore;

crates/queryd/src/service.rs

@@ -9,6 +9,7 @@ use axum::{
 };
 use serde::{Deserialize, Serialize};
 
+use crate::cache::CacheStats;
 use crate::context::QueryEngine;
 use crate::delta;
 use crate::paged::ResultStore;

crates/queryd/src/workspace.rs

@@ -2,12 +2,15 @@
 /// Each workspace tracks an agent's activity on a specific contract or search,
 /// with daily/weekly/monthly tiers and instant handoff capability.
 
+use arrow::array::{ArrayRef, RecordBatch, StringArray, Int64Array};
+use arrow::datatypes::{DataType, Field, Schema};
 use chrono::{DateTime, Utc};
 use serde::{Deserialize, Serialize};
 use std::collections::HashMap;
 use std::sync::Arc;
 use tokio::sync::RwLock;
 
+use crate::delta;
 use object_store::ObjectStore;
 
 /// Retention tier for workspace data.

crates/shared/src/types.rs

@@ -269,20 +269,6 @@ pub struct ModelProfile {
     /// / 5M+ vector workloads.
     #[serde(default)]
     pub vector_backend: VectorBackend,
-    /// Phase 41: Profile type for routing + activation behavior.
-    /// Default Execution for backward compatibility.
-    #[serde(default)]
-    pub profile_type: ProfileType,
-}
-
-#[derive(Debug, Clone, Copy, PartialEq, Serialize, Deserialize, Default)]
-#[serde(rename_all = "snake_case")]
-pub enum ProfileType {
-    #[default]
-    Execution,
-    Retrieval,
-    Memory,
-    Observer,
 }
 
 fn default_embed_model() -> String { "nomic-embed-text".to_string() }

crates/truth/Cargo.toml

@@ -1,10 +0,0 @@
-[package]
-name = "truth"
-version = "0.1.0"
-edition = "2024"
-
-[dependencies]
-serde = { workspace = true }
-serde_json = { workspace = true }
-tokio = { workspace = true }
-tracing = { workspace = true }

crates/truth/src/lib.rs

@@ -1,523 +0,0 @@
-use serde::{Deserialize, Serialize};
-use std::collections::HashMap;
-
-#[derive(Clone, Debug, Serialize, Deserialize)]
-pub struct TruthRule {
-    pub id: String,
-    pub task_class: String,
-    pub description: String,
-    pub condition: RuleCondition,
-    pub action: RuleAction,
-}
-
-#[derive(Clone, Debug, PartialEq, Serialize, Deserialize)]
-#[serde(tag = "type")]
-pub enum RuleCondition {
-    Always,
-    FieldEquals { field: String, value: String },
-    FieldMismatch { field: String, value: String },
-    FieldEmpty { field: String },
-    FieldGreater { field: String, threshold: i64 },
-}
-
-#[derive(Clone, Debug, PartialEq, Serialize, Deserialize)]
-#[serde(tag = "type")]
-pub enum RuleAction {
-    Pass,
-    Reject { message: String },
-    Redact { fields: Vec<String> },
-    Block { message: String },
-}
-
-#[derive(Default)]
-pub struct TruthStore {
-    rules: HashMap<String, Vec<TruthRule>>,
-}
-
-impl TruthStore {
-    pub fn new() -> Self {
-        Self::default()
-    }
-
-    pub fn add_rule(&mut self, rule: TruthRule) {
-        self.rules
-            .entry(rule.task_class.clone())
-            .or_default()
-            .push(rule);
-    }
-
-    pub fn get_rules(&self, task_class: &str) -> Vec<&TruthRule> {
-        self.rules
-            .get(task_class)
-            .map(|v| v.iter().collect())
-            .unwrap_or_default()
-    }
-
-    /// Legacy API: returns the list of actions registered for a task class
-    /// without evaluating conditions. Retained for backward compatibility
-    /// with callers that only want the action catalog. New callers should
-    /// prefer `evaluate()`, which actually walks `RuleCondition` against
-    /// a context and reports per-rule pass/fail.
-    pub fn check(&self, task_class: &str) -> Vec<RuleAction> {
-        let rules = self.get_rules(task_class);
-        rules
-            .into_iter()
-            .map(|r| r.action.clone())
-            .collect()
-    }
-
-    /// Evaluate every rule registered for `task_class` against `ctx`,
-    /// returning one `RuleOutcome` per rule. `passed = true` means the
-    /// rule's `condition` held; the rule's action is still attached so
-    /// callers can distinguish "passed and therefore no-op" (RuleAction::Pass)
-    /// from "passed and apply Redact". `passed = false` means the condition
-    /// failed — callers should treat the attached action as the enforcement
-    /// response (Reject/Block).
-    ///
-    /// Fixed P42-001 (2026-04-23): previously `check()` returned all actions
-    /// unconditionally — the `RuleCondition` field was ignored. Now every
-    /// rule is actually walked against the provided context.
-    pub fn evaluate(&self, task_class: &str, ctx: &serde_json::Value) -> Vec<RuleOutcome> {
-        self.get_rules(task_class)
-            .into_iter()
-            .map(|r| RuleOutcome {
-                rule_id: r.id.clone(),
-                passed: evaluate_condition(&r.condition, ctx),
-                action: r.action.clone(),
-            })
-            .collect()
-    }
-}
-
-/// Result of evaluating one rule against a context. `passed` reports
-/// whether the condition held; `action` is the rule's declared action
-/// regardless (callers decide how to apply it based on `passed`).
-#[derive(Clone, Debug, PartialEq, Serialize, Deserialize)]
-pub struct RuleOutcome {
-    pub rule_id: String,
-    pub passed: bool,
-    pub action: RuleAction,
-}
-
-fn evaluate_condition(cond: &RuleCondition, ctx: &serde_json::Value) -> bool {
-    match cond {
-        RuleCondition::Always => true,
-        RuleCondition::FieldEquals { field, value } => {
-            field_as_string(ctx, field)
-                .map(|s| s == *value)
-                .unwrap_or(false)
-        }
-        RuleCondition::FieldMismatch { field, value } => {
-            field_as_string(ctx, field)
-                .map(|s| s != *value)
-                .unwrap_or(false)
-        }
-        RuleCondition::FieldEmpty { field } => {
-            match lookup(ctx, field) {
-                None => true,
-                Some(v) => v.is_null() || v.as_str().map(|s| s.is_empty()).unwrap_or(false),
-            }
-        }
-        RuleCondition::FieldGreater { field, threshold } => {
-            lookup(ctx, field)
-                .and_then(|v| v.as_i64().or_else(|| v.as_f64().map(|f| f as i64)))
-                .map(|n| n > *threshold)
-                .unwrap_or(false)
-        }
-    }
-}
-
-/// Walk a dot-separated path through a serde_json::Value. `"worker.status"`
-/// → `ctx["worker"]["status"]`. Returns None if any segment is missing or
-/// a non-object is encountered mid-path.
-fn lookup<'a>(ctx: &'a serde_json::Value, path: &str) -> Option<&'a serde_json::Value> {
-    let mut cur = ctx;
-    for seg in path.split('.') {
-        cur = cur.get(seg)?;
-    }
-    Some(cur)
-}
-
-fn field_as_string(ctx: &serde_json::Value, path: &str) -> Option<String> {
-    lookup(ctx, path).and_then(|v| match v {
-        serde_json::Value::String(s) => Some(s.clone()),
-        serde_json::Value::Bool(b) => Some(b.to_string()),
-        serde_json::Value::Number(n) => Some(n.to_string()),
-        _ => None,
-    })
-}
-
-pub fn default_truth_store() -> TruthStore {
-    let mut store = TruthStore::new();
-
-    store.add_rule(TruthRule {
-        id: "worker-active".to_string(),
-        task_class: "staffing.fill".to_string(),
-        description: "Worker must be active".to_string(),
-        condition: RuleCondition::FieldEquals {
-            field: "worker.status".to_string(),
-            value: "active".to_string(),
-        },
-        action: RuleAction::Pass,
-    });
-
-    store.add_rule(TruthRule {
-        id: "client-not-blacklisted".to_string(),
-        task_class: "staffing.fill".to_string(),
-        description: "Worker cannot be blacklisted for client".to_string(),
-        condition: RuleCondition::FieldEquals {
-            field: "worker.client_blacklisted".to_string(),
-            value: "false".to_string(),
-        },
-        action: RuleAction::Pass,
-    });
-
-    store.add_rule(TruthRule {
-        id: "deadline-required".to_string(),
-        task_class: "staffing.fill".to_string(),
-        description: "Contract must have deadline".to_string(),
-        condition: RuleCondition::FieldEmpty {
-            field: "contract.deadline".to_string(),
-        },
-        action: RuleAction::Reject {
-            message: "Contract deadline is required".to_string(),
-        },
-    });
-
-    store.add_rule(TruthRule {
-        id: "budget-required".to_string(),
-        task_class: "staffing.fill".to_string(),
-        description: "Budget must be non-negative".to_string(),
-        condition: RuleCondition::FieldGreater {
-            field: "contract.budget_per_hour_max".to_string(),
-            threshold: 0,
-        },
-        action: RuleAction::Pass,
-    });
-
-    store.add_rule(TruthRule {
-        id: "pii-redact".to_string(),
-        task_class: "staffing.any".to_string(),
-        description: "Redact PII before cloud calls".to_string(),
-        condition: RuleCondition::Always,
-        action: RuleAction::Redact {
-            fields: vec!["ssn".to_string(), "salary".to_string()],
-        },
-    });
-
-    store
-}
-
-#[cfg(test)]
-mod tests {
-    use super::*;
-
-    #[test]
-    fn truth_store_new_is_empty() {
-        let store = TruthStore::new();
-        assert!(store.rules.is_empty());
-    }
-
-    #[test]
-    fn add_rule_inserts_into_correct_task_class() {
-        let mut store = TruthStore::new();
-        store.add_rule(TruthRule {
-            id: "test-rule".to_string(),
-            task_class: "test.task".to_string(),
-            description: "Test rule".to_string(),
-            condition: RuleCondition::Always,
-            action: RuleAction::Pass,
-        });
-        let rules = store.get_rules("test.task");
-        assert_eq!(rules.len(), 1);
-        assert_eq!(rules[0].id, "test-rule");
-    }
-
-    #[test]
-    fn get_rules_returns_empty_for_unknown_class() {
-        let store = TruthStore::new();
-        let rules = store.get_rules("unknown.class");
-        assert!(rules.is_empty());
-    }
-
-    #[test]
-    fn check_returns_actions_for_task_class() {
-        let mut store = TruthStore::new();
-        store.add_rule(TruthRule {
-            id: "a1".to_string(),
-            task_class: "test".to_string(),
-            description: "A1".to_string(),
-            condition: RuleCondition::Always,
-            action: RuleAction::Pass,
-        });
-        store.add_rule(TruthRule {
-            id: "a2".to_string(),
-            task_class: "test".to_string(),
-            description: "A2".to_string(),
-            condition: RuleCondition::Always,
-            action: RuleAction::Reject {
-                message: "test reject".to_string(),
-            },
-        });
-        let actions = store.check("test");
-        assert_eq!(actions.len(), 2);
-    }
-
-    #[test]
-    fn rule_condition_serialize_always() {
-        let cond = RuleCondition::Always;
-        let json = serde_json::to_string(&cond).unwrap();
-        assert!(json.contains(r#""type":"Always"#));
-    }
-
-    #[test]
-    fn rule_condition_serialize_field_equals() {
-        let cond = RuleCondition::FieldEquals {
-            field: "foo".to_string(),
-            value: "bar".to_string(),
-        };
-        let json = serde_json::to_string(&cond).unwrap();
-        assert!(json.contains(r#""type":"FieldEquals""#));
-        assert!(json.contains(r#""field":"foo""#));
-        assert!(json.contains(r#""value":"bar""#));
-    }
-
-    #[test]
-    fn rule_action_serialize_redact() {
-        let action = RuleAction::Redact {
-            fields: vec!["ssn".to_string()],
-        };
-        let json = serde_json::to_string(&action).unwrap();
-        assert!(json.contains(r#""type":"Redact""#));
-        assert!(json.contains("ssn"));
-    }
-
-    #[test]
-    fn rule_action_serialize_reject() {
-        let action = RuleAction::Reject {
-            message: "test".to_string(),
-        };
-        let json = serde_json::to_string(&action).unwrap();
-        assert!(json.contains(r#""type":"Reject""#));
-    }
-
-    #[test]
-    fn default_truth_store_has_staffing_rules() {
-        let store = default_truth_store();
-        let fill_rules = store.get_rules("staffing.fill");
-        assert!(!fill_rules.is_empty());
-        let any_rules = store.get_rules("staffing.any");
-        assert!(!any_rules.is_empty());
-    }
-
-    #[test]
-    fn multiple_rules_same_task_class() {
-        let mut store = TruthStore::new();
-        for i in 0..5 {
-            store.add_rule(TruthRule {
-                id: format!("rule-{}", i),
-                task_class: "test".to_string(),
-                description: format!("Rule {}", i),
-                condition: RuleCondition::Always,
-                action: RuleAction::Pass,
-            });
-        }
-        let rules = store.get_rules("test");
-        assert_eq!(rules.len(), 5);
-    }
-
-    #[test]
-    fn truth_rule_clone_preserves_data() {
-        let rule = TruthRule {
-            id: "clone-test".to_string(),
-            task_class: "clone.task".to_string(),
-            description: "Clone test".to_string(),
-            condition: RuleCondition::FieldEquals {
-                field: "x".to_string(),
-                value: "y".to_string(),
-            },
-            action: RuleAction::Block {
-                message: "blocked".to_string(),
-            },
-        };
-        let cloned = rule.clone();
-        assert_eq!(cloned.id, rule.id);
-        assert_eq!(cloned.condition, rule.condition);
-        assert_eq!(cloned.action, rule.action);
-    }
-
-    #[test]
-    fn field_greater_condition_parse() {
-        let json = r#"{"type":"FieldGreater","field":"count","threshold":10}"#;
-        let cond: RuleCondition = serde_json::from_str(json).unwrap();
-        match cond {
-            RuleCondition::FieldGreater { field, threshold } => {
-                assert_eq!(field, "count");
-                assert_eq!(threshold, 10);
-            }
-            _ => panic!("Expected FieldGreater"),
-        }
-    }
-
-    #[test]
-    fn block_action_blocks_with_message() {
-        let action = RuleAction::Block {
-            message: "Rate limited".to_string(),
-        };
-        let json = serde_json::to_string(&action).unwrap();
-        assert!(json.contains("Rate limited"));
-    }
-
-    #[test]
-    fn empty_store_check_returns_empty() {
-        let store = TruthStore::new();
-        let actions = store.check("empty.class");
-        assert!(actions.is_empty());
-    }
-
-    // ── P42-001 evaluate() tests — actually walk RuleCondition ──
-
-    fn fill_store() -> TruthStore {
-        let mut s = TruthStore::new();
-        s.add_rule(TruthRule {
-            id: "active".into(),
-            task_class: "t".into(),
-            description: "must be active".into(),
-            condition: RuleCondition::FieldEquals {
-                field: "worker.status".into(),
-                value: "active".into(),
-            },
-            action: RuleAction::Reject {
-                message: "worker not active".into(),
-            },
-        });
-        s.add_rule(TruthRule {
-            id: "deadline".into(),
-            task_class: "t".into(),
-            description: "deadline required".into(),
-            condition: RuleCondition::FieldEmpty {
-                field: "contract.deadline".into(),
-            },
-            action: RuleAction::Reject {
-                message: "missing deadline".into(),
-            },
-        });
-        s.add_rule(TruthRule {
-            id: "budget".into(),
-            task_class: "t".into(),
-            description: "budget positive".into(),
-            condition: RuleCondition::FieldGreater {
-                field: "contract.budget".into(),
-                threshold: 0,
-            },
-            action: RuleAction::Block {
-                message: "budget must be positive".into(),
-            },
-        });
-        s
-    }
-
-    #[test]
-    fn evaluate_field_equals_pass_on_match() {
-        let s = fill_store();
-        let ctx = serde_json::json!({"worker": {"status": "active"}});
-        let o = s.evaluate("t", &ctx);
-        let active = o.iter().find(|r| r.rule_id == "active").unwrap();
-        assert!(active.passed, "active condition should hold");
-    }
-
-    #[test]
-    fn evaluate_field_equals_fail_on_mismatch() {
-        let s = fill_store();
-        let ctx = serde_json::json!({"worker": {"status": "terminated"}});
-        let o = s.evaluate("t", &ctx);
-        let active = o.iter().find(|r| r.rule_id == "active").unwrap();
-        assert!(!active.passed, "terminated should fail active condition");
-    }
-
-    #[test]
-    fn evaluate_field_equals_fail_on_missing() {
-        let s = fill_store();
-        let ctx = serde_json::json!({});
-        let o = s.evaluate("t", &ctx);
-        let active = o.iter().find(|r| r.rule_id == "active").unwrap();
-        assert!(!active.passed, "missing worker.status should fail");
-    }
-
-    #[test]
-    fn evaluate_field_empty_pass_when_absent() {
-        let s = fill_store();
-        // FieldEmpty passes when the field is missing/null/empty string.
-        // Deadline rule says "field empty means action fires" — so passed=true
-        // here means the rule's condition held (deadline IS empty).
-        let ctx = serde_json::json!({});
-        let o = s.evaluate("t", &ctx);
-        let deadline = o.iter().find(|r| r.rule_id == "deadline").unwrap();
-        assert!(deadline.passed);
-    }
-
-    #[test]
-    fn evaluate_field_empty_fail_when_present() {
-        let s = fill_store();
-        let ctx = serde_json::json!({"contract": {"deadline": "2026-05-01"}});
-        let o = s.evaluate("t", &ctx);
-        let deadline = o.iter().find(|r| r.rule_id == "deadline").unwrap();
-        assert!(!deadline.passed, "non-empty deadline should fail FieldEmpty check");
-    }
-
-    #[test]
-    fn evaluate_field_greater_pass_and_fail() {
-        let s = fill_store();
-        let ctx_ok = serde_json::json!({"contract": {"budget": 100}});
-        let ctx_bad = serde_json::json!({"contract": {"budget": 0}});
-        let ok = s.evaluate("t", &ctx_ok);
-        let bad = s.evaluate("t", &ctx_bad);
-        assert!(ok.iter().find(|r| r.rule_id == "budget").unwrap().passed);
-        assert!(!bad.iter().find(|r| r.rule_id == "budget").unwrap().passed);
-    }
-
-    #[test]
-    fn evaluate_always_condition_passes_unconditionally() {
-        let mut s = TruthStore::new();
-        s.add_rule(TruthRule {
-            id: "always".into(),
-            task_class: "x".into(),
-            description: "".into(),
-            condition: RuleCondition::Always,
-            action: RuleAction::Pass,
-        });
-        let o = s.evaluate("x", &serde_json::json!(null));
-        assert!(o[0].passed);
-    }
-
-    #[test]
-    fn evaluate_preserves_action_regardless_of_outcome() {
-        let s = fill_store();
-        let ctx = serde_json::json!({"worker": {"status": "active"}});
-        let o = s.evaluate("t", &ctx);
-        let active = o.iter().find(|r| r.rule_id == "active").unwrap();
-        // Action is attached whether the rule passed or not — the consumer
-        // decides how to use it.
-        assert_eq!(
-            active.action,
-            RuleAction::Reject {
-                message: "worker not active".into()
-            }
-        );
-    }
-
-    #[test]
-    fn evaluate_on_unknown_task_class_returns_empty() {
-        let s = fill_store();
-        let o = s.evaluate("nonexistent", &serde_json::json!({}));
-        assert!(o.is_empty());
-    }
-
-    #[test]
-    fn check_still_returns_actions_unconditionally_for_back_compat() {
-        // Legacy API should still behave the same — no condition walking.
-        let s = fill_store();
-        let actions = s.check("t");
-        assert_eq!(actions.len(), 3, "check returns one action per rule regardless of condition");
-    }
-}

crates/vectord/src/jobs.rs

@@ -8,13 +8,6 @@ use std::collections::HashMap;
 use std::sync::Arc;
 use tokio::sync::RwLock;
 
-#[derive(Debug, Clone, Serialize)]
-#[serde(rename_all = "lowercase")]
-pub enum JobType {
-    Embed,
-    ProfileActivation,
-}
-
 #[derive(Debug, Clone, Serialize)]
 #[serde(rename_all = "lowercase")]
 pub enum JobStatus {
@@ -26,61 +19,24 @@ pub enum JobStatus {
 #[derive(Debug, Clone, Serialize)]
 pub struct Job {
     pub id: String,
-    #[serde(skip_serializing_if = "Option::is_none")]
-    pub job_type: Option<JobType>,
     pub status: JobStatus,
-    pub index_name: Option<String>,
-    pub profile_id: Option<String>,
+    pub index_name: String,
     pub total_chunks: usize,
+    /// How many chunks have been embedded so far.
+    /// Also serialized as "processed" for backward-compat with monitoring scripts.
+    pub embedded_chunks: usize,
     #[serde(rename = "processed")]
     pub processed_alias: usize,
+    pub total: usize,
     pub progress_pct: f32,
     pub storage_key: Option<String>,
     pub error: Option<String>,
     pub started_at: String,
     pub completed_at: Option<String>,
-    #[serde(skip_serializing_if = "Option::is_none")]
-    pub result: Option<serde_json::Value>,
-}
-
-impl Job {
-    pub fn new_embed(index_name: &str, total_chunks: usize) -> Self {
-        Self {
-            id: format!("job-{}", chrono::Utc::now().timestamp_millis()),
-            job_type: Some(JobType::Embed),
-            status: JobStatus::Running,
-            index_name: Some(index_name.to_string()),
-            profile_id: None,
-            total_chunks,
-            processed_alias: 0,
-            progress_pct: 0.0,
-            storage_key: None,
-            error: None,
-            started_at: chrono::Utc::now().to_rfc3339(),
-            completed_at: None,
-            result: None,
-        }
-    }
-
-    pub fn new_profile_activation(profile_id: &str) -> Self {
-        Self {
-            id: format!("job-{}", chrono::Utc::now().timestamp_millis()),
-            job_type: Some(JobType::ProfileActivation),
-            status: JobStatus::Running,
-            index_name: None,
-            profile_id: Some(profile_id.to_string()),
-            total_chunks: 0,
-            processed_alias: 0,
-            progress_pct: 0.0,
-            storage_key: None,
-            error: None,
-            started_at: chrono::Utc::now().to_rfc3339(),
-            completed_at: None,
-            result: None,
-        }
-    }
+    pub chunks_per_sec: f32,
 }
 
+/// Shared progress tracker that background tasks update.
 #[derive(Clone)]
 pub struct JobTracker {
     jobs: Arc<RwLock<HashMap<String, Job>>>,
@@ -93,42 +49,57 @@ impl JobTracker {
         }
     }
 
-    pub async fn create_embed(&self, index_name: &str, total_chunks: usize) -> String {
-        let job = Job::new_embed(index_name, total_chunks);
-        let id = job.id.clone();
+    /// Register a new job. Returns the job ID.
+    pub async fn create(&self, index_name: &str, total_chunks: usize) -> String {
+        let id = format!("job-{}", chrono::Utc::now().timestamp_millis());
+        let job = Job {
+            id: id.clone(),
+            status: JobStatus::Running,
+            index_name: index_name.to_string(),
+            total_chunks,
+            embedded_chunks: 0,
+            processed_alias: 0,
+            total: total_chunks,
+            progress_pct: 0.0,
+            storage_key: None,
+            error: None,
+            started_at: chrono::Utc::now().to_rfc3339(),
+            completed_at: None,
+            chunks_per_sec: 0.0,
+        };
         self.jobs.write().await.insert(id.clone(), job);
         id
     }
 
-    pub async fn create_profile_activation(&self, profile_id: &str) -> String {
-        let job = Job::new_profile_activation(profile_id);
-        let id = job.id.clone();
-        self.jobs.write().await.insert(id.clone(), job);
-        id
-    }
-
-    pub async fn update_embed_progress(&self, id: &str, embedded: usize, _rate: f32) {
+    /// Update progress.
+    pub async fn update_progress(&self, id: &str, embedded: usize, rate: f32) {
         let mut jobs = self.jobs.write().await;
         if let Some(job) = jobs.get_mut(id) {
-            job.processed_alias = embedded;
+            job.embedded_chunks = embedded;
+            job.processed_alias = embedded;  // keep alias in sync
             job.progress_pct = if job.total_chunks > 0 {
                 (embedded as f32 / job.total_chunks as f32) * 100.0
             } else {
                 0.0
             };
+            job.chunks_per_sec = rate;
         }
     }
 
-    pub async fn complete(&self, id: &str, result: Option<serde_json::Value>) {
+    /// Mark job as completed.
+    pub async fn complete(&self, id: &str, storage_key: String) {
         let mut jobs = self.jobs.write().await;
         if let Some(job) = jobs.get_mut(id) {
             job.status = JobStatus::Completed;
+            job.embedded_chunks = job.total_chunks;
+            job.processed_alias = job.total_chunks;
             job.progress_pct = 100.0;
+            job.storage_key = Some(storage_key);
             job.completed_at = Some(chrono::Utc::now().to_rfc3339());
-            job.result = result;
         }
     }
 
+    /// Mark job as failed.
     pub async fn fail(&self, id: &str, error: String) {
         let mut jobs = self.jobs.write().await;
         if let Some(job) = jobs.get_mut(id) {
@@ -138,11 +109,13 @@ impl JobTracker {
         }
     }
 
+    /// Get job status.
     pub async fn get(&self, id: &str) -> Option<Job> {
         self.jobs.read().await.get(id).cloned()
     }
 
+    /// List all jobs.
     pub async fn list(&self) -> Vec<Job> {
         self.jobs.read().await.values().cloned().collect()
     }
-}
+}

crates/vectord/src/service.rs

@@ -7,7 +7,6 @@ use axum::{
 };
 use object_store::ObjectStore;
 use serde::{Deserialize, Serialize};
-use serde_json::json;
 use std::sync::Arc;
 
 use aibridge::client::{AiClient, EmbedRequest, GenerateRequest};
@@ -197,7 +196,7 @@ async fn create_index(
     let bucket = req.bucket.clone().unwrap_or_else(|| "primary".to_string());
 
     // Create job and return immediately
-    let job_id = state.job_tracker.create_embed(&index_name, n_chunks).await;
+    let job_id = state.job_tracker.create(&index_name, n_chunks).await;
     tracing::info!("job {job_id}: indexing '{}' — {} docs → {} chunks (background)", index_name, n_docs, n_chunks);
 
     // Spawn supervised dual-pipeline embedding
@@ -241,7 +240,7 @@ async fn create_index(
                 };
                 let _ = registry.register(meta).await;
 
-                tracker.complete(&jid, Some(json!({ "storage_key": key }))).await;
+                tracker.complete(&jid, key).await;
                 tracing::info!("job {jid}: completed — {n_chunks} chunks in {elapsed:.0}s ({rate:.0}/sec)");
             }
             Err(e) => {
@@ -483,7 +482,7 @@ async fn _run_embedding_job_legacy(
         // Update progress
         let elapsed = start.elapsed().as_secs_f32();
         let rate = if elapsed > 0.0 { all_vectors.len() as f32 / elapsed } else { 0.0 };
-        tracker.update_embed_progress(job_id, all_vectors.len(), rate).await;
+        tracker.update_progress(job_id, all_vectors.len(), rate).await;
 
         // Log every 100 batches
         if (i + 1) % 100 == 0 {
@@ -1372,218 +1371,239 @@ async fn activate_profile(
     State(state): State<VectorState>,
     Path(profile_id): Path<String>,
 ) -> impl IntoResponse {
-    tracing::info!("[activate_profile] START profile_id={}", profile_id);
+    let t0 = std::time::Instant::now();
+
     let profile = match state.catalog.get_profile(&profile_id).await {
         Some(p) => p,
         None => return Err((StatusCode::NOT_FOUND, format!("profile not found: {profile_id}"))),
     };
 
-    let job_id = state.job_tracker.create_profile_activation(&profile_id).await;
-    let job_id_for_response = job_id.clone();
-    let tracker = state.job_tracker.clone();
-    let _catalog = state.catalog.clone();
-    let index_registry = state.index_registry.clone();
-    let bucket_registry = state.bucket_registry.clone();
-    let lance = state.lance.clone();
-    let embedding_cache = state.embedding_cache.clone();
-    let hnsw_store = state.hnsw_store.clone();
-    let promotion_registry = state.promotion_registry.clone();
-    let ai_client = state.ai_client.clone();
-    let active_profile = state.active_profile.clone();
-    let profile_name = profile.ollama_name.clone();
-    let profile_id_clone = profile.id.clone();
-    let profile_bucket = profile.bucket.clone();
-    let profile_bound = profile.bound_datasets.clone();
-    let profile_hnsw = profile.hnsw_config.clone();
-    let profile_backend = profile.vector_backend.clone();
-    let _profile_full = profile.clone();
+    let mut warmed = Vec::new();
+    let mut failures = Vec::new();
+    let mut total_vectors = 0usize;
 
-    tokio::spawn(async move {
-        let t0 = std::time::Instant::now();
-        let mut warmed = Vec::new();
-        let mut failures = Vec::new();
-        let mut total_vectors = 0usize;
-        let job_id = job_id;
+    // Phase 17 / C: VRAM-aware swap. If another profile currently holds
+    // the GPU and uses a DIFFERENT Ollama model than the one being
+    // activated, unload it first (keep_alive=0). Same-model activations
+    // skip the unload — no point churning a model that's already loaded.
+    let previous_slot = {
+        let guard = state.active_profile.read().await;
+        guard.clone()
+    };
+    if let Some(prev) = &previous_slot {
+        if prev.ollama_name != profile.ollama_name {
+            match state.ai_client.unload_model(&prev.ollama_name).await {
+                Ok(_) => tracing::info!(
+                    "profile swap: unloaded '{}' ({} -> {})",
+                    prev.ollama_name, prev.profile_id, profile.id,
+                ),
+                Err(e) => failures.push(format!(
+                    "unload previous model '{}': {e}", prev.ollama_name,
+                )),
+            }
+        }
+    }
 
-        let previous_slot = {
-            let guard = active_profile.read().await;
-            guard.clone()
-        };
-        if let Some(prev) = &previous_slot {
-            if prev.ollama_name != profile_name {
-                match ai_client.unload_model(&prev.ollama_name).await {
-                    Ok(_) => tracing::info!(
-                        "profile swap: unloaded '{}' ({} -> {})",
-                        prev.ollama_name, prev.profile_id, profile_id_clone,
-                    ),
-                    Err(e) => failures.push(format!("unload previous model '{}': {e}", prev.ollama_name)),
+    // Federation layer 2: if this profile declares its own bucket and
+    // that bucket isn't registered yet, auto-provision it under the
+    // configured profile_root. This is the moment a "dormant" profile
+    // becomes live — its bucket exists and is readable/writable.
+    if let Some(bucket_name) = profile.bucket.clone() {
+        if !state.bucket_registry.contains(&bucket_name) {
+            let root = format!(
+                "{}/{}",
+                state.bucket_registry.profile_root().trim_end_matches('/'),
+                bucket_name.replace(':', "_"),
+            );
+            let bc = shared::config::BucketConfig {
+                name: bucket_name.clone(),
+                backend: "local".to_string(),
+                root: Some(root.clone()),
+                bucket: None,
+                region: None,
+                endpoint: None,
+                secret_ref: None,
+            };
+            match state.bucket_registry.add_bucket(bc).await {
+                Ok(info) => {
+                    tracing::info!(
+                        "profile '{}' activated bucket '{}' (root={}, reachable={})",
+                        profile.id, bucket_name, root, info.reachable,
+                    );
+                }
+                Err(e) => {
+                    failures.push(format!(
+                        "auto-provision bucket '{}': {}", bucket_name, e,
+                    ));
                 }
             }
         }
+    }
 
-        if let Some(bucket_name) = profile_bucket.clone() {
-            if !bucket_registry.contains(&bucket_name) {
-                let root = format!(
-                    "{}/{}",
-                    bucket_registry.profile_root().trim_end_matches('/'),
-                    bucket_name.replace(':', "_"),
-                );
-                let bc = shared::config::BucketConfig {
-                    name: bucket_name.clone(),
-                    backend: "local".to_string(),
-                    root: Some(root.clone()),
-                    bucket: None,
-                    region: None,
-                    endpoint: None,
-                    secret_ref: None,
-                };
-                match bucket_registry.add_bucket(bc).await {
-                    Ok(info) => {
-                        tracing::info!(
-                            "profile '{}' activated bucket '{}' (root={}, reachable={})",
-                            profile_id_clone, bucket_name, root, info.reachable,
-                        );
+    let all_indexes = state.index_registry.list(None, None).await;
+    let use_lance = profile.vector_backend == shared::types::VectorBackend::Lance;
+
+    for binding in &profile.bound_datasets {
+        let matched: Vec<_> = all_indexes
+            .iter()
+            .filter(|m| &m.source == binding)
+            .collect();
+        if matched.is_empty() {
+            failures.push(format!(
+                "no vector index found for binding '{}'", binding,
+            ));
+            continue;
+        }
+        for meta in matched {
+            if use_lance {
+                // --- Lance activation path ---
+                // Ensure a Lance dataset exists for this index. If it
+                // doesn't, auto-migrate from the Parquet blob. Then
+                // ensure an IVF_PQ index is built.
+                let bucket = meta.bucket.clone();
+                let lance_store = match state.lance.store_for_new(&meta.index_name, &bucket).await {
+                    Ok(s) => s,
+                    Err(e) => {
+                        failures.push(format!("{}: lance store init: {e}", meta.index_name));
+                        continue;
                     }
-                    Err(e) => failures.push(format!("auto-provision bucket '{}': {}", bucket_name, e)),
-                }
-            }
-        }
-
-        let all_indexes = index_registry.list(None, None).await;
-        let use_lance = profile_backend == shared::types::VectorBackend::Lance;
-
-        for binding in &profile_bound {
-            let matched: Vec<_> = all_indexes
-                .iter()
-                .filter(|m| &m.source == binding)
-                .collect();
-            if matched.is_empty() {
-                failures.push(format!("no vector index found for binding '{}'", binding));
-                continue;
-            }
-            for meta in matched {
-                if use_lance {
-                    let bucket = meta.bucket.clone();
-                    let lance_store = match lance.store_for_new(&meta.index_name, &bucket).await {
+                };
+                let count = lance_store.count().await.unwrap_or(0);
+                if count == 0 {
+                    // Auto-migrate from existing Parquet.
+                    let pq_store = match state.bucket_registry.get(&bucket) {
                         Ok(s) => s,
-                        Err(e) => { failures.push(format!("{}: lance store init: {e}", meta.index_name)); continue; }
+                        Err(e) => { failures.push(format!("{}: bucket: {e}", meta.index_name)); continue; }
                     };
-                    let count = lance_store.count().await.unwrap_or(0);
-                    if count == 0 {
-                        let pq_store = match bucket_registry.get(&bucket) {
-                            Ok(s) => s,
-                            Err(e) => { failures.push(format!("{}: bucket: {e}", meta.index_name)); continue; }
-                        };
-                        match storaged::ops::get(&pq_store, &meta.storage_key).await {
-                            Ok(bytes) => {
-                                let build_t = std::time::Instant::now();
-                                match lance_store.migrate_from_parquet_bytes(&bytes).await {
-                                    Ok(ms) => {
-                                        total_vectors += ms.rows_written;
-                                        tracing::info!("lance auto-migrate '{}': {} rows in {:.2}s", meta.index_name, ms.rows_written, ms.duration_secs);
-                                        warmed.push(WarmedIndex {
-                                            index_name: meta.index_name.clone(),
-                                            source: meta.source.clone(),
-                                            vectors: ms.rows_written,
-                                            hnsw_build_secs: build_t.elapsed().as_secs_f32(),
-                                        });
-                                    }
-                                    Err(e) => failures.push(format!("{}: lance migrate: {e}", meta.index_name)),
+                    match storaged::ops::get(&pq_store, &meta.storage_key).await {
+                        Ok(bytes) => {
+                            let build_t = std::time::Instant::now();
+                            match lance_store.migrate_from_parquet_bytes(&bytes).await {
+                                Ok(ms) => {
+                                    total_vectors += ms.rows_written;
+                                    tracing::info!(
+                                        "lance auto-migrate '{}': {} rows in {:.2}s",
+                                        meta.index_name, ms.rows_written, ms.duration_secs,
+                                    );
+                                    warmed.push(WarmedIndex {
+                                        index_name: meta.index_name.clone(),
+                                        source: meta.source.clone(),
+                                        vectors: ms.rows_written,
+                                        hnsw_build_secs: build_t.elapsed().as_secs_f32(),
+                                    });
                                 }
+                                Err(e) => failures.push(format!("{}: lance migrate: {e}", meta.index_name)),
                             }
-                            Err(e) => failures.push(format!("{}: read parquet: {e}", meta.index_name)),
                         }
-                    } else {
-                        total_vectors += count;
+                        Err(e) => failures.push(format!("{}: read parquet: {e}", meta.index_name)),
+                    }
+                } else {
+                    total_vectors += count;
+                    warmed.push(WarmedIndex {
+                        index_name: meta.index_name.clone(),
+                        source: meta.source.clone(),
+                        vectors: count,
+                        hnsw_build_secs: 0.0,
+                    });
+                }
+                // Ensure IVF_PQ vector index exists.
+                if !lance_store.has_vector_index().await.unwrap_or(false) {
+                    match lance_store.build_index(316, 8, 48).await {
+                        Ok(ix) => tracing::info!(
+                            "lance auto-index '{}': IVF_PQ built in {:.1}s",
+                            meta.index_name, ix.build_time_secs,
+                        ),
+                        Err(e) => failures.push(format!("{}: lance IVF_PQ build: {e}", meta.index_name)),
+                    }
+                }
+                // Ensure scalar btree on doc_id for O(log N) random fetch.
+                if !lance_store.has_scalar_index("doc_id").await.unwrap_or(false) {
+                    match lance_store.build_scalar_index("doc_id").await {
+                        Ok(ix) => tracing::info!(
+                            "lance auto-index '{}': doc_id btree built in {:.2}s",
+                            meta.index_name, ix.build_time_secs,
+                        ),
+                        Err(e) => failures.push(format!("{}: lance doc_id btree: {e}", meta.index_name)),
+                    }
+                }
+            } else {
+                // --- Parquet + HNSW activation path (existing) ---
+                let embeddings = match state.embedding_cache.get_or_load(&meta.index_name).await {
+                    Ok(arc) => arc,
+                    Err(e) => {
+                        failures.push(format!("{}: load failed: {}", meta.index_name, e));
+                        continue;
+                    }
+                };
+                total_vectors += embeddings.len();
+
+                let profile_default = trial::HnswConfig {
+                    ef_construction: profile.hnsw_config.ef_construction,
+                    ef_search: profile.hnsw_config.ef_search,
+                    seed: profile.hnsw_config.seed,
+                };
+                let cfg = state
+                    .promotion_registry
+                    .config_or(&meta.index_name, profile_default)
+                    .await;
+                let build_t = std::time::Instant::now();
+                match state
+                    .hnsw_store
+                    .build_index_with_config(&meta.index_name, (*embeddings).clone(), &cfg)
+                    .await
+                {
+                    Ok(_) => {
                         warmed.push(WarmedIndex {
                             index_name: meta.index_name.clone(),
                             source: meta.source.clone(),
-                            vectors: count,
-                            hnsw_build_secs: 0.0,
+                            vectors: embeddings.len(),
+                            hnsw_build_secs: build_t.elapsed().as_secs_f32(),
                         });
                     }
-                    if !lance_store.has_vector_index().await.unwrap_or(false) {
-                        match lance_store.build_index(316, 8, 48).await {
-                            Ok(ix) => tracing::info!("lance auto-index '{}': IVF_PQ built in {:.1}s", meta.index_name, ix.build_time_secs),
-                            Err(e) => failures.push(format!("{}: lance IVF_PQ build: {e}", meta.index_name)),
-                        }
-                    }
-                    if !lance_store.has_scalar_index("doc_id").await.unwrap_or(false) {
-                        match lance_store.build_scalar_index("doc_id").await {
-                            Ok(ix) => tracing::info!("lance auto-index '{}': doc_id btree built in {:.2}s", meta.index_name, ix.build_time_secs),
-                            Err(e) => failures.push(format!("{}: lance doc_id btree: {e}", meta.index_name)),
-                        }
-                    }
-                } else {
-                    let embeddings = match embedding_cache.get_or_load(&meta.index_name).await {
-                        Ok(arc) => arc,
-                        Err(e) => { failures.push(format!("{}: load failed: {}", meta.index_name, e)); continue; }
-                    };
-                    total_vectors += embeddings.len();
-
-                    let profile_default = trial::HnswConfig {
-                        ef_construction: profile_hnsw.ef_construction,
-                        ef_search: profile_hnsw.ef_search,
-                        seed: profile_hnsw.seed,
-                    };
-                    let cfg = promotion_registry
-                        .config_or(&meta.index_name, profile_default)
-                        .await;
-                    let build_t = std::time::Instant::now();
-                    match hnsw_store
-                        .build_index_with_config(&meta.index_name, (*embeddings).clone(), &cfg)
-                        .await
-                    {
-                        Ok(_) => {
-                            warmed.push(WarmedIndex {
-                                index_name: meta.index_name.clone(),
-                                source: meta.source.clone(),
-                                vectors: embeddings.len(),
-                                hnsw_build_secs: build_t.elapsed().as_secs_f32(),
-                            });
-                        }
-                        Err(e) => failures.push(format!("{}: HNSW build failed: {}", meta.index_name, e)),
+                    Err(e) => {
+                        failures.push(format!("{}: HNSW build failed: {}", meta.index_name, e));
                     }
                 }
             }
         }
+    }
 
-        let mut model_preloaded = false;
-        match ai_client.preload_model(&profile_name).await {
-            Ok(_) => {
-                model_preloaded = true;
-                tracing::info!("profile '{}' preloaded ollama model '{}'", profile_id_clone, profile_name);
-            }
-            Err(e) => failures.push(format!("preload ollama model '{}': {e}", profile_name)),
+    // Preload the new profile's Ollama model proactively. Same-model
+    // re-activations are cheap (Ollama no-ops if already loaded).
+    let mut model_preloaded = false;
+    match state.ai_client.preload_model(&profile.ollama_name).await {
+        Ok(_) => {
+            model_preloaded = true;
+            tracing::info!("profile '{}' preloaded ollama model '{}'",
+                profile.id, profile.ollama_name);
         }
+        Err(e) => failures.push(format!(
+            "preload ollama model '{}': {e}", profile.ollama_name,
+        )),
+    }
 
-        {
-            let mut guard = active_profile.write().await;
-            *guard = Some(ActiveProfileSlot {
-                profile_id: profile_id_clone.clone(),
-                ollama_name: profile_name.clone(),
-                activated_at: chrono::Utc::now(),
-            });
-        }
+    // Take the GPU slot.
+    {
+        let mut guard = state.active_profile.write().await;
+        *guard = Some(ActiveProfileSlot {
+            profile_id: profile.id.clone(),
+            ollama_name: profile.ollama_name.clone(),
+            activated_at: chrono::Utc::now(),
+        });
+    }
 
-        let result = serde_json::to_value(ActivateReport {
-            profile_id: profile_id_clone,
-            ollama_name: profile_name,
-            indexes_warmed: warmed,
-            failures,
-            total_vectors,
-            duration_secs: t0.elapsed().as_secs_f32(),
-            model_preloaded,
-            previous_profile: previous_slot.map(|s| s.profile_id),
-        }).ok();
+    let report = ActivateReport {
+        profile_id: profile.id,
+        ollama_name: profile.ollama_name,
+        indexes_warmed: warmed,
+        failures,
+        total_vectors,
+        duration_secs: t0.elapsed().as_secs_f32(),
+        model_preloaded,
+        previous_profile: previous_slot.map(|s| s.profile_id),
+    };
 
-        tracker.complete(&job_id, result).await;
-    });
-
-    Ok(Json(json!({
-        "job_id": job_id_for_response,
-        "message": format!("profile activation started — poll /vectors/jobs/{} for progress", job_id_for_response),
-    })))
+    Ok(Json(report))
 }
 
 /// Unload this profile's model and clear the active slot. No-op if the

crates/vectord/src/store.rs

@@ -2,8 +2,9 @@
 /// Each embedding index is stored as: source, doc_id, chunk_idx, chunk_text, vector (binary blob).
 /// Vectors are stored as raw f32 bytes for compact storage and fast loading.
 
-use arrow::array::{ArrayRef, BinaryArray, Int32Array, RecordBatch, StringArray};
+use arrow::array::{ArrayRef, BinaryArray, Float32Array, Int32Array, RecordBatch, StringArray};
 use arrow::datatypes::{DataType, Field, Schema};
+use bytes::Bytes;
 use object_store::ObjectStore;
 use std::sync::Arc;
 

crates/vectord/src/supervisor.rs

@@ -170,7 +170,7 @@ pub async fn run_supervised(
                         // Update job tracker
                         let elapsed = start_time.elapsed().as_secs_f32();
                         let rate = if elapsed > 0.0 { done as f32 / elapsed } else { 0.0 };
-                        tracker.update_embed_progress(&jid, done, rate).await;
+                        tracker.update_progress(&jid, done, rate).await;
 
                         // Update checkpoint
                         let mut ckpt = ckpt.write().await;

docs/PHASES.md

@@ -324,31 +324,6 @@
   - Mem0-style upsert: `/seed` with `append=true` (default) routes through `upsert_entry`, which decides ADD / UPDATE / NOOP on (operation, day, city, state). Same-day re-seed merges names (union, stable order) instead of duplicating the row. Identical re-seed is a no-op. Different-day same-operation is a fresh ADD. Playbook_id stays stable on UPDATE so prior citations remain valid.
   - Letta-style hot cache: `PlaybookMemory` now holds a `geo_index: HashMap<(city_lower, state_upper), Vec<entry_idx>>` rebuilt on every mutation. Geo-filtered boost queries skip the full scan and hit the O(1) key lookup. At 1.9K entries the full scan was sub-ms; the index scales the same path to 100K+ without code changes.
   - `UpsertOutcome` enum reported back to callers — `{mode: added|updated|noop, playbook_id, merged_names?}` + `entries_after`.
-- [x] **Phase 37: Hot-swap async** (2026-04-22)
-  - Extended `JobTracker` with `JobType::ProfileActivation` + `Embed` enum variants
-  - Made `activate_profile` return immediately with `job_id`, work runs in background via `tokio::spawn`
-  - Background jobs tracked via `POST /vectors/jobs/{id}` + `GET /vectors/jobs`
-- [x] **Phase 38: Universal API Skeleton** (2026-04-23)
-  - `/v1/chat` — OpenAI-compatible POST, forwards to local Ollama or Ollama Cloud
-  - `/v1/usage` — returns `{requests, prompt_tokens, completion_tokens, total_tokens}`
-  - `/v1/sessions` — returns `{data: [], note: "Phase 38: stateless"}`
-  - Langfuse trace integration (fire-and-forget, Phase 40 early)
-  - 12 unit tests green, curl gates pass
-- [x] **Phase 39: Provider Adapter Refactor** (2026-04-23)
-  - `ProviderAdapter` trait with `chat()` + `embed()` + `unload()` + `health()`
-  - `OllamaAdapter` — wraps existing AiClient
-  - `OpenRouterAdapter` — HTTP client to openrouter.ai
-  - `provider_key()` routing by model prefix (openrouter/* → OpenRouter)
-- [x] **Phase 40: Routing & Policy Engine** (2026-04-23)
-  - `RoutingEngine` with `RouteDecision` in aibridge::routing
-  - `config/routing.toml` — rules by model_pattern, fallback chain, cost gating
-  - Per-provider usage tracking: Usage.by_provider
-  - 12 gateway tests green, curl gates pass
-- [x] **Phase 41: Profile System Expansion** (2026-04-23)
-  - `ProfileType` enum: Execution, Retrieval, Memory, Observer
-  - Per-type endpoints: `/profiles/retrieval`, `/profiles/memory`, `/profiles/observer`
-  - `profile_type` field on ModelProfile
-  - Guard fix: automated scrumaudit.py finds real issues
 - [ ] Fine-tuned domain models (Phase 25+)
 - [ ] Multi-node query distribution (only if ceilings bite)
 

docs/SCRUM_FIX_WAVE.md

@@ -1,63 +0,0 @@
-# Scrum Fix Wave — Phase-Sweep 2026-04-23
-
-**Purpose:** Direct the scrum-master pipeline at concrete findings from the Phase 0→42 audit sweep, not at the high-level vision alone. Findings live in `data/_kb/phase_sweep_findings.jsonl` (19 items).
-
-## What the auditor expects you to produce per file
-
-For each file the scrum sees: concrete code-level suggestions that close the listed findings. Not rewrites for style. Not vision drift. Land the invariant or admit the checkbox was premature.
-
-## Meta-pattern to fix (read this first)
-
-The sweep surfaced **one root cause repeated across 5 phases**: primitives exist, cross-cutting enforcement doesn't. Auth, journal, access control, truth rules — the machinery is built, nothing calls it from the actual request path.
-
-One PR-cluster retires the pattern:
-1. **Identity.** Auth middleware wires X-API-Key → extension `AgentIdentity { name, role, api_key_hash }`. (P5-001)
-2. **Request pipeline.** `/query/sql` and `/tools/*/call` read `AgentIdentity`, pass into queryd + tools handlers.
-3. **Access enforcement.** Handlers call `access.can_access()` / `masked_columns()` before returning data; log via `access.log_query()`. (P13-001)
-4. **Mutation journaling.** Every ingest / delta-write / tombstone-add / catalog-register calls the corresponding `journal.record_*`. (P9-001)
-5. **Truth enforcement.** `TruthStore::check()` rewritten to `evaluate(task_class, ctx) -> Vec<RuleOutcome>`, actually walking `RuleCondition` against context. (P42-001, P42-002)
-
-After this cluster lands, Phases 5, 9, 13, 42 become "truly shipped" rather than "machinery shipped."
-
-## Findings by severity
-
-### 🔴 High
-
-- **P9-001** `journald/src/journal.rs`, `crates/gateway/src/main.rs`, all mutation sites. Journal has zero internal callers. Every `ingestd::service::upload_file` success, every `queryd::delta::write_delta`, every `catalogd::tombstones::add`, every `catalogd::registry::register` should emit a journal event. Plus fix: `event_counter` resets on process restart — seed from max existing `event_id` on rebuild or switch to UUID v7.
-- **P13-001** `crates/gateway/src/main.rs` + `crates/queryd/src/service.rs` + `crates/gateway/src/tools/service.rs`. `AccessControl.can_access` / `masked_columns` / `log_query` have zero callers. Query path ignores role. Phase 17's `profile_scoped_search` (service.rs:1641) is the template — copy that shape.
-- **P42-001** `crates/truth/src/lib.rs:56`. `TruthStore::check(task_class)` ignores `RuleCondition` entirely. Signature needs `evaluate(task_class, ctx: &serde_json::Value) -> Vec<RuleOutcome>` that actually walks conditions. Update all 14 tests to exercise fail/pass semantics, not just storage.
-
-### 🟡 Medium
-
-- **P5-001** `crates/gateway/src/auth.rs` + `crates/gateway/src/main.rs:222-233`. `api_key_auth` is `#[allow(dead_code)]`. Wire with `axum::middleware::from_fn_with_state(api_key, auth::api_key_auth)` on protected routes. `/health` stays public.
-- **P10-001** Legacy datasets (including `candidates`, 2.47M rows) have no PII flags. Add `POST /catalog/resync-metadata` mirroring `/catalog/resync-missing`.
-- **P14-001** `crates/ingestd/src/schema_evolution.rs`. Module has 5 passing tests and zero callers. Add `POST /catalog/datasets/by-name/{name}/schema-diff`. When ADR-020 `register()` returns 409, include a `migration_rules[]` body.
-- **P20-001** `config/models.json` is spec-only — never loaded by Rust. Load into `shared::model_matrix::ModelMatrix` at startup; delegate `aibridge::context::context_window_for` to matrix.
-- **P21-001** `generate_continuable` has one prod caller (`rag.rs:171`). Audit every `ai_client.generate()` site. Convert the truncation-prone + thinking-empty-prone sites (auditor paths, reranker, autotune) to `generate_continuable`.
-- **P39-001** `ProviderAdapter` trait + adapters ship, zero callers. `/v1/chat` in `v1/mod.rs:152` uses hardcoded `match req.provider`. Replace with adapter dispatch.
-- **P40-001** `config/routing.toml` is spec-only. `RoutingEngine::new` has no callers. Add `RoutingEngine::from_toml(path)`; `V1State` carries `routing: Arc<RoutingEngine>`; `/v1/chat` consults it before provider match.
-- **P42-002** Truth has no enforcement site. `/v1/chat` or execution_loop should call `truth.evaluate(task_class, ctx)` post-response.
-
-### 🟢 Low
-
-- **P1-001** `crates/storaged/src/federation_service.rs:34-35`. Bucket-qualified routes wire only PUT + GET. Add DELETE + LIST on `/buckets/{bucket}/objects/{*key}`.
-- **P4-001** UI deploy stale. Either rebuild (`just ui-build` + restart `lakehouse-ui.service`) or amend `PHASES.md` to note pre-Phase-9 drift.
-- **P7-001** `vectord::index_registry`. Orphan index registrations (parquet deleted) still list in `/vectors/indexes`. Add a startup sweep + `POST /vectors/resync-missing`.
-- **P12-001** `crates/gateway/src/tools/service.rs`. Audit row has `row_count=null`. Propagate `QueryResponse.row_count` + add `latency_ms`.
-- **P20-002** `crates/gateway/src/v1/mod.rs`. No model-prefix auto-routing. Caller must set `provider` explicitly. Tie to P39-001 + P40-001 fix.
-- **P21-002** `crates/aibridge/src/context.rs`. `context_window_for` hardcoded HashMap duplicates `config/models.json`. Delegate once P20-001 lands.
-- **P38-001** `crates/gateway/src/execution_loop/mod.rs:1523`. Test `executor_prompt_includes_surfaced_candidates` fails on "W-1 Alice Smith" assertion. Either update prompt formatter or update test.
-- **P40-002** Cost gating absent. Add `cost_ceiling_usd_per_hour` to `RoutingEngine` rule, pre-request check against `Usage.by_provider`.
-
-## What "done" looks like for each file the scrum touches
-
-- Name the specific finding(s) the file participates in.
-- Show code-level diff (minimum: function signature + first 5 lines of body) for the fix.
-- Call out any test that needs updating + one new test that would catch the bug on reintroduction.
-- Flag if the fix is too big for one PR and should be split (most of the cross-cutting cluster wants a shared identity/middleware PR first, per-service PRs after).
-
-## Out of scope for this wave
-
-- New features beyond what the findings describe.
-- UI work (Phase 4 stale is known).
-- DevOps / long-horizon domain work (Terraform/Ansible — Phase 43+).

docs/SCRUM_FORENSIC_PROMPT.md

@@ -1,198 +0,0 @@
-# Scrum Master PR Loop — Forensic Validation Prompt (iter 2+)
-
-Adopted 2026-04-23 from J. Replaces the default scrum prompt starting iter 2. Iter 1 used the softer "fix-wave" framing; iter 2 onward uses this adversarial one.
-
----
-
-You are acting as an adversarial **Scrum Master + Systems Auditor**.
-
-Your job is to **prove whether this system actually works**, not to describe it.
-
-You are auditing a system with the following architecture:
-
-- AI Gateway with per-model adapters
-- Output normalization + schema validation layer
-- Execution pipeline (Terraform / Ansible / shell)
-- Task-scoped execution memory (S3 + Apache Arrow/Parquet)
-- Relevance orchestration (context filtering, freshness validation, fact extraction)
-- Local → Cloud fallback loop for failed tasks
-- Iterative repair loop with stored execution evidence
-
----
-
-## PRIMARY OBJECTIVE
-
-Determine if the system is:
-
-1. Executable (real, not pseudocode)
-2. Aligned with PRD contracts
-3. Deterministic enough to trust
-4. Protected from model output drift
-5. Actually closing the loop (fail → repair → reuse)
-
----
-
-## NON-NEGOTIABLE RULES
-
-- Do NOT summarize
-- Do NOT explain architecture unless tied to failure
-- Do NOT assume code works — verify
-- Every claim MUST reference files, functions, or execution evidence
-- If something is unclear → mark as FAIL
-
----
-
-## AUDIT PASSES (RUN ALL)
-
-### 1. PSEUDOCODE / FAKE IMPLEMENTATION DETECTION
-Find any:
-- TODO / stub / placeholder
-- hardcoded outputs where AI should decide
-- mocked execution paths
-- fake success returns
-
-Output exact file + line references.
-
-### 2. PRD CONTRACT VALIDATION
-Verify implementation exists for:
-
-- Gateway routing logic
-- Per-model adapters
-- Output normalization (strip, parse, canonicalize)
-- Schema validation layer
-- Repair loop (retry with modification)
-- Raw output storage
-- Execution memory persistence
-- Retrieval based on prior failures
-- Relevance filtering (freshness / protocol awareness)
-- Execution permission gate
-
-For each component:
-- status: implemented | partial | missing
-- include file references
-
-### 3. NORMALIZATION + VALIDATION PIPELINE
-Prove that:
-
-- Raw model output is NEVER executed directly
-- JSON extraction is enforced
-- Unknown fields are rejected or handled
-- Schema validation blocks bad output
-- Repair loop triggers on failure
-
-If any path bypasses validation → FAIL
-
-### 4. FAILURE → CLOUD → REPAIR LOOP
-Trace the loop:
-
-- Local model fails
-- Failure is classified
-- Context is packaged
-- Cloud model returns corrective instruction
-- Local model retries
-- Result is validated
-- Successful pattern is stored
-
-If any step is missing or non-deterministic → FAIL
-
-### 5. EXECUTION MEMORY (S3 / ARROW)
-Verify:
-
-- Raw runs are stored (input, raw output, normalized output)
-- Failures are recorded with signatures
-- Successful retries are recorded
-- Retrieval pulls based on:
-  - task similarity
-  - failure signature
-  - execution success history
-
-If memory is only logs and not reused → FAIL
-
-### 6. RELEVANCE ORCHESTRATION
-Verify:
-
-- Context is filtered before model input
-- Freshness or version awareness exists
-- Fact extraction reduces noise
-- Context inclusion is explainable
-
-If system blindly injects context → FAIL
-
-### 7. EXECUTION SAFETY
-Verify:
-
-- No shell / terraform / ansible execution without validation gate
-- No direct model-to-command execution
-- Clear permission boundary exists
-
-If AI can execute commands unchecked → CRITICAL FAIL
-
-### 8. TESTING + EVIDENCE
-Find:
-
-- real tests (not mocks)
-- execution logs
-- validation results
-- success/failure traces
-
-If no proof of execution → FAIL
-
----
-
-## OUTPUT FORMAT (STRICT)
-
-Each finding in any array MUST include a `confidence` field (integer 0–100). The confidence represents your self-assessed probability that the finding is correct and actionable. Low confidence is valuable — do not inflate. A finding with confidence < 50 is still recorded (it signals investigation needed) but downstream consumers will weight it less.
-
-```json
-{
-  "verdict": "pass | fail | needs_patch",
-  "critical_failures": [
-    {"id": "CF-1", "file": "path:line", "description": "...", "confidence": 95}
-  ],
-  "pseudocode_flags": [
-    {"file": "path:line", "reason": "...", "confidence": 88}
-  ],
-  "prd_mismatches": [
-    {"component": "...", "status": "partial|missing", "file_ref": "...", "confidence": 80}
-  ],
-  "broken_pipelines": [
-    {"pipeline": "...", "break_point": "...", "confidence": 70}
-  ],
-  "missing_components": [
-    {"component": "...", "required_by": "PRD section X", "confidence": 85}
-  ],
-  "risk_points": [
-    {"area": "...", "risk": "...", "confidence": 60}
-  ],
-  "verified_components": [
-    {"component": "...", "evidence": "file:line or test name", "confidence": 95}
-  ],
-  "evidence": {
-    "files_inspected": [],
-    "execution_paths_traced": [],
-    "tests_found": [],
-    "tests_missing": []
-  },
-  "required_next_actions": [
-    {"action": "...", "file_hint": "...", "confidence": 75}
-  ]
-}
-```
-
-**Calibration guide:**
-- 90–100: pattern seen repeatedly in shipped code; mechanical; low regression risk
-- 70–89: confident in direction, API shape or naming may vary
-- 50–69: plausible fix but may not match conventions, could cascade
-- <50: genuinely uncertain — record anyway so downstream knows to investigate
-
----
-
-## FINAL DIRECTIVE
-
-You are not reviewing code.
-
-You are answering:
-
-> "Can this system be trusted to execute real-world DevOps tasks without hallucinating, bypassing validation, or collapsing under edge cases?"
-
-If the answer is not provably yes, the verdict is FAIL.

docs/SCRUM_LOOP_NOTES.md

@@ -1,95 +0,0 @@
-# Scrum Loop Notes — Observations across iterations
-
-Running notes from the 6x scrum loop (started 2026-04-23). One section per iteration. "Fix next loop" items accumulate here so the next scrum run picks them up — do not fix inline during a running iteration.
-
-## Iteration tracker
-
-| Iter | Status | Scrum started | Scrum finished | Fixes applied | Build green | Re-sweep findings |
-|---|---|---|---|---|---|---|
-| 1 | 🟡 scrum running | 2026-04-23 (brqz3jxgo) | - | - | - | - (baseline = 19) |
-| 2 | 🟡 scrum running | 2026-04-23 (bzs6miehr) | - | - | - | pending |
-| 3 | ⬜ queued | - | - | - | - | - |
-| 4 | ⬜ queued | - | - | - | - | - |
-| 5 | ⬜ queued | - | - | - | - | - |
-| 6 | ⬜ queued | - | - | - | - | - |
-
-## Iteration 1 — in flight
-
-**Target files:** 21 source files extracted from the 19 Phase 0→42 findings.
-**Ladder:** cloud-first per feedback_scrum_cloud_first.md (gpt-oss:120b → qwen3.5:397b → devstral-2:123b → mistral-large-3:675b → gpt-oss:20b → qwen3.5:latest).
-**Proposal:** `docs/SCRUM_FIX_WAVE.md` (via LH_SCRUM_PROPOSAL env).
-
-### Fix next loop — observations accumulating
-
-*Add items here as the scrum runs. Keep each item to one line with a pointer to file + reason. Don't fix inline.*
-
-**[ITER 2 OBSERVATIONS]**
-- **[FORENSIC vs thin-detector mismatch]** iter 2 first attempt on auth.rs triggered "thin/unstructured" rejection at 2031 chars. Cause: forensic prompt asks for strict JSON verdict output, scrum's thin-answer detector expects markdown with score + table. The detector logic needs a forensic-aware branch OR the forensic prompt should preserve markdown output shape while still applying the 8 audit passes. File: `tests/real-world/scrum_master_pipeline.ts`, function that scores accepted vs thin. Fix next loop: add `isForensicAcceptable(text)` that checks for `"verdict"` field + at least one of `critical_failures`/`pseudocode_flags`/`required_next_actions`.
-
-- **[OBSERVATION metric]** 11 `#[allow(dead_code)]` markers cluster in crates/gateway/{auth,access,tools/registry,execution_loop,v1/truth} + crates/aibridge/providers/openrouter + crates/vectord/service. Each one maps cleanly to an audit finding. The `execution_loop/mod.rs:85` comment even admits it: `// reserved for Phase 42 truth-gate (step 6)`. **Metric:** fewer `#[allow(dead_code)]` markers per iteration = less pseudo-real code. Baseline = 11. Target after iter 6: ≤ 2 (only ones that are genuinely optional helpers).
-- **[OBSERVATION gateway-as-router]** scrum_master_pipeline currently fetches `GATEWAY/v1/chat` directly but its LADDER is still a hardcoded const. Should be driven by `config/routing.toml` via RoutingEngine (blocked by P40-001 until iter 1 lands fix). File: `tests/real-world/scrum_master_pipeline.ts:53`.
-- **[OBSERVATION file-type]** iter 1 target list is `.rs` only. Iter 2 must include `tests/multi-agent/*.ts` (executor, observer, kb consumer), `auditor/checks/*.ts`, `sidecar/sidecar/*.py`, and `config/*.{json,toml}`. The scrum pipeline handles any text file.
-- **[OBSERVATION triangulation]** auth.rs scrum review (first file out) independently identified P5-001 exactly: flagged `#[allow(dead_code)]`, scored alignment 4/10, prescribed an `AgentIdentity { name, role, hashed_key }` type matching SCRUM_FIX_WAVE. Audit + scrum converged without seeing each other's output — strong signal the findings are real, not artifacts of one method.
-- **[RULE from J 2026-04-23]** Wiring-gap fixes happen AFTER the scrum completes, not inline. Accumulate observations, apply in one coherent pass. Matches feedback_audit_findings_log.md.
-- **[OBSERVATION oversize-file]** `crates/gateway/src/execution_loop/mod.rs` is 80,901 chars → 24 shards (scrum pipeline's tree-split kicks in at 6KB threshold). A single-file-of-this-size for an execution module is itself a smell — it's the Phase 43 scaffold we kept piling into. Split candidates: executor prompts, reviewer prompts, budget accounting, truth-gate hook, fixtures. Not a fix for this iter, but queue for iter 3.
-- **[OBSERVATION cost-tracking]** zero escalations across first 8 files — 0.0 dollar cloud spend above the minimum. Per-request cost on gpt-oss:120b via Ollama Cloud is effectively $0 in this environment (self-hosted or flat-rate per the llm_team_config key). If we add per-iter token totals to scrum_loop_metrics.jsonl we can show trajectory even when cost is flat.
-
-**[ITER 3 OBSERVATIONS]**
-- **[LARGE-HANDLER thin]** kimi-k2:1t went thin on `crates/gateway/src/tools/service.rs` (~11KB, single large axum handler). deepseek-v3.1:671b rescued on attempt 2 (92.8s, 5408 chars, accepted). Pattern: very large routing files challenge even 1T models. Fix next loop: raise tree-split threshold for handler files OR shard by function boundaries not byte count.
-- **[WRITE-ONLY INDICATORS STILL]** 8 KB files write-only after iter 3: `audits.jsonl` (189 rows/1.9MB — biggest waste), `phase_sweep_findings.jsonl` (35), `distilled_facts.jsonl` (17), `human_overrides.jsonl` (8), `classifications.jsonl` (5), `scrum_loop_metrics.jsonl` (2), `distilled_config_hints.jsonl` (2), `distilled_procedures.jsonl` (2). Fix next loop: extend `auditor/checks/kb_query.ts` to surface these on PR review, OR build a single "KB health dashboard" reader.
-- **[ISOLATED AUTOTUNE]** `crates/vectord/src/agent.rs` has zero refs to scrum/audit/human_override KB. It tunes HNSW but doesn't know which indexes are attached to files the scrum flagged. Fix next loop: add `TriggerEvent::CodeReviewFlag { index_name, gradient_tier }` that biases trial budget toward indexes of flagged files.
-- **[CONFIDENCE WELL-CALIBRATED]** kimi-k2:1t confidences span 75-98 across iter3 files, cluster 85-95. No 100% inflation; min 75 = honest edge-case uncertainty. Good signal — the model is calibrating, not performance-signaling. Do NOT "fix" this by prompt-boosting confidence.
-- **[SCRUM→OBSERVER WIRED]** 2026-04-24 fix landed in iter-3 source but applies to iter 4+ (bun loaded code pre-edit). Verify next loop: `curl :3800/stats` should show `by_source.scrum > 0` after iter 4 runs. If zero, observer /event payload schema mismatch.
-- **[LOW-CONFIDENCE BLOCK flag WORKING]** `crates/storaged/src/federation_service.rs` scored 3/10 with confidences **[40, 35, 50]** → avg 42, min 35. Permission Gradient correctly classifies this file as `block` tier (min <50) — exactly the signal we want. kimi-k2:1t is honestly saying "I'm not confident about these suggestions." Human must review before any auto-apply. Validates Layer #6 working end-to-end. **DO NOT fix this** — it's the system protecting us.
-- **[CONFIDENCE-COLUMN DROPOUT]** `crates/gateway/src/main.rs` accepted review has 0 confidences extracted despite the prompt requiring them. Either kimi-k2:1t omitted the Confidence column in its table format (regex didn't match), or the specific content ran into token budget and confidence got trimmed. Fix next loop: strengthen the prompt instruction to say "if you omit the Confidence column you MUST provide Confidence: NN% inline after every suggestion" AND post-accept sanity-check the row (reject if findings_count=0 across 5+ suggestions).
-- **[SCORE-PARSER MISS on some files]** `crates/queryd/src/service.rs` and `crates/queryd/src/delta.rs` reviews return score='?' — regex `(\d)\s*/\s*10` isn't matching. Models may have written score as "Score: 4.5/10" or "4/10 (mid)" which the parser can't see. Fix next loop: regex accepts decimals + surrounding context. Not critical — confidences still landed.
-- **[SCORE DISTRIBUTION]** across 12 iter-3 files: 3/10 (7 files), 4/10 (2), 6/10 (1), ?/? (2). vectord/index_registry.rs alone scored 6/10 — meaningfully higher. That's worth a closer look: what does that file do right? If we find the pattern there and replicate to peers, scores should rise. This is learning-loop signal.
-
-- **[FORENSIC JSON OUTPUT IS RICHER THAN MARKDOWN]** kimi-k2:1t emitted strict JSON-schema output (matching SCRUM_FORENSIC_PROMPT.md) for `vectord/src/index_registry.rs`. Structure separates critical_failures / pseudocode_flags / prd_mismatches / broken_pipelines / missing_components / risk_points / **verified_components** / required_next_actions — each with confidence per entry. Markdown reviews never captured `verified_components` (what's confirmed working). Fix next loop: scrum pipeline detects JSON format in accepted output and extracts structured fields into KB row (`verified_components_count`, `critical_failures_count`, `missing_components_count`, `verdict`). Downstream consumers then filter PR files by `verdict: needs_patch` or prioritize by `missing_components_count`. **This is the biggest next-iter KB quality jump available** — goes from "confidence as a scalar" to "confidence per specific claim with evidence field." Verified_components in particular is the PROOF-OF-LIFE signal that tells us what's real — flipside of P9/P13/P42 gaps.
-
-- **[🔴 TREE-SPLIT REVIEW SHARD-LEAKAGE]** `ingestd/src/service.rs` (7 shards, 24.3KB) accepted output is titled "Forensic Audit Report – ... (shard 3)". The review covers only the Postgres-import path (shard 3). The `ingest_file` handler where my P9-001 fix lives (journal.record_ingest call) is in shard 1 or 2 — that reviewer never saw the fix. **`tree_split_fired: true` is supposed to mean the output is the reducer-merged summary of all shards**, but this review retained shard-specific scope. Either (a) the reduce step didn't integrate shard summaries, (b) the accepted attempt was one individual shard response that slipped past the reducer, or (c) the reducer prompt doesn't instruct the model to present the file holistically. **This is a real correctness bug** — it means file-level findings can be ghost-negative (fix applied, reviewer blind to it) and ghost-positive (gap exists in unreviewed shard, reviewer gives clean bill). Fix next loop: examine the reduce-step prompt in tree-split path, ensure accepted output comes from reduce step not from any individual shard. Validate by running on a file with a known fix and confirming the review notices it.
-
-**[ITER 4 OBSERVATIONS]**
-- **[🔴 OBSERVER DROPS SCRUM RICH FIELDS]** Scrum→observer wiring works (by_source.scrum appears in /stats on iter 4 file 1). BUT observer.ts:262-283 `ObservedOp = {...}` literal only spreads known keys (endpoint, success, duration_ms, role, city, state, count, rescue_*). My scrum-specific fields (confidence_avg, confidence_min, gradient_tier, verdict, critical_failures_count, verified_components_count, missing_components_count, alignment_score, output_format, findings_count, attempts_made, thin_rejections) are silently discarded. Observer knows the scrum event happened but loses review-quality data. Fix next loop: add `metadata?: Record<string, any>` passthrough on ObservedOp, or declare scrum-specific fields explicitly. Preferred: metadata passthrough so future sources (auditor, kb_extractor) land the same way.
-- **[SCHEMA V4 LANDING CORRECTLY]** main.rs iter-4 KB row has alignment_score=3 (decimal parser fixed), output_format="markdown" (classifier works), verdict=null (correct — only forensic_json produces verdict), confidence_avg=91 (previous iter got 0 due to column dropout — run-to-run variance self-healed this). Structured counters (critical/verified/missing) = 0 on markdown rows, populated on forensic_json rows.
-- **[RING BUFFER EVICTING LANGFUSE]** observer ring hit 2000 cap; first 2 scrum events pushed 2 langfuse entries out (1999 → 1997). Not a bug — ring works as designed — but means old-context retention is bounded. If we care about historical Langfuse traces we need a larger ring OR a separate per-source ring.
-- **[UI Playwright probe found 2 real bugs]** (fixed 2026-04-24): (a) ui/server.ts tryFetch relied on content-type header to decide JSON vs text; observer Bun.serve returns JSON without `application/json` content-type, so stats were strings — UI showed "0 ops" instead of 2000. Fixed: always attempt JSON.parse, fall back to raw text. (b) ui.js renderNodeContext used Object.entries(n.health) which iterates characters on a string — gateway /health returns "lakehouse ok" and the panel showed rows like `0=l, 1=a, 2=k, ...`. Fixed: primitive-vs-object guard. **Both were invisible in functional tests — only a real browser render exposed them.** Worth adding a Playwright smoke test to CI for any future UI changes.
-
-### Iter 1 results
-
-*Populated after scrum finishes.*
-
-## Iteration 2 — queued
-
-**Prompt shape change (from J 2026-04-23):** iter 2+ uses `docs/SCRUM_FORENSIC_PROMPT.md` as the system prompt, replacing the softer iter-1 framing. Adversarial auditor tone with 8 audit passes. Strict JSON output format with `verdict: pass|fail|needs_patch`. If system can't prove itself, verdict is FAIL.
-
-**Scrum pipeline change:** `scrum_master_pipeline.ts` needs an env `LH_SCRUM_SYSTEM_PROMPT` (new) to inject the forensic frame alongside the proposal doc. The file-level loop still asks for suggestions per file but under the 8-pass adversarial lens.
-
-**Goal:** Self-host. Pipeline loads its ladder from `config/routing.toml` via the RoutingEngine that iter 1 wired. If that still isn't loaded, note gap, proceed with hardcoded ladder, flag for iter 3.
-**Target expansion:** beyond `.rs` to `.ts` (tests/multi-agent, auditor/), `.py` (sidecar), `.md` (docs).
-
-## Iterations 3-6 — queued
-
-**Goal:** measure trajectory. Each iteration reduces finding count, raises unit test count, reduces grep-for-fake-markers count. If any iteration doesn't improve, that's the data point.
-
-## Metrics per iteration
-
-Capture after each re-sweep:
-
-- `findings_total` (baseline: 19)
-- `findings_by_severity` (baseline: 3h / 8m / 8l)
-- `phases_partial_count` (baseline: 9)
-- `phases_real_count` (baseline: 25 of 35)
-- `rust_test_count` (baseline: 194+)
-- `gateway_test_fail_count` (baseline: 1 — P38-001)
-- `grep_hits_unimplemented` run: `grep -rEc 'todo!\(\)|unimplemented!\(\)|FIXME' crates/`
-- `grep_hits_pseudo` run: `grep -rEc '\"placeholder\"|\"stub\"|\"mock\"|\"fake\"' crates/`
-
-## Rules for this loop
-
-1. **Cloud-first for every iteration.** Per feedback_scrum_cloud_first.md, strategic review uses 120B+ tier.
-2. **One cross-cutting PR per iteration when possible.** Meta-pattern from audit: identity+auth+access+journal+truth share a pipe. Fix them together.
-3. **Build must be green before next iteration starts.** A broken build is evidence the last iteration regressed, not progressed.
-4. **Log findings to the jsonl as new rows per iteration** with `sweep_id: phase_sweep_2026-04-23-iterN`. Never overwrite prior iteration's findings — the trajectory is the whole point.
-5. **Don't fix things during an iteration.** Every observation goes into "Fix next loop" section above. Next iteration's scrum picks them up.
-

docs/SYSTEM_EVOLUTION_LAYERS.md

@@ -1,83 +0,0 @@
-# Future Expansion — Advanced System Evolution Layers
-
-Adopted 2026-04-24 from J. The system stops optimizing for task completion. It optimizes for **provable execution, repeatable outcomes, resilience under drift, failure, and adversarial conditions.**
-
-## Layer roster + iteration mapping
-
-| # | Layer | Short form | Target iter |
-|---|---|---|---:|
-| 1 | Counterfactual Execution | Generate synthetic failure variants from each success | iter 5 |
-| 2 | Model Trust Profiling | Per-(model, task_type) success rate → routing weight | **iter 3** |
-| 3 | Execution DNA | Compress successful runs into reusable patterns | iter 4 |
-| 4 | Drift Sentinel | Re-validate historical tasks on a schedule | iter 5 |
-| 5 | Adversarial Injection | Inject poisoned context / malformed outputs / conflicts | iter 6 |
-| 6 | Permission Gradient | Confidence → execution tier (≥0.9 full, ≥0.7 dry-run, ≥0.5 sim, <0.5 block) | **iter 3** |
-| 7 | Multi-Agent Disagreement | Planner/Critic/Validator — disagreement = signal | iter 4 |
-| 8 | Temporal Context | Time-aware memory with decay_score + last_validated_at | iter 4 |
-| 9 | Execution Cost Intelligence | Tokens, iterations, cloud_calls, latency per task | **iter 3** |
-| 10 | Human Override as Data | Capture manual fixes as jsonl rows | **iter 3** |
-
-## Detail (J's original framing preserved)
-
-### 1. Counterfactual Execution Layer
-Simulate alternate failure paths for every successful task. Real Execution → Success → Generate Variations (env, version, inputs) → Simulate Failure Cases → Store Synthetic Failure Signatures. **Purpose:** pre-train against unseen failures before real exposure.
-
-### 2. Model Trust Profiling ← iter 3
-Per-(model, task_type) performance tracking.
-```
-{ "model": "...", "task_type": "...", "success_rate": 0.0, "failure_modes": [], "trust_score": 0.0 }
-```
-**Usage:** route by trust score, adjust validation strictness dynamically, per-model risk budgets.
-
-### 3. Execution DNA (Trace Compression)
-Successful executions → reusable fragments.
-```
-{ "dna_id": "hash", "task_signature": "...", "critical_steps": [], "failure_avoidance": [] }
-```
-Replaces doc retrieval with pattern retrieval; faster convergence on similar tasks.
-
-### 4. Drift Sentinel
-Select Historical Task → Re-run Current Env → Compare → If Failure → Mark Drifted → Trigger Re-learning. Detect silent decay; maintain long-term reliability.
-
-### 5. Adversarial Injection Engine
-Inject malformed outputs / outdated docs / conflicting instructions / poisoned memory. Verify validation catches, execution blocks unsafe actions, memory rejects corrupted data. Build system immunity.
-
-### 6. Permission Gradient Execution ← iter 3
-Confidence-based control replacing binary:
-- confidence ≥ 0.9 → full execution
-- confidence ≥ 0.7 → dry-run + diff
-- confidence ≥ 0.5 → simulation only
-- confidence < 0.5 → block
-Inputs: validation score, model trust score, memory match confidence. Risk-aware control; reduced catastrophic-failure surface.
-
-### 7. Multi-Agent Disagreement Engine
-Planner / Critic / Validator; disagreement triggers more context, bigger model, stricter validation. Disagreement is signal, not noise.
-
-### 8. Temporal Context Layer
-```
-{ "created_at": "ts", "last_validated_at": "ts", "decay_score": 0.0 }
-```
-Retrieval priority: recent + validated + high success rate. Avoid stale knowledge.
-
-### 9. Execution Cost Intelligence ← iter 3
-```
-{ "task": "...", "tokens_used": 0, "iterations": 0, "cloud_calls": 0, "latency_ms": 0 }
-```
-Optimize local vs cloud; reduce unnecessary iterations.
-
-### 10. Human Override as Data ← iter 3
-```
-{ "human_fix": "...", "reason": "...", "task_signature": "...", "validated": true }
-```
-Manual fixes become reusable knowledge.
-
-## Final Principle
-
-Memory is not passive recall. It is operational substrate:
-- failures become structured knowledge
-- successes become reusable execution patterns
-- all outputs are validated before reuse
-
-## System Directive
-
-Not speed. Not convenience. **Correctness. Verifiability. Resilience under change.**

mcp-server/langfuse_bridge.ts

@@ -1,174 +0,0 @@
-// langfuse_bridge — the missing piece called out in project_lost_stack.md
-// and Phase 40 PRD. Polls Langfuse `/api/public/traces` at interval,
-// forwards every completed trace to observer `:3800/event` with
-// `source: "langfuse"`. Observer's existing ring buffer + analyzer
-// pick it up, so the KB learns from cost/latency/provider deltas per
-// model — not just from scenario outcomes.
-//
-// Loopback: observer persistOp() appends to data/_observer/ops.jsonl
-// and its aggregator produces pathway_recommendations.jsonl. This
-// bridge closes the feedback loop between LLM call metadata and the
-// playbook/KB learning surface.
-//
-// State persistence: last-seen trace timestamp written to a JSON file
-// so restarts don't double-emit. Bounded forward window (50/tick) so
-// first-run catch-up doesn't hammer the observer.
-
-const LANGFUSE_URL = process.env.LANGFUSE_URL ?? "http://localhost:3000";
-const LANGFUSE_PUBLIC = process.env.LANGFUSE_PUBLIC_KEY;
-const LANGFUSE_SECRET = process.env.LANGFUSE_SECRET_KEY;
-const OBSERVER_URL = process.env.OBSERVER_URL ?? "http://localhost:3800";
-const POLL_INTERVAL_MS = Number(process.env.LANGFUSE_POLL_MS ?? 30000);
-const BATCH_LIMIT = Number(process.env.LANGFUSE_BATCH_LIMIT ?? 50);
-const STATE_FILE = process.env.LANGFUSE_STATE_FILE
-  ?? "/var/lib/lakehouse-guard/langfuse_last_seen.json";
-
-interface LangfuseTrace {
-  id: string;
-  name?: string;
-  timestamp: string;
-  input?: any;
-  output?: any;
-  latency?: number;          // seconds, per Langfuse API
-  totalCost?: number;
-  usage?: { input?: number; output?: number; total?: number };
-  metadata?: any;
-}
-
-interface State { last_seen_ts?: string }
-
-function basicAuth(): string {
-  return "Basic " + btoa(`${LANGFUSE_PUBLIC}:${LANGFUSE_SECRET}`);
-}
-
-async function loadState(): Promise<State> {
-  try {
-    const f = Bun.file(STATE_FILE);
-    if (!(await f.exists())) return {};
-    return JSON.parse(await f.text()) as State;
-  } catch (e) {
-    console.warn(`[langfuse-bridge] state load failed: ${e}`);
-    return {};
-  }
-}
-
-async function saveState(s: State): Promise<void> {
-  try {
-    await Bun.write(STATE_FILE, JSON.stringify(s));
-  } catch (e) {
-    console.warn(`[langfuse-bridge] state save failed: ${e}`);
-  }
-}
-
-async function fetchTracesSince(cursor?: string): Promise<LangfuseTrace[]> {
-  const url = new URL("/api/public/traces", LANGFUSE_URL);
-  url.searchParams.set("limit", String(BATCH_LIMIT));
-  url.searchParams.set("orderBy", "timestamp.asc");
-  if (cursor) url.searchParams.set("fromTimestamp", cursor);
-  const resp = await fetch(url, {
-    headers: { authorization: basicAuth() },
-    signal: AbortSignal.timeout(10_000),
-  });
-  if (!resp.ok) {
-    throw new Error(`langfuse ${resp.status}: ${(await resp.text()).slice(0, 200)}`);
-  }
-  const body: any = await resp.json();
-  return (body.data ?? []) as LangfuseTrace[];
-}
-
-// Shape one Langfuse trace into the ObservedOp the observer expects
-// (see mcp-server/observer.ts:29). `source: "langfuse"` is the
-// provenance flag so the analyzer can weight traces differently from
-// scenario-sourced events.
-function toObservedOp(t: LangfuseTrace): Record<string, any> {
-  const endpoint = t.metadata?.provider
-    ?? t.metadata?.model
-    ?? t.name
-    ?? "langfuse.trace";
-  const inputSummary = typeof t.input === "string"
-    ? t.input.slice(0, 200)
-    : JSON.stringify(t.input ?? {}).slice(0, 200);
-  const outputSummary = typeof t.output === "string"
-    ? t.output.slice(0, 200)
-    : JSON.stringify(t.output ?? {}).slice(0, 200);
-  return {
-    timestamp: t.timestamp,
-    endpoint: `langfuse:${endpoint}`,
-    input_summary: inputSummary,
-    success: !t.metadata?.error,
-    duration_ms: Math.round((t.latency ?? 0) * 1000),
-    output_summary: outputSummary,
-    source: "langfuse",
-    sig_hash: t.metadata?.sig_hash,
-    event_kind: t.metadata?.task_class,
-    // Extra fields the observer doesn't schema but the KB aggregator
-    // can still pick up via JSON passthrough.
-    model: t.metadata?.model,
-    provider: t.metadata?.provider,
-    prompt_tokens: t.usage?.input,
-    completion_tokens: t.usage?.output,
-    total_tokens: t.usage?.total,
-    total_cost: t.totalCost,
-  };
-}
-
-async function forwardToObserver(op: Record<string, any>): Promise<void> {
-  const resp = await fetch(`${OBSERVER_URL}/event`, {
-    method: "POST",
-    headers: { "content-type": "application/json" },
-    body: JSON.stringify(op),
-    signal: AbortSignal.timeout(5_000),
-  });
-  if (!resp.ok) {
-    throw new Error(`observer ${resp.status}: ${(await resp.text()).slice(0, 200)}`);
-  }
-}
-
-async function tick(): Promise<void> {
-  const state = await loadState();
-  let traces: LangfuseTrace[];
-  try {
-    traces = await fetchTracesSince(state.last_seen_ts);
-  } catch (e) {
-    console.warn(`[langfuse-bridge] fetch failed: ${e}`);
-    return;
-  }
-  if (traces.length === 0) {
-    console.log(`[langfuse-bridge] no new traces since ${state.last_seen_ts ?? "start"}`);
-    return;
-  }
-  let last = state.last_seen_ts ?? "";
-  let forwarded = 0;
-  for (const t of traces) {
-    try {
-      await forwardToObserver(toObservedOp(t));
-      forwarded++;
-      if (t.timestamp > last) last = t.timestamp;
-    } catch (e) {
-      console.warn(`[langfuse-bridge] forward ${t.id} failed: ${e}`);
-      // Don't advance cursor on forward failure — retry next tick.
-      break;
-    }
-  }
-  if (last) await saveState({ last_seen_ts: last });
-  console.log(
-    `[langfuse-bridge] forwarded ${forwarded}/${traces.length}, last_seen=${last}`,
-  );
-}
-
-async function main(): Promise<void> {
-  if (!LANGFUSE_PUBLIC || !LANGFUSE_SECRET) {
-    console.error("LANGFUSE_PUBLIC_KEY + LANGFUSE_SECRET_KEY required");
-    process.exit(1);
-  }
-  console.log(
-    `[langfuse-bridge] polling ${LANGFUSE_URL} every ${POLL_INTERVAL_MS}ms → ${OBSERVER_URL}/event`,
-  );
-  await tick();
-  setInterval(tick, POLL_INTERVAL_MS);
-}
-
-main().catch(e => {
-  console.error(`[langfuse-bridge] fatal: ${e}`);
-  process.exit(1);
-});

mcp-server/observer.ts

@@ -37,7 +37,7 @@ interface ObservedOp {
   // Phase 24 — optional provenance so error analyzer and playbook
   // builder can differentiate MCP-layer ops from scenario-sourced
   // events. Scenarios set source="scenario" + staffer_id + sig_hash.
-  source?: "mcp" | "scenario" | "langfuse" | "overseer_correction";
+  source?: "mcp" | "scenario";
   staffer_id?: string;
   sig_hash?: string;
   event_kind?: string;
@@ -47,12 +47,6 @@ interface ObservedOp {
   count?: number;
   rescue_attempted?: boolean;
   rescue_succeeded?: boolean;
-  // Overseer-correction-specific (2026-04-23): lets the analyzer
-  // correlate corrections with the drift that prompted them and with
-  // subsequent outcomes that either validated or invalidated the advice.
-  task_class?: string;
-  correction?: string;
-  applied_at_turn?: number;
 }
 
 const recentOps: ObservedOp[] = [];
@@ -267,10 +261,7 @@ function startHttpListener() {
             duration_ms: Number(body.duration_ms ?? 0),
             output_summary: body.output_summary ?? (body.success ? "filled" : (body.error ?? "failed")),
             error: body.error,
-            // Respect the client's provenance if set (langfuse bridge
-            // sends source:"langfuse", etc.). Default to "scenario"
-            // to keep legacy Phase 24 callers working.
-            source: body.source ?? "scenario",
+            source: "scenario",
             staffer_id: body.staffer_id,
             sig_hash: body.sig_hash,
             event_kind: body.event_kind,
@@ -293,58 +284,6 @@ function startHttpListener() {
   console.error(`[observer] HTTP listener bound to 0.0.0.0:${OBSERVER_PORT}`);
 }
 
-// ─── Overseer corrections tailer (2026-04-23) ───
-
-// The gateway's /v1/respond loop writes T3 overseer corrections to
-// data/_kb/overseer_corrections.jsonl. Tail it once per cycle and
-// inject each new row into the same recentOps ring that analyzeErrors
-// + consolidatePlaybooks read — so a correction that just fired shows
-// up alongside the outcomes it was meant to repair, and the analyzer
-// can flag patterns like "three corrections on staffing.fill with the
-// same advice — underlying problem isn't a drift, it's a data gap".
-const CORRECTIONS_PATH = process.env.OVERSEER_CORRECTIONS_PATH
-  ?? "/home/profit/lakehouse/data/_kb/overseer_corrections.jsonl";
-let correctionsCursor = 0;  // byte offset
-
-async function tailOverseerCorrections(): Promise<number> {
-  const f = Bun.file(CORRECTIONS_PATH);
-  if (!(await f.exists())) return 0;
-  const size = f.size;
-  if (size <= correctionsCursor) return 0;
-
-  // Read only the suffix since the last cursor; keeps tail work
-  // bounded even as the file grows.
-  const text = await f.slice(correctionsCursor, size).text();
-  correctionsCursor = size;
-
-  let forwarded = 0;
-  for (const line of text.split("\n")) {
-    if (!line.trim()) continue;
-    let row: any;
-    try { row = JSON.parse(line); } catch { continue; }
-    const op: ObservedOp = {
-      timestamp: row.created_at ?? new Date().toISOString(),
-      endpoint: `overseer:${row.model ?? "gpt-oss:120b"}`,
-      input_summary: `${row.task_class ?? "?"}: ${row.reason ?? "escalation"}`,
-      // Correction itself is neither success nor failure — it's a
-      // mitigation attempt. We mark success=true so analyzeErrors
-      // doesn't count it as a failure, but the preview lets the
-      // analyzer see what was tried.
-      success: true,
-      duration_ms: Number(row.usage?.latency_ms ?? 0),
-      output_summary: String(row.correction ?? "").slice(0, 200),
-      source: "overseer_correction",
-      sig_hash: row.sig_hash,
-      task_class: row.task_class,
-      correction: String(row.correction ?? ""),
-      applied_at_turn: Number(row.applied_at_turn ?? 0),
-    };
-    recordExternalOp(op);
-    forwarded++;
-  }
-  return forwarded;
-}
-
 // ─── Main loop ───
 
 async function main() {
@@ -367,14 +306,7 @@ async function main() {
     await Bun.sleep(CYCLE_SECS * 1000);
     cycle++;
 
-    // Every cycle: tail the overseer corrections KB stream, then
-    // analyze errors. Order matters — if an overseer correction just
-    // landed for a sig_hash that previously failed, the analyzer
-    // should see both.
-    const newCorrections = await tailOverseerCorrections();
-    if (newCorrections > 0) {
-      console.error(`[observer] pulled ${newCorrections} new overseer correction(s) into ring`);
-    }
+    // Every cycle: analyze errors if any
     await analyzeErrors();
 
     // Every 5 cycles: consolidate playbooks
@@ -383,16 +315,12 @@ async function main() {
     }
 
     const scenarioOps = recentOps.filter(o => o.source === "scenario").length;
-    const langfuseOps = recentOps.filter(o => o.source === "langfuse").length;
-    const correctionOps = recentOps.filter(o => o.source === "overseer_correction").length;
     const stats = {
       cycle,
       total_ops: recentOps.length,
       successes: recentOps.filter(o => o.success).length,
       failures: recentOps.filter(o => !o.success).length,
       scenario_ops: scenarioOps,
-      langfuse_ops: langfuseOps,
-      overseer_corrections: correctionOps,
     };
     console.error(`[observer] cycle ${cycle}: ${JSON.stringify(stats)}`);
   }

ops/systemd/lakehouse.service

@@ -1,26 +0,0 @@
-[Unit]
-Description=Lakehouse Gateway
-After=network.target ollama.service
-
-[Service]
-Type=simple
-WorkingDirectory=/home/profit/lakehouse
-ExecStart=/home/profit/lakehouse/target/release/gateway
-Restart=always
-RestartSec=5
-Environment=RUST_LOG=info
-# Lance S3 support — connects to MinIO via the AWS SDK env vars.
-# AWS_ALLOW_HTTP required for non-TLS MinIO endpoints.
-Environment=AWS_ACCESS_KEY_ID=profit
-Environment=AWS_SECRET_ACCESS_KEY=29IgevhKQjE2WHg088ieI1wP
-Environment=AWS_ENDPOINT=http://localhost:9000
-Environment=AWS_ALLOW_HTTP=true
-Environment=AWS_DEFAULT_REGION=us-east-1
-# Langfuse keys — shared with lakehouse-langfuse-bridge.service so the
-# gateway-side emitter (`/v1/chat`, `/v1/respond`) and the observer
-# ingest path see the same project. Leading `-` makes missing-file a
-# warn-not-fatal so gateway still starts if Langfuse is torn down.
-EnvironmentFile=-/etc/lakehouse/langfuse.env
-
-[Install]
-WantedBy=multi-user.target

tests/multi-agent/scenarios/manifest.json

@@ -1,126 +1,126 @@
 {
   "count": 20,
-  "seed": 42,
+  "seed": 1337,
   "scenarios": [
     {
-      "file": "scen_000_Heritage_Foods_Indianapolis.json",
-      "client": "Heritage Foods",
-      "city": "Indianapolis",
-      "events": 5
-    },
-    {
-      "file": "scen_001_Great_Lakes_Mfg_Madison.json",
+      "file": "scen_000_Great_Lakes_Mfg_Cincinnati.json",
       "client": "Great Lakes Mfg",
-      "city": "Madison",
-      "events": 2
-    },
-    {
-      "file": "scen_002_Vanguard_Components_Lexington.json",
-      "client": "Vanguard Components",
-      "city": "Lexington",
-      "events": 2
-    },
-    {
-      "file": "scen_003_Cornerstone_Fabrication_Fort_Wayne.json",
-      "client": "Cornerstone Fabrication",
-      "city": "Fort Wayne",
+      "city": "Cincinnati",
       "events": 4
     },
     {
-      "file": "scen_004_Horizon_Supply_Louisville.json",
-      "client": "Horizon Supply",
-      "city": "Louisville",
-      "events": 3
-    },
-    {
-      "file": "scen_005_Summit_Industrial_Akron.json",
-      "client": "Summit Industrial",
-      "city": "Akron",
+      "file": "scen_001_Parallel_Machining_Joliet.json",
+      "client": "Parallel Machining",
+      "city": "Joliet",
       "events": 2
     },
     {
-      "file": "scen_006_Centennial_Packaging_Flint.json",
-      "client": "Centennial Packaging",
-      "city": "Flint",
+      "file": "scen_002_Summit_Industrial_Cincinnati.json",
+      "client": "Summit Industrial",
+      "city": "Cincinnati",
       "events": 3
     },
     {
-      "file": "scen_007_Pioneer_Assembly_Grand_Rapids.json",
+      "file": "scen_003_Pioneer_Assembly_Chicago.json",
       "client": "Pioneer Assembly",
-      "city": "Grand Rapids",
+      "city": "Chicago",
       "events": 1
     },
     {
-      "file": "scen_008_Cornerstone_Fabrication_Grand_Rapids.json",
-      "client": "Cornerstone Fabrication",
-      "city": "Grand Rapids",
-      "events": 3
-    },
-    {
-      "file": "scen_009_Midway_Distribution_Fort_Wayne.json",
+      "file": "scen_004_Midway_Distribution_Columbus.json",
       "client": "Midway Distribution",
-      "city": "Fort Wayne",
+      "city": "Columbus",
+      "events": 2
+    },
+    {
+      "file": "scen_005_Apex_Warehouse_Cleveland.json",
+      "client": "Apex Warehouse",
+      "city": "Cleveland",
       "events": 3
     },
     {
-      "file": "scen_010_Keystone_Plastics_Lexington.json",
-      "client": "Keystone Plastics",
-      "city": "Lexington",
+      "file": "scen_006_Pioneer_Assembly_Flint.json",
+      "client": "Pioneer Assembly",
+      "city": "Flint",
       "events": 5
     },
     {
-      "file": "scen_011_Cornerstone_Fabrication_Toledo.json",
-      "client": "Cornerstone Fabrication",
+      "file": "scen_007_Riverfront_Steel_Toledo.json",
+      "client": "Riverfront Steel",
       "city": "Toledo",
       "events": 3
     },
     {
-      "file": "scen_012_Heritage_Foods_Gary.json",
-      "client": "Heritage Foods",
-      "city": "Gary",
-      "events": 3
-    },
-    {
-      "file": "scen_013_Riverfront_Steel_Columbus.json",
-      "client": "Riverfront Steel",
-      "city": "Columbus",
-      "events": 3
-    },
-    {
-      "file": "scen_014_Keystone_Plastics_Cincinnati.json",
-      "client": "Keystone Plastics",
-      "city": "Cincinnati",
-      "events": 2
-    },
-    {
-      "file": "scen_015_Beacon_Freight_Detroit.json",
-      "client": "Beacon Freight",
-      "city": "Detroit",
+      "file": "scen_008_Northland_Logistics_Indianapolis.json",
+      "client": "Northland Logistics",
+      "city": "Indianapolis",
       "events": 4
     },
     {
-      "file": "scen_016_Parallel_Machining_Grand_Rapids.json",
+      "file": "scen_009_Parallel_Machining_Flint.json",
       "client": "Parallel Machining",
-      "city": "Grand Rapids",
+      "city": "Flint",
       "events": 3
     },
     {
-      "file": "scen_017_Parallel_Machining_Gary.json",
-      "client": "Parallel Machining",
-      "city": "Gary",
-      "events": 3
-    },
-    {
-      "file": "scen_018_Cornerstone_Fabrication_Louisville.json",
-      "client": "Cornerstone Fabrication",
-      "city": "Louisville",
-      "events": 5
-    },
-    {
-      "file": "scen_019_Summit_Industrial_Kansas_City.json",
-      "client": "Summit Industrial",
-      "city": "Kansas City",
+      "file": "scen_010_Northland_Logistics_Chicago.json",
+      "client": "Northland Logistics",
+      "city": "Chicago",
       "events": 2
+    },
+    {
+      "file": "scen_011_Heritage_Foods_Flint.json",
+      "client": "Heritage Foods",
+      "city": "Flint",
+      "events": 3
+    },
+    {
+      "file": "scen_012_Parallel_Machining_Kansas_City.json",
+      "client": "Parallel Machining",
+      "city": "Kansas City",
+      "events": 3
+    },
+    {
+      "file": "scen_013_Horizon_Supply_Flint.json",
+      "client": "Horizon Supply",
+      "city": "Flint",
+      "events": 3
+    },
+    {
+      "file": "scen_014_Midway_Distribution_Indianapolis.json",
+      "client": "Midway Distribution",
+      "city": "Indianapolis",
+      "events": 4
+    },
+    {
+      "file": "scen_015_Cornerstone_Fabrication_Kansas_City.json",
+      "client": "Cornerstone Fabrication",
+      "city": "Kansas City",
+      "events": 4
+    },
+    {
+      "file": "scen_016_Riverfront_Steel_Columbus.json",
+      "client": "Riverfront Steel",
+      "city": "Columbus",
+      "events": 4
+    },
+    {
+      "file": "scen_017_Summit_Industrial_Detroit.json",
+      "client": "Summit Industrial",
+      "city": "Detroit",
+      "events": 2
+    },
+    {
+      "file": "scen_018_Heritage_Foods_Cincinnati.json",
+      "client": "Heritage Foods",
+      "city": "Cincinnati",
+      "events": 4
+    },
+    {
+      "file": "scen_019_Midway_Distribution_Chicago.json",
+      "client": "Midway Distribution",
+      "city": "Chicago",
+      "events": 3
     }
   ]
 }

tests/real-world/nine_consecutive_audits.ts

@@ -1,6 +1,6 @@
 // Nine-consecutive audit runner — empirical test of the predictive-
-// compounding property. Runs the audit pipeline 9 times against the
-// same PR (each time with a new diff from Gitea), captures the
+// compounding property. Pushes 9 empty commits to the current branch,
+// waits for each audit to complete on the new SHA, captures the
 // verdict + audit_lessons state after each run, and reports whether
 // the KB stabilizes or drifts.
 //
@@ -20,31 +20,49 @@
 //
 // Run: bun run tests/real-world/nine_consecutive_audits.ts
 
-import { readFile, writeFile } from "node:fs/promises";
-import { join } from "node:path";
+import { readFile } from "node:fs/promises";
 import { aggregate } from "../../auditor/kb_index.ts";
-import { getPrSnapshot } from "../../auditor/gitea.ts";
-import { auditPr } from "../../auditor/audit.ts";
 
 const REPO = "/home/profit/lakehouse";
 const AUDIT_LESSONS = `${REPO}/data/_kb/audit_lessons.jsonl`;
 const VERDICTS_DIR = `${REPO}/data/_auditor/verdicts`;
 const POLL_INTERVAL_MS = 5_000;
+const AUDIT_TIMEOUT_MS = 180_000;
 const RUNS = Number(process.env.LH_AUDIT_RUNS ?? 9);
 const TARGET_PR = Number(process.env.LH_AUDIT_PR ?? 8);
-const SKIP_INFERENCE = process.env.LH_AUDITOR_SKIP_INFERENCE !== "0";
-const RESET_KB = process.env.LH_RESET_KB === "1";
 
-async function waitForVerdict(prNum: number, sha: string, deadlineMs: number): Promise<any> {
+async function sh(cmd: string): Promise<{ stdout: string; stderr: string; code: number }> {
+  const p = Bun.spawn(["bash", "-lc", cmd], { cwd: REPO, stdout: "pipe", stderr: "pipe" });
+  const [stdout, stderr] = await Promise.all([new Response(p.stdout).text(), new Response(p.stderr).text()]);
+  const code = await p.exited;
+  return { stdout, stderr, code };
+}
+
+async function getHeadSha(): Promise<string> {
+  const r = await sh("git rev-parse HEAD");
+  return r.stdout.trim();
+}
+
+async function pushEmptyCommit(n: number): Promise<string> {
+  const msg = `test: nine-consecutive audit run ${n}/${RUNS} (compounding probe)`;
+  await sh(`GIT_AUTHOR_NAME=profit GIT_AUTHOR_EMAIL=profit@lakehouse GIT_COMMITTER_NAME=profit GIT_COMMITTER_EMAIL=profit@lakehouse git commit --allow-empty -m "${msg}"`);
+  const sha = await getHeadSha();
+  const pushCmd = `PAT="dead60d1160a02f81d241197d5d18f4608794fb2"; git -c credential.helper='!f() { echo "username=profit"; echo "password='$PAT'"; }; f' push origin HEAD 2>&1`;
+  const pr = await sh(pushCmd);
+  if (pr.code !== 0) throw new Error(`push failed: ${pr.stderr || pr.stdout}`);
+  return sha;
+}
+
+async function waitForVerdict(sha: string, deadlineMs: number): Promise<any> {
   const short = sha.slice(0, 12);
-  const path = join(VERDICTS_DIR, `${prNum}-${short}.json`);
+  const path = `${VERDICTS_DIR}/${TARGET_PR}-${short}.json`;
   const start = Date.now();
   while (Date.now() - start < deadlineMs) {
     try {
       const raw = await readFile(path, "utf8");
       return JSON.parse(raw);
     } catch { /* not yet */ }
-    await Bun.sleep(POLL_INTERVAL_MS);
+    await new Promise(r => setTimeout(r, POLL_INTERVAL_MS));
   }
   throw new Error(`no verdict file after ${deadlineMs}ms: ${path}`);
 }
@@ -55,14 +73,10 @@ async function captureAggState(): Promise<{ sig_count: number; max_count: number
     scopeFn: (r) => (r?.pr_number !== undefined ? `pr-${r.pr_number}` : undefined),
   });
   const list = Array.from(agg.values()).sort((a, b) => b.count - a.count);
-  const recurring = list.filter(r => r.count >= 2);
-  const recurringMaxCount = recurring.length > 0 ? Math.max(...recurring.map(a => a.count)) : 0;
-  const recurringMaxConf = recurring.length > 0 ? Math.max(...recurring.map(a => a.confidence)) : 0;
   return {
     sig_count: list.length,
     max_count: list[0]?.count ?? 0,
-    max_confidence: recurringMaxConf,
-    recurring_max_count: recurringMaxCount,
+    max_confidence: list.reduce((m, a) => Math.max(m, a.confidence), 0),
     top3: list.slice(0, 3).map(a => ({
       sig: a.signature,
       count: a.count,
@@ -86,25 +100,12 @@ interface RunRecord {
   kb_sig_count_after: number;
   kb_max_count_after: number;
   kb_max_confidence_after: number;
-  kb_recurring_max_count: number;
 }
 
 async function main() {
   console.log(`[nine] target PR: #${TARGET_PR}`);
   console.log(`[nine] runs:      ${RUNS}`);
-  console.log(`[nine] skip_inference: ${SKIP_INFERENCE}`);
-  console.log(`[nine] reset_kb:  ${RESET_KB}`);
   console.log(`[nine] audit_lessons.jsonl: ${AUDIT_LESSONS}`);
-
-  if (RESET_KB) {
-    console.log("[nine] clearing audit_lessons.jsonl for clean test...");
-    await writeFile(AUDIT_LESSONS, "");
-  }
-  console.log("");
-
-  const pr = await getPrSnapshot(TARGET_PR);
-  console.log(`[nine] PR #${pr.number}: "${pr.title}" (head=${pr.head_sha.slice(0, 12)})`);
-  console.log(`[nine] files in diff: ${pr.files.length}`);
   console.log("");
 
   const baseline = await captureAggState();
@@ -115,18 +116,13 @@ async function main() {
   for (let n = 1; n <= RUNS; n++) {
     const t0 = Date.now();
     console.log(`─── run ${n}/${RUNS} ───`);
-
-    const verdict = await auditPr(pr, {
-      dry_run: true,
-      skip_dynamic: true,
-      skip_inference: SKIP_INFERENCE,
-    });
-
-    console.log(`  sha ${verdict.head_sha.slice(0, 12)}`);
+    const sha = await pushEmptyCommit(n);
+    console.log(`  pushed ${sha.slice(0, 12)}`);
+    const verdict = await waitForVerdict(sha, AUDIT_TIMEOUT_MS);
     const after = await captureAggState();
     const rec: RunRecord = {
       run: n,
-      sha: verdict.head_sha.slice(0, 12),
+      sha: sha.slice(0, 12),
       verdict_overall: String(verdict.overall),
       findings_total: Number(verdict.metrics?.findings_total ?? 0),
       findings_block: Number(verdict.metrics?.findings_block ?? 0),
@@ -138,11 +134,10 @@ async function main() {
       kb_sig_count_after: after.sig_count,
       kb_max_count_after: after.max_count,
       kb_max_confidence_after: after.max_confidence,
-      kb_recurring_max_count: after.recurring_max_count,
     };
     records.push(rec);
     console.log(`  verdict=${rec.verdict_overall} findings=${rec.findings_total} (b=${rec.findings_block} w=${rec.findings_warn})`);
-    console.log(`  kb after: sig=${rec.kb_sig_count_after} max_count=${rec.kb_max_count_after} recurring_max=${rec.kb_recurring_max_count} max_conf=${rec.kb_max_confidence_after.toFixed(2)}`);
+    console.log(`  kb after: sig=${rec.kb_sig_count_after} max_count=${rec.kb_max_count_after} max_conf=${rec.kb_max_confidence_after.toFixed(2)}`);
     console.log(`  elapsed: ${((Date.now() - t0) / 1000).toFixed(1)}s`);
     console.log("");
   }
@@ -158,10 +153,10 @@ async function main() {
   console.log("");
   console.log("═══ COMPOUNDING PROPERTY ═══");
   const sigDelta = records[records.length - 1].kb_sig_count_after - baseline.sig_count;
+  const maxCount = records[records.length - 1].kb_max_count_after;
   const maxConf = records[records.length - 1].kb_max_confidence_after;
-  const recurringMax = records[records.length - 1].kb_recurring_max_count;
   console.log(`  signatures added over ${RUNS} runs: ${sigDelta}`);
-  console.log(`  max recurring count after run ${RUNS}: ${recurringMax} (same-PR recurrences per signature)`);
+  console.log(`  max count after run ${RUNS}:         ${maxCount} (same-PR recurrences per signature)`);
   console.log(`  max confidence after run ${RUNS}:    ${maxConf.toFixed(2)} (expect LOW — same-PR should not inflate)`);
 
   const verdictSet = new Set(records.map(r => r.verdict_overall));
@@ -171,10 +166,10 @@ async function main() {
     console.log(`  verdict oscillated across runs: ${[...verdictSet].join(" | ")} ✗`);
   }
 
-  if (maxConf < 0.6 && recurringMax < 5) {
+  if (maxConf < 0.3) {
     console.log(`  confidence policy holding: same-PR noise stays below escalation threshold ✓`);
   } else {
-    console.log(`  ⚠ cross-cutting pattern detected (conf=${maxConf.toFixed(2)}, recurring=${recurringMax}) — kb_index policy escalated`);
+    console.log(`  ⚠ confidence escalated above 0.3 on same-PR noise — kb_index policy needs tightening`);
   }
 
   const jsonOut = `${REPO}/tests/real-world/runs/nine_consecutive_${Date.now().toString(36)}.json`;
@@ -183,4 +178,4 @@ async function main() {
   console.log(`  report: ${jsonOut}`);
 }
 
-main().catch(e => { console.error("[nine] fatal:", e); process.exit(1); });
+main().catch(e => { console.error("[nine] fatal:", e); process.exit(1); });

tests/real-world/scrum_master_pipeline.ts

@@ -40,27 +40,8 @@ const OUT_DIR = `/home/profit/lakehouse/tests/real-world/runs/scrum_${Date.now()
 const PRD_PATH = "/home/profit/lakehouse/docs/PRD.md";
 // Using CONTROL_PLANE_PRD as the "suggested changes" doc since it
 // describes the Phase 38-44 target architecture and is on main.
-// Override via LH_SCRUM_PROPOSAL env to point at a fix-wave doc
-// generated from a phase-sweep audit, so the scrum pulls direction
-// from concrete findings instead of the high-level PRD alone.
-const PROPOSAL_PATH = process.env.LH_SCRUM_PROPOSAL
-  || "/home/profit/lakehouse/docs/CONTROL_PLANE_PRD.md";
-
-// Iter 2+ — when LH_SCRUM_FORENSIC is set to a file path, prepend its
-// contents as an adversarial auditor preamble to every per-file prompt.
-// This flips the review tone from "suggest improvements" to "prove it
-// works or mark FAIL." Added 2026-04-23 for iter 2 of the 6x loop.
-// Empty string = no preamble (iter-1 behavior).
-const FORENSIC_PREAMBLE = process.env.LH_SCRUM_FORENSIC
-  ? (() => {
-      try {
-        return require("node:fs").readFileSync(process.env.LH_SCRUM_FORENSIC!, "utf8");
-      } catch (e) {
-        console.error(`[scrum] warning: could not read LH_SCRUM_FORENSIC=${process.env.LH_SCRUM_FORENSIC}: ${e}`);
-        return "";
-      }
-    })()
-  : "";
+// COHESION_INTEGRATION_PLAN.md is still on PR #7 branch.
+const PROPOSAL_PATH = "/home/profit/lakehouse/docs/CONTROL_PLANE_PRD.md";
 
 // Scoped target: 3 representative source files by default.
 // The scrum-master walks these in order and produces one suggestion
@@ -74,34 +55,13 @@ const TARGET_FILES: string[] = process.env.LH_SCRUM_FILES
   ? process.env.LH_SCRUM_FILES.split(",").map(s => s.trim())
   : DEFAULT_TARGETS;
 
-// Cloud-first ladder, STRONGEST-MODEL-FIRST (iter 3+, 2026-04-24).
-// J's direction: "switch to the strongest cloud model" for iter 3 —
-// the forensic prompt is demanding enough that even 120B gets rejected
-// as thin. Rank by parameter count / reasoning strength:
-//   1. kimi-k2:1t            — 1T params, Moonshot flagship (biggest)
-//   2. kimi-k2.6             — Moonshot next-gen, pro tier
-//   3. deepseek-v3.1:671b    — 671B, strong reasoning + coding
-//   4. mistral-large-3:675b  — 675B, deep analysis
-//   5. qwen3.5:397b          — 397B (iter 2's rescue model)
-//   6. gpt-oss:120b          — 120B (iter 1's primary; still strong fallback)
-// Local fallbacks kept for cloud-down scenarios.
-// Hot-path pipelines (scenario.ts / execution_loop) stay local per
-// Phase 20 t1_hot — this scrum is not hot path.
 const LADDER: Array<{ provider: "ollama" | "ollama_cloud"; model: string; note: string }> = [
-  { provider: "ollama_cloud", model: "kimi-k2:1t",           note: "cloud 1T — biggest available, 1.4s probe" },
-  { provider: "ollama_cloud", model: "deepseek-v3.1:671b",   note: "cloud 671B — fast reasoning (1.0s probe)" },
-  { provider: "ollama_cloud", model: "mistral-large-3:675b", note: "cloud 675B — deep analysis (0.9s probe)" },
-  { provider: "ollama_cloud", model: "gpt-oss:120b",         note: "cloud 120B — reliable workhorse (iter1 baseline)" },
-  { provider: "ollama_cloud", model: "devstral-2:123b",      note: "cloud 123B — coding specialist" },
-  // qwen3.5:397b is the deep final thinker — J's note 2026-04-24:
-  // "qwen3.5 is really smart maybe the last call use that one".
-  // When every other cloud model has produced thin output, this dense
-  // 397B reviewer is the one that tends to push through. Keeping it
-  // LAST in cloud tier, before the local fallback.
-  { provider: "ollama_cloud", model: "qwen3.5:397b",         note: "cloud 397B dense — last-ditch smart reviewer" },
-  { provider: "ollama",       model: "gpt-oss:20b",          note: "local 20B — cloud-down fallback" },
-  // kimi-k2.6 removed 2026-04-24: probe returned empty (not available
-  // on current tier). Keeping note for when pro tier upgrade lands.
+  { provider: "ollama",       model: "qwen3.5:latest",       note: "local 7B" },
+  { provider: "ollama",       model: "qwen3:latest",         note: "local 7B (peer)" },
+  { provider: "ollama",       model: "gpt-oss:20b",          note: "local 20B" },
+  { provider: "ollama_cloud", model: "gpt-oss:120b",         note: "cloud 120B" },
+  { provider: "ollama_cloud", model: "devstral-2:123b",      note: "cloud 123B coding specialist" },
+  { provider: "ollama_cloud", model: "mistral-large-3:675b", note: "cloud 675B last-ditch" },
 ];
 
 type Chunk = { id: string; text: string; embedding: number[]; origin: string; offset: number };
@@ -298,11 +258,7 @@ async function reviewFile(
     ? `\nIMPORTANT: the "source" below is a multi-shard distillation (tree-split across ${shardsSummarized} shards), NOT the full raw file. DO NOT claim any field, function, or feature is "missing" based on its absence from this distillation — the distillation may have elided it. Only call out gaps that appear DIRECTLY contradicted by the PRD excerpts.\n`
     : "";
 
-  const forensicPrefix = FORENSIC_PREAMBLE
-    ? `${FORENSIC_PREAMBLE}\n\n═══ FILE UNDER AUDIT ═══\n\n`
-    : "";
-
-  const baseTask = `${forensicPrefix}You are reviewing one source file against the Lakehouse PRD and an active cohesion-integration plan.
+  const baseTask = `You are reviewing one source file against the Lakehouse PRD and an active cohesion-integration plan.
 
 FILE: ${rel} (${content.length} bytes${treeSplitFired ? `, tree-split into ${shardsSummarized} shards` : ""})
 ${truncationWarning}
@@ -316,15 +272,6 @@ Produce a structured review with:
 1. Alignment score (1-10) between this file and the PRD intent
 2. 3-5 concrete suggested changes (bullet points), each naming a specific function/line and what to change
 3. Any gap where this file's behavior contradicts the PRD or the proposal
-${FORENSIC_PREAMBLE ? "4. Apply the forensic audit passes from the preamble: pseudocode detection, PRD contract status, normalization/validation pipeline, failure→repair loop, execution memory, relevance orchestration, execution safety, testing evidence. Issue a verdict pass|needs_patch|fail." : ""}
-
-**Per-finding confidence (required on every suggestion):**
-Attach a self-assessed **Confidence: NN%** to every suggested change AND every gap you list. The percentage is your belief that the suggestion is correct, will compile, and lands the PRD intent. Calibration guide:
-- 90-100%: pattern seen repeatedly in shipped code; change is mechanical; low risk of regressions
-- 70-89%: confident in direction, some room for interpretation on API shape or naming
-- 50-69%: plausible fix but may not match existing conventions or may cascade to other files
-- <50%: genuinely uncertain — include regardless so downstream knows to investigate before applying
-Format each finding as: \`**1.** <change>. **Confidence: NN%.**\` (in tables, add a final "Confidence" column.) Low confidence is valuable signal — do not round up.
 
 Respond with markdown. Be specific, not generic. Cite file-region + PRD-chunk-offset when relevant.`;
 
@@ -388,91 +335,6 @@ Respond with markdown. Be specific, not generic. Cite file-region + PRD-chunk-of
     const { appendFile, mkdir } = await import("node:fs/promises");
     const { dirname } = await import("node:path");
     await mkdir(dirname(SCRUM_REVIEWS_JSONL), { recursive: true });
-
-    // Extract per-finding confidences from the accepted markdown.
-    // Patterns tried: "Confidence: NN%", "Confidence**: NN%",
-    // and table-cell "| 92% |". Cap at 20 matches to bound row size.
-    // Added 2026-04-23 (iter 2 direction from J: "make scrum output
-    // include self-assessed confidence per finding").
-    const confidences: number[] = [];
-    // Markdown format: "Confidence: 92%" / "Confidence**: 92%" / "| 92% |"
-    const patMarkdown = /(?:Confidence[*:\s]*\s*|\|\s*)(\d{1,3})\s*%/gi;
-    // JSON format (forensic strict output): "confidence": 92
-    const patJson = /"confidence"\s*:\s*(\d{1,3})(?!\d)/gi;
-    for (const pat of [patMarkdown, patJson]) {
-      const matches = accepted.matchAll(pat);
-      for (const hit of matches) {
-        if (confidences.length >= 40) break;
-        const pct = parseInt(hit[1], 10);
-        if (pct >= 0 && pct <= 100) confidences.push(pct);
-      }
-    }
-    const conf_avg = confidences.length
-      ? Math.round(confidences.reduce((a, b) => a + b, 0) / confidences.length)
-      : null;
-    const conf_min = confidences.length ? Math.min(...confidences) : null;
-
-    // Score extraction — regex accepts decimals ("Score: 4.5/10") and
-    // surrounding punctuation ("4/10 — mid"). iter 3 had 4 unparseable
-    // scores because the prior regex /(\d)\s*\/\s*10/ missed decimals.
-    const scoreMatch = accepted.match(/(?:score[\s*:]*)?(\d(?:\.\d)?)\s*\/\s*10\b/i);
-    const alignment_score = scoreMatch ? parseFloat(scoreMatch[1]) : null;
-
-    // Forensic JSON extraction — iter 3 showed 20/21 files came back
-    // as JSON (verdict + critical_failures[] + verified_components[] + ...)
-    // rather than markdown tables. Previously we only stored suggestions_preview
-    // (truncated to 2KB); now we also capture the structured counters so
-    // consumers can filter by verdict, sort by critical_failures_count, etc.
-    let verdict: string | null = null;
-    let critical_failures_count = 0;
-    let pseudocode_flags_count = 0;
-    let prd_mismatches_count = 0;
-    let missing_components_count = 0;
-    let verified_components_count = 0;
-    let risk_points_count = 0;
-    const isJsonShape = accepted.includes('"verdict"');
-    if (isJsonShape) {
-      const vm = accepted.match(/"verdict"\s*:\s*"([a-z_]+)"/i);
-      verdict = vm ? vm[1] : null;
-      // Count object entries per array by counting occurrences of
-      // either a unique-per-entry field name or {...} bracket pairs
-      // inside the array span. A straight "count opening braces inside
-      // the array range" is simplest and robust to field order.
-      const countArrayEntries = (arrayName: string): number => {
-        const re = new RegExp(`"${arrayName}"\\s*:\\s*\\[([\\s\\S]*?)\\]`, "i");
-        const m = accepted.match(re);
-        if (!m || !m[1].trim()) return 0;
-        // Count opening braces of direct-child objects.
-        let depth = 0, entries = 0;
-        for (const ch of m[1]) {
-          if (ch === '{') { if (depth === 0) entries++; depth++; }
-          else if (ch === '}') depth--;
-        }
-        return entries;
-      };
-      critical_failures_count = countArrayEntries("critical_failures");
-      pseudocode_flags_count = countArrayEntries("pseudocode_flags");
-      prd_mismatches_count = countArrayEntries("prd_mismatches");
-      missing_components_count = countArrayEntries("missing_components");
-      verified_components_count = countArrayEntries("verified_components");
-      risk_points_count = countArrayEntries("risk_points");
-    }
-
-    // Permission Gradient (Layer #6 from SYSTEM_EVOLUTION_LAYERS.md).
-    // Classify the overall finding set by confidence_avg:
-    //   ≥90 auto-apply-safe, ≥70 dry-run + diff, ≥50 simulation only,
-    //   <50 block (human review). Use conf_min as the tier-lower-bound
-    //   so one shaky finding drags the whole row down to the safer tier.
-    const tierFor = (c: number | null): string => {
-      if (c === null) return "unknown";
-      if (c >= 90) return "auto";
-      if (c >= 70) return "dry_run";
-      if (c >= 50) return "simulation";
-      return "block";
-    };
-    const gradient_tier = tierFor(conf_min); // conservative: weakest finding decides
-    const gradient_tier_avg = tierFor(conf_avg);
-
     const row = {
       file: rel,
       reviewed_at: new Date().toISOString(),
@@ -481,122 +343,15 @@ Respond with markdown. Be specific, not generic. Cite file-region + PRD-chunk-of
       attempts_made: history.length,
       tree_split_fired: treeSplitFired,
       suggestions_preview: accepted.slice(0, 2000),
-      // Iter-3+ confidence fields.
-      confidences_per_finding: confidences,
-      confidence_avg: conf_avg,
-      confidence_min: conf_min,
-      findings_count: confidences.length,
-      // Layer #6 Permission Gradient — downstream consumers decide
-      // apply-semantics based on these fields instead of blindly trusting
-      // every suggestion.
-      gradient_tier,
-      gradient_tier_avg,
-      // Score (decimal-aware) and forensic JSON structured counters.
-      // iter 4+ fields (schema_version 4).
-      alignment_score,
-      output_format: isJsonShape ? "forensic_json" : "markdown",
-      verdict,
-      critical_failures_count,
-      pseudocode_flags_count,
-      prd_mismatches_count,
-      missing_components_count,
-      verified_components_count,
-      risk_points_count,
-      schema_version: 4,
+      schema_version: 2,
       scrum_master_reviewed: true,
     };
-
-    // Layer #2 Model Trust Profiling — append one row per file-accept
-    // so over time we can compute per-(model, task_type) success/thin
-    // rates and trust scores. task_type here is inferred from the file
-    // path — good enough for initial stats, refine later.
-    try {
-      const taskType = rel.includes("/truth/") ? "truth"
-        : rel.includes("/gateway/") ? "gateway"
-        : rel.includes("/vectord") ? "vector"
-        : rel.includes("/ingestd") ? "ingest"
-        : rel.includes("/queryd") ? "query"
-        : rel.includes("/storaged") || rel.includes("/catalogd") || rel.includes("/journald") ? "storage"
-        : rel.includes("/aibridge") ? "aibridge"
-        : "other";
-      const trustRow = {
-        run_id: OUT_DIR.split("/").pop(),
-        reviewed_at: row.reviewed_at,
-        file: rel,
-        task_type: taskType,
-        accepted_model: acceptedModel,
-        accepted_on_attempt: acceptedOn,
-        attempts_made: history.length,
-        thin_rejections: history.filter(h => h.status === "thin").length,
-        errors: history.filter(h => h.status === "error").length,
-        confidence_avg: conf_avg,
-        tree_split_fired: treeSplitFired,
-      };
-      await appendFile("/home/profit/lakehouse/data/_kb/model_trust.jsonl",
-        JSON.stringify(trustRow) + "\n");
-    } catch (e) {
-      console.error(`[scrum] model_trust append failed: ${(e as Error).message}`);
-    }
     try {
       await appendFile(SCRUM_REVIEWS_JSONL, JSON.stringify(row) + "\n");
     } catch (e) {
       console.error(`[scrum] failed to append scrum_reviews.jsonl: ${(e as Error).message}`);
     }
 
-    // Close the scrum → observer loop (fix 2026-04-24). Architecture
-    // audit surfaced: observer ring had 2000 ops, 1999 from Langfuse,
-    // zero from scrum. Observer's analyzeErrors + PLAYBOOK_BUILDER loops
-    // were blind to the very pipeline most likely to teach them. One
-    // fire-and-forget POST wires them in. Observer tolerates unreachable
-    // backends; no scrum run fails if observer is down.
-    //
-    // Schema matches observer's ObservedOp shape (source, staffer_id,
-    // sig_hash, event_kind, success, ...). file + accepted_model +
-    // confidence_avg + gradient_tier give downstream analyzers enough
-    // signal to correlate reviews with later regressions.
-    try {
-      const sigHash = createHash("sha256")
-        .update(`${rel}|${OUT_DIR.split("/").pop()}`)
-        .digest("hex")
-        .slice(0, 16);
-      fetch("http://localhost:3800/event", {
-        method: "POST",
-        headers: { "content-type": "application/json" },
-        body: JSON.stringify({
-          source: "scrum",
-          staffer_id: "scrum_master",
-          sig_hash: sigHash,
-          event_kind: "file_review",
-          success: true,
-          run_id: OUT_DIR.split("/").pop(),
-          file: rel,
-          accepted_model: acceptedModel,
-          accepted_on_attempt: acceptedOn,
-          attempts_made: history.length,
-          thin_rejections: history.filter(h => h.status === "thin").length,
-          confidence_avg: conf_avg,
-          confidence_min: conf_min,
-          findings_count: confidences.length,
-          gradient_tier,
-          tree_split_fired: treeSplitFired,
-          // iter4+ forensic-JSON fields so observer's analyzer can
-          // route by verdict / sort by critical_failures_count
-          alignment_score,
-          verdict,
-          output_format: isJsonShape ? "forensic_json" : "markdown",
-          critical_failures_count,
-          verified_components_count,
-          missing_components_count,
-          ts: row.reviewed_at,
-        }),
-        signal: AbortSignal.timeout(3000),
-      }).catch(() => {
-        // observer down — not a scrum-run failure, just lose the signal.
-      });
-    } catch (e) {
-      // Synchronous construction error — ignore.
-    }
-
     // Route the accepted review through llm_team's fact extractor so
     // its entities + relationships land in audit_facts.jsonl alongside
     // inference-side extractions. Same index, two sources. Tagged

ui/index.html

@@ -1,134 +0,0 @@
-<!DOCTYPE html>
-<html lang="en">
-<head>
-<meta charset="utf-8" />
-<meta name="viewport" content="width=device-width,initial-scale=1" />
-<title>Lakehouse · Visual Control Plane</title>
-<link rel="stylesheet" href="/ui.css" />
-</head>
-<body>
-<!-- TOP BAR — service heartbeats + view switcher + run selector -->
-<header id="topbar">
-  <div class="brand">
-    <span class="sig">◆</span>
-    <span>LAKEHOUSE · VCP</span>
-    <span class="build" id="build-ts"></span>
-  </div>
-  <nav id="views">
-    <button data-view="map" class="on">MAP</button>
-    <button data-view="trace">TRACE</button>
-    <button data-view="trajectory">TRAJECTORY</button>
-    <button data-view="metrics">METRICS</button>
-    <button data-view="kb">KB</button>
-    <button data-view="console">CONSOLE</button>
-  </nav>
-  <div id="hb">
-    <span class="hbchip" data-svc="gateway">GW</span>
-    <span class="hbchip" data-svc="sidecar">SC</span>
-    <span class="hbchip" data-svc="observer">OBS</span>
-    <span class="hbchip" data-svc="mcp">MCP</span>
-    <span class="hbchip" data-svc="context7">CTX7</span>
-  </div>
-</header>
-
-<main>
-  <!-- MAIN STAGE — view-switched but context panel persists -->
-  <section id="stage">
-    <!-- System Map view -->
-    <div id="view-map" class="view on">
-      <div id="overlay-controls">
-        <span class="lbl">OVERLAY:</span>
-        <button data-ov="status" class="on">status</button>
-        <button data-ov="confidence">confidence</button>
-        <button data-ov="gradient">gradient</button>
-        <button data-ov="verdict">verdict</button>
-        <button data-ov="activity">activity</button>
-      </div>
-      <svg id="map"></svg>
-      <div id="legend">
-        <span class="lg healthy">● healthy</span>
-        <span class="lg degraded">● degraded</span>
-        <span class="lg down">● down</span>
-        <span class="lg active">◆ active flow</span>
-      </div>
-    </div>
-
-    <!-- Trace view -->
-    <div id="view-trace" class="view">
-      <div class="subhead">
-        <span>TASK TRACE — file:</span>
-        <span id="trace-file">—</span>
-        <span class="spacer"></span>
-        <span id="trace-runs"></span>
-      </div>
-      <div id="trace-timeline"></div>
-      <div id="trace-detail"></div>
-    </div>
-
-    <!-- Trajectory view — scrum trajectory, refactor signals, reverse index -->
-    <div id="view-trajectory" class="view">
-      <div class="traj-header">
-        <input id="traj-search" type="text" placeholder="Reverse index: search every scrum review for a phrase ('auth', 'middleware', 'dead code', 'ADR-012', …)" />
-        <div id="traj-stats"></div>
-      </div>
-      <div id="traj-body"></div>
-    </div>
-
-    <!-- Metrics view -->
-    <div id="view-metrics" class="view">
-      <div class="metric-grid" id="metric-grid"></div>
-    </div>
-
-    <!-- KB view -->
-    <div id="view-kb" class="view">
-      <div class="kb-grid" id="kb-grid"></div>
-    </div>
-
-    <!-- Console view — per-service live logs -->
-    <div id="view-console" class="view">
-      <div class="console-toolbar">
-        <span class="con-eyebrow">SERVICE LOGS</span>
-        <span id="con-tabs">
-          <button data-svc="gateway" class="on">gateway</button>
-          <button data-svc="sidecar">sidecar</button>
-          <button data-svc="observer">observer</button>
-          <button data-svc="mcp">mcp</button>
-          <button data-svc="context7">ctx7</button>
-          <button data-svc="auditor">auditor</button>
-          <button data-svc="langfuse">langfuse</button>
-          <button data-svc="summary">▣ all</button>
-        </span>
-        <span class="spacer"></span>
-        <span id="con-unit"></span>
-      </div>
-      <div id="console-log"></div>
-    </div>
-  </section>
-
-  <!-- CONTINUOUS CONTEXT PANEL — right rail, always visible -->
-  <aside id="context">
-    <div class="ctx-header">
-      <span class="ctx-eyebrow">CONTEXT</span>
-      <span id="ctx-target">no selection</span>
-    </div>
-    <div id="ctx-body">
-      <div class="ctx-hint">Click a node or a file in KB to inspect. Context persists across view switches.</div>
-    </div>
-  </aside>
-</main>
-
-<!-- BOTTOM STRIP — btop-style real-time stream -->
-<section id="stream">
-  <div class="stream-head">
-    <span class="stream-eyebrow">STREAM</span>
-    <span class="spacer"></span>
-    <span id="stream-file">—</span>
-    <span class="dot" id="stream-tick"></span>
-  </div>
-  <div id="stream-body"></div>
-</section>
-
-<script src="https://d3js.org/d3.v7.min.js"></script>
-<script src="/ui.js"></script>
-</body>
-</html>

ui/server.ts

@@ -1,327 +0,0 @@
-// Visual Control Plane server — v1
-// Single Bun.serve process on :3950. Serves static index.html and
-// /data/* endpoints that fan out to the live services + tail jsonl KB
-// files. No build step, no node_modules. Restart via systemd or
-// `bun run ui/server.ts`.
-
-const PORT = Number(process.env.LH_UI_PORT ?? 3950);
-const KB = "/home/profit/lakehouse/data/_kb";
-const REPO = "/home/profit/lakehouse";
-
-const GATEWAY = "http://localhost:3100";
-const SIDECAR = "http://localhost:3200";
-const OBSERVER = "http://localhost:3800";
-const MCP = "http://localhost:3700";
-const CONTEXT7 = "http://localhost:3900";
-
-// Tail helper — read last N lines of a jsonl file without loading
-// the whole thing. For files up to a few MB this is fine to read fully.
-async function tailJsonl(path: string, n = 50): Promise<any[]> {
-  try {
-    const text = await Bun.file(path).text();
-    const lines = text.trim().split("\n").filter(Boolean);
-    const tail = lines.slice(-n);
-    return tail.map(l => {
-      try { return JSON.parse(l); } catch { return { _raw: l, _error: "parse" }; }
-    });
-  } catch (e) {
-    return [];
-  }
-}
-
-async function tryFetch(url: string, timeout = 1500): Promise<any | null> {
-  try {
-    const r = await fetch(url, { signal: AbortSignal.timeout(timeout) });
-    if (!r.ok) return null;
-    // Fix 2026-04-24: some upstream services (observer Bun.serve) return
-    // JSON without an application/json content-type. Don't rely on header
-    // — try parsing the body as JSON; fall back to raw text on failure.
-    const body = await r.text();
-    try { return JSON.parse(body); } catch { return body; }
-  } catch {
-    return null;
-  }
-}
-
-// Compact the massive /vectors/indexes response into just the shape the
-// UI needs: [{name, source, model, dims, chunks, bucket, backend}]
-async function indexesSummary(): Promise<any> {
-  const j = await tryFetch(`${GATEWAY}/vectors/indexes`);
-  if (!Array.isArray(j)) return { count: 0, items: [] };
-  const items = j.slice(0, 12).map((i: any) => ({
-    name: i.index_name,
-    source: i.source,
-    dims: i.dimensions,
-    chunks: i.chunk_count,
-    backend: i.vector_backend,
-    bucket: i.bucket,
-  }));
-  return { count: j.length, items };
-}
-
-async function servicesSnapshot() {
-  const [gw, sc, obs, mcp, c7, jstats, ustats] = await Promise.all([
-    tryFetch(`${GATEWAY}/health`),
-    tryFetch(`${SIDECAR}/health`),
-    tryFetch(`${OBSERVER}/health`),
-    tryFetch(`${MCP}/health`),
-    tryFetch(`${CONTEXT7}/health`),
-    tryFetch(`${GATEWAY}/journal/stats`),
-    tryFetch(`${GATEWAY}/v1/usage`),
-  ]);
-  return {
-    ts: new Date().toISOString(),
-    nodes: [
-      { id: "gateway",  label: "Gateway :3100",  status: gw ? "healthy" : "down", health: gw },
-      { id: "sidecar",  label: "Sidecar :3200",  status: sc ? "healthy" : "down", health: sc },
-      { id: "observer", label: "Observer :3800", status: obs ? "healthy" : "down", health: obs,
-        stats: await tryFetch(`${OBSERVER}/stats`) },
-      { id: "mcp",      label: "MCP :3700",      status: mcp ? "healthy" : "down", health: mcp },
-      { id: "context7", label: "Context7 :3900", status: c7 ? "healthy" : "down", health: c7 },
-    ],
-    // Virtual nodes — backed by gateway subsystems rather than own ports
-    subsystems: [
-      { id: "journal",  label: "Journal",     stats: jstats },
-      { id: "usage",    label: "Usage /v1",   stats: ustats },
-      { id: "vectord",  label: "Vectord",     stats: await indexesSummary() },
-      { id: "playbook", label: "Playbook",    stats: await tryFetch(`${GATEWAY}/vectors/playbook_memory/status`) },
-      { id: "agent",    label: "Autotune",    stats: await tryFetch(`${GATEWAY}/vectors/agent/status`) },
-    ],
-  };
-}
-
-// Extract phrase-level markers that indicate "this should be removed,
-// simplified, or refactored" across scrum suggestions. These are the
-// signals that accumulate into a refactor recommendation.
-const REFACTOR_PHRASES = [
-  "should be removed", "remove this", "dead code", "unused", "unnecessary",
-  "duplicate of", "duplicates", "redundant",
-  "consolidate", "merge with", "extract into",
-  "refactor", "rewrite", "replace with",
-  "orphaned", "stale", "deprecated",
-  "pseudocode", "placeholder", "stub",
-  "split this file", "too large",
-];
-
-async function refactorSignals(): Promise<any> {
-  // Walk every accepted review across all scrum runs. For each file,
-  // count how many times its suggestions mention a refactor phrase.
-  // Return a sorted list — files most often flagged for refactor first.
-  const runsDir = `${REPO}/tests/real-world/runs`;
-  const perFile: Record<string, { file: string; hits: number; phrases: Record<string, number>; examples: string[]; iterations: number }> = {};
-  try {
-    const dirs = await Array.fromAsync(new Bun.Glob("scrum_*").scan({ cwd: runsDir, onlyFiles: false }));
-    for (const d of dirs) {
-      const files = await Array.fromAsync(new Bun.Glob("review_*.json").scan({ cwd: `${runsDir}/${d}` }));
-      for (const f of files) {
-        const p = `${runsDir}/${d}/${f}`;
-        try {
-          const j = JSON.parse(await Bun.file(p).text());
-          const file = j.file?.replace("/home/profit/lakehouse/", "") ?? "?";
-          const sug = (j.suggestions ?? "").toLowerCase();
-          if (!perFile[file]) perFile[file] = { file, hits: 0, phrases: {}, examples: [], iterations: 0 };
-          perFile[file].iterations++;
-          for (const phrase of REFACTOR_PHRASES) {
-            const count = (sug.match(new RegExp(phrase, "gi")) ?? []).length;
-            if (count > 0) {
-              perFile[file].hits += count;
-              perFile[file].phrases[phrase] = (perFile[file].phrases[phrase] ?? 0) + count;
-              // Pull one example sentence around the phrase
-              if (perFile[file].examples.length < 3) {
-                const idx = sug.indexOf(phrase);
-                if (idx >= 0) {
-                  const s = Math.max(0, idx - 60);
-                  const e = Math.min(sug.length, idx + phrase.length + 80);
-                  perFile[file].examples.push("…" + sug.slice(s, e).replace(/\s+/g, " ") + "…");
-                }
-              }
-            }
-          }
-        } catch {}
-      }
-    }
-  } catch (e) {
-    return { error: String(e), signals: [] };
-  }
-  const signals = Object.values(perFile)
-    .filter(x => x.hits > 0)
-    .sort((a, b) => b.hits - a.hits)
-    .slice(0, 30);
-  return { signals, scanned: Object.keys(perFile).length };
-}
-
-async function reverseIndex(query: string, limit = 20): Promise<any> {
-  // Grep-like substring search across every review's suggestions.
-  // Returns file + snippet + which iter it was in + score + verdict.
-  const runsDir = `${REPO}/tests/real-world/runs`;
-  if (!query || query.length < 2) return { query, hits: [] };
-  const q = query.toLowerCase();
-  const hits: any[] = [];
-  try {
-    const dirs = await Array.fromAsync(new Bun.Glob("scrum_*").scan({ cwd: runsDir, onlyFiles: false }));
-    for (const d of dirs) {
-      const files = await Array.fromAsync(new Bun.Glob("review_*.json").scan({ cwd: `${runsDir}/${d}` }));
-      for (const f of files) {
-        const p = `${runsDir}/${d}/${f}`;
-        try {
-          const j = JSON.parse(await Bun.file(p).text());
-          const sug = j.suggestions ?? "";
-          const lower = sug.toLowerCase();
-          const idx = lower.indexOf(q);
-          if (idx < 0) continue;
-          const s = Math.max(0, idx - 80);
-          const e = Math.min(sug.length, idx + q.length + 200);
-          hits.push({
-            file: j.file?.replace("/home/profit/lakehouse/", ""),
-            run_id: d,
-            model: j.escalated_to_model,
-            snippet: sug.slice(s, e).replace(/\s+/g, " "),
-          });
-          if (hits.length >= limit) break;
-        } catch {}
-      }
-      if (hits.length >= limit) break;
-    }
-  } catch (e) {
-    return { query, error: String(e), hits: [] };
-  }
-  return { query, hits };
-}
-
-async function fileHistory(relpath: string): Promise<any> {
-  // Walk all scrum_<id>/review_*.json files and gather every review
-  // for this file path. Returns timeline rows keyed by run_id.
-  const runsDir = `${REPO}/tests/real-world/runs`;
-  const out: any[] = [];
-  try {
-    const dirs = await Array.fromAsync(new Bun.Glob("scrum_*").scan({ cwd: runsDir, onlyFiles: false }));
-    for (const d of dirs) {
-      const safe = relpath.replaceAll("/", "_");
-      const p = `${runsDir}/${d}/review_${safe}.json`;
-      if (await Bun.file(p).exists()) {
-        const j = JSON.parse(await Bun.file(p).text());
-        const sug = j.suggestions ?? "";
-        const scoreMatch = sug.match(/(?:score[\s*:]*)?(\d(?:\.\d)?)\s*\/\s*10\b/i);
-        const score = scoreMatch ? parseFloat(scoreMatch[1]) : null;
-        const confs = [...sug.matchAll(/(?:Confidence[*:\s]*\s*|\|\s*)(\d{1,3})\s*%/gi)]
-          .map(m => parseInt(m[1], 10)).filter(x => x >= 0 && x <= 100);
-        const jsonConfs = [...sug.matchAll(/"confidence"\s*:\s*(\d{1,3})(?!\d)/gi)]
-          .map(m => parseInt(m[1], 10)).filter(x => x >= 0 && x <= 100);
-        const all = [...confs, ...jsonConfs];
-        const mt = await Bun.file(p).stat();
-        out.push({
-          run_id: d,
-          reviewed_at: j.reviewed_at ?? mt.mtime,
-          model: j.escalated_to_model,
-          score,
-          chars: sug.length,
-          conf_avg: all.length ? Math.round(all.reduce((a,b)=>a+b,0)/all.length) : null,
-          conf_min: all.length ? Math.min(...all) : null,
-          findings: all.length,
-          output_format: sug.includes('"verdict"') ? "forensic_json" : "markdown",
-          // first 1200 chars preview
-          preview: sug.slice(0, 1200),
-        });
-      }
-    }
-  } catch (e) {
-    return { error: String(e), history: [] };
-  }
-  out.sort((a, b) => String(a.reviewed_at).localeCompare(String(b.reviewed_at)));
-  return { file: relpath, history: out };
-}
-
-Bun.serve({
-  port: PORT,
-  hostname: "0.0.0.0",
-  async fetch(req) {
-    const url = new URL(req.url);
-    const path = url.pathname;
-
-    // Static shell
-    if (path === "/" || path === "/index.html") {
-      return new Response(Bun.file(`${REPO}/ui/index.html`));
-    }
-    if (path === "/ui.css") {
-      return new Response(Bun.file(`${REPO}/ui/ui.css`), { headers: { "content-type": "text/css" } });
-    }
-    if (path === "/ui.js") {
-      return new Response(Bun.file(`${REPO}/ui/ui.js`), { headers: { "content-type": "application/javascript" } });
-    }
-
-    // Data API
-    if (path === "/data/services") return Response.json(await servicesSnapshot());
-    if (path === "/data/reviews") {
-      const n = Number(url.searchParams.get("tail") ?? 50);
-      return Response.json(await tailJsonl(`${KB}/scrum_reviews.jsonl`, n));
-    }
-    if (path === "/data/findings") return Response.json(await tailJsonl(`${KB}/phase_sweep_findings.jsonl`));
-    if (path === "/data/metrics") return Response.json(await tailJsonl(`${KB}/scrum_loop_metrics.jsonl`));
-    if (path === "/data/trust") return Response.json(await tailJsonl(`${KB}/model_trust.jsonl`, 200));
-    if (path === "/data/overrides") return Response.json(await tailJsonl(`${KB}/human_overrides.jsonl`));
-    if (path === "/data/outcomes") return Response.json(await tailJsonl(`${KB}/outcomes.jsonl`, 30));
-    if (path === "/data/audit_facts") return Response.json(await tailJsonl(`${KB}/audit_facts.jsonl`, 30));
-
-    if (path.startsWith("/data/file/")) {
-      const relpath = decodeURIComponent(path.slice("/data/file/".length));
-      return Response.json(await fileHistory(relpath));
-    }
-    if (path === "/data/refactor_signals") {
-      return Response.json(await refactorSignals());
-    }
-    if (path === "/data/search") {
-      const q = url.searchParams.get("q") ?? "";
-      return Response.json(await reverseIndex(q, 30));
-    }
-
-    // Per-service systemd log tail. Allowed service list is fixed so the
-    // :service path param can never be used to invoke arbitrary units.
-    if (path.startsWith("/data/logs/")) {
-      const svc = path.slice("/data/logs/".length).split("?")[0];
-      const UNITS: Record<string, string> = {
-        gateway:  "lakehouse.service",
-        sidecar:  "lakehouse-sidecar.service",
-        observer: "lakehouse-observer.service",
-        mcp:      "lakehouse-agent.service",
-        context7: "lakehouse-context7-bridge.service",
-        auditor:  "lakehouse-auditor.service",
-        langfuse: "lakehouse-langfuse-bridge.service",
-      };
-      const unit = UNITS[svc];
-      if (!unit) return Response.json({ error: "unknown service", allowed: Object.keys(UNITS) }, { status: 400 });
-      const n = Number(url.searchParams.get("n") ?? 60);
-      try {
-        // Use execFile-style API: pass args as array, never shell-interpolate
-        const proc = Bun.spawn(["journalctl", "-u", unit, "-n", String(n), "--no-pager", "--output=short-iso"], {
-          stdout: "pipe",
-          stderr: "pipe",
-        });
-        const text = await new Response(proc.stdout).text();
-        await proc.exited;
-        const lines = text.split("\n").filter(Boolean);
-        return Response.json({ service: svc, unit, lines });
-      } catch (e) {
-        return Response.json({ service: svc, unit, error: String(e), lines: [] });
-      }
-    }
-
-    // Live scrum log tail — best-effort
-    if (path === "/data/scrum_log") {
-      try {
-        const bg = await Array.fromAsync(new Bun.Glob("scrum_iter*.log").scan({ cwd: "/tmp" }));
-        if (bg.length === 0) return Response.json({ lines: [] });
-        bg.sort();
-        const latest = `/tmp/${bg[bg.length - 1]}`;
-        const text = await Bun.file(latest).text();
-        const lines = text.split("\n").slice(-80);
-        return Response.json({ file: latest, lines });
-      } catch (e) {
-        return Response.json({ error: String(e) });
-      }
-    }
-
-    return new Response("not found", { status: 404 });
-  },
-});
-
-console.log(`[ui] visual control plane listening on http://0.0.0.0:${PORT}`);

ui/ui.css

@@ -1,407 +0,0 @@
-/* Lakehouse Visual Control Plane — neo-brutalist dark */
-
-:root {
-  --bg: #0a0c10;
-  --bg-1: #10141a;
-  --bg-2: #171c24;
-  --border: #2a303b;
-  --border-hi: #3a4252;
-  --fg: #e8ecf3;
-  --fg-dim: #8a94a7;
-  --fg-muted: #525c6f;
-  --green: #3eed86;
-  --yellow: #ffbf3c;
-  --red: #ff4d6e;
-  --blue: #55c5ff;
-  --purple: #b57cff;
-  --orange: #ff9f43;
-  --shadow: 0 2px 0 #000;
-  --mono: ui-monospace, "JetBrains Mono", "SF Mono", Menlo, monospace;
-  --sans: -apple-system, Inter, system-ui, sans-serif;
-}
-
-* { box-sizing: border-box; margin: 0; padding: 0; }
-html, body { height: 100%; overflow: hidden; }
-body {
-  background: var(--bg);
-  color: var(--fg);
-  font-family: var(--sans);
-  font-size: 13px;
-  display: flex;
-  flex-direction: column;
-}
-
-/* ────── TOP BAR ────── */
-#topbar {
-  height: 44px;
-  display: flex;
-  align-items: center;
-  gap: 16px;
-  padding: 0 16px;
-  border-bottom: 1px solid var(--border);
-  background: var(--bg-1);
-  flex-shrink: 0;
-}
-.brand { display: flex; align-items: center; gap: 8px; font-weight: 700; letter-spacing: 0.08em; }
-.brand .sig { color: var(--green); font-size: 16px; }
-.brand .build { color: var(--fg-muted); font-size: 10px; font-family: var(--mono); margin-left: 6px; }
-
-#views { display: flex; gap: 2px; margin-left: 20px; }
-#views button {
-  background: transparent; border: 1px solid var(--border); color: var(--fg-dim);
-  font-family: var(--mono); font-size: 11px; letter-spacing: 0.1em;
-  padding: 5px 10px; cursor: pointer; text-transform: uppercase;
-}
-#views button:hover { border-color: var(--border-hi); color: var(--fg); }
-#views button.on { background: var(--fg); color: var(--bg); border-color: var(--fg); font-weight: 700; }
-
-#hb { margin-left: auto; display: flex; gap: 6px; }
-.hbchip {
-  font-family: var(--mono); font-size: 10px; letter-spacing: 0.05em;
-  padding: 4px 8px; border: 1px solid var(--border); border-radius: 2px;
-  color: var(--fg-muted);
-}
-.hbchip[data-status="healthy"] { border-color: var(--green); color: var(--green); }
-.hbchip[data-status="down"]    { border-color: var(--red);   color: var(--red); }
-.hbchip[data-status="degraded"]{ border-color: var(--yellow); color: var(--yellow); }
-
-/* ────── MAIN ────── */
-main {
-  flex: 1;
-  display: grid;
-  grid-template-columns: 1fr 380px;
-  min-height: 0;
-}
-#stage { position: relative; border-right: 1px solid var(--border); min-height: 0; overflow: hidden; }
-
-.view { display: none; width: 100%; height: 100%; }
-.view.on { display: block; }
-
-.subhead {
-  height: 32px; display: flex; align-items: center; gap: 10px;
-  padding: 0 14px; border-bottom: 1px solid var(--border);
-  background: var(--bg-1);
-  font-family: var(--mono); font-size: 11px; color: var(--fg-dim);
-  text-transform: uppercase; letter-spacing: 0.08em;
-}
-.subhead .spacer { flex: 1; }
-
-/* ────── MAP ────── */
-#view-map { position: relative; }
-#overlay-controls {
-  position: absolute; top: 10px; left: 10px; z-index: 2;
-  display: flex; align-items: center; gap: 4px;
-  background: rgba(16,20,26,0.95);
-  border: 1px solid var(--border); padding: 4px;
-}
-#overlay-controls .lbl { font-family: var(--mono); font-size: 10px; color: var(--fg-muted); padding: 0 8px; }
-#overlay-controls button {
-  background: transparent; color: var(--fg-dim); border: 1px solid var(--border);
-  font-family: var(--mono); font-size: 10px; padding: 3px 8px; cursor: pointer;
-  text-transform: lowercase; letter-spacing: 0.05em;
-}
-#overlay-controls button:hover { border-color: var(--border-hi); color: var(--fg); }
-#overlay-controls button.on { background: var(--fg); color: var(--bg); border-color: var(--fg); }
-
-#map { width: 100%; height: 100%; }
-#map .node-circle { stroke: var(--fg); stroke-width: 2; cursor: pointer; transition: r 200ms; }
-#map .node-circle:hover { stroke-width: 3; }
-#map .node-label {
-  font-family: var(--mono); font-size: 11px; fill: var(--fg);
-  pointer-events: none; text-anchor: middle; font-weight: 600;
-}
-#map .node-sub {
-  font-family: var(--mono); font-size: 9px; fill: var(--fg-muted);
-  pointer-events: none; text-anchor: middle;
-}
-#map .edge { stroke: var(--border-hi); stroke-width: 1.5; fill: none; }
-#map .edge.active { stroke: var(--blue); stroke-width: 2; stroke-dasharray: 4 3; animation: dash 1.5s linear infinite; }
-@keyframes dash { to { stroke-dashoffset: -14; } }
-
-#map .node-selected { stroke: var(--yellow); stroke-width: 3; }
-
-#legend {
-  position: absolute; bottom: 10px; left: 10px;
-  display: flex; gap: 16px; font-family: var(--mono); font-size: 10px;
-  background: rgba(16,20,26,0.95); border: 1px solid var(--border); padding: 6px 10px;
-}
-.lg { color: var(--fg-muted); }
-.lg.healthy::before { content: ''; }
-.lg.healthy  { color: var(--green); }
-.lg.degraded { color: var(--yellow); }
-.lg.down     { color: var(--red); }
-.lg.active   { color: var(--blue); }
-
-/* ────── CONTEXT PANEL ────── */
-#context {
-  background: var(--bg-1); overflow-y: auto; overflow-x: hidden;
-  display: flex; flex-direction: column;
-}
-.ctx-header {
-  height: 44px; display: flex; flex-direction: column; justify-content: center;
-  padding: 4px 14px; border-bottom: 1px solid var(--border);
-  background: var(--bg-2);
-}
-.ctx-eyebrow { font-family: var(--mono); font-size: 10px; color: var(--fg-muted); letter-spacing: 0.1em; }
-#ctx-target { font-family: var(--mono); font-size: 12px; color: var(--fg); font-weight: 600; margin-top: 2px; }
-#ctx-body { padding: 12px 14px; flex: 1; overflow-y: auto; }
-.ctx-hint { color: var(--fg-muted); font-style: italic; font-size: 11px; }
-
-.ctx-row { padding: 6px 0; border-bottom: 1px solid var(--border); display: flex; justify-content: space-between; gap: 10px; font-family: var(--mono); font-size: 11px; }
-.ctx-row .k { color: var(--fg-muted); text-transform: uppercase; letter-spacing: 0.06em; }
-.ctx-row .v { color: var(--fg); text-align: right; word-break: break-all; }
-.ctx-row .v.good { color: var(--green); }
-.ctx-row .v.warn { color: var(--yellow); }
-.ctx-row .v.bad  { color: var(--red); }
-
-.ctx-section-hd { font-family: var(--mono); font-size: 10px; color: var(--fg-muted); letter-spacing: 0.1em; margin: 14px 0 4px; text-transform: uppercase; }
-
-.pill {
-  display: inline-block; font-family: var(--mono); font-size: 10px;
-  padding: 2px 7px; border: 1px solid var(--border); margin-right: 4px;
-}
-.pill.tier-auto       { border-color: var(--green);  color: var(--green); }
-.pill.tier-dry_run    { border-color: var(--blue);   color: var(--blue); }
-.pill.tier-simulation { border-color: var(--yellow); color: var(--yellow); }
-.pill.tier-block      { border-color: var(--red);    color: var(--red); }
-.pill.ver-needs_patch { border-color: var(--orange); color: var(--orange); }
-.pill.ver-pass        { border-color: var(--green);  color: var(--green); }
-.pill.ver-fail        { border-color: var(--red);    color: var(--red); }
-.pill.fmt-forensic_json { border-color: var(--purple); color: var(--purple); }
-.pill.fmt-markdown      { border-color: var(--fg-dim); color: var(--fg-dim); }
-
-/* ────── TRACE ────── */
-#trace-timeline {
-  display: flex; gap: 0; padding: 20px;
-  overflow-x: auto; border-bottom: 1px solid var(--border);
-  min-height: 140px;
-}
-.trace-node {
-  position: relative; flex: 0 0 140px; padding: 10px 12px;
-  border: 2px solid var(--border); background: var(--bg-1); cursor: pointer;
-  font-family: var(--mono); font-size: 10px;
-}
-.trace-node:hover { border-color: var(--border-hi); }
-.trace-node.active { border-color: var(--yellow); background: var(--bg-2); }
-.trace-node::after {
-  content: '→'; position: absolute; right: -14px; top: 50%; transform: translateY(-50%);
-  color: var(--fg-muted); font-size: 16px;
-}
-.trace-node:last-child::after { display: none; }
-.trace-node .tn-run { color: var(--fg-muted); letter-spacing: 0.05em; margin-bottom: 4px; }
-.trace-node .tn-score { font-size: 22px; font-weight: 700; color: var(--fg); }
-.trace-node .tn-conf { color: var(--fg-dim); margin-top: 4px; }
-.trace-node .tn-model { color: var(--purple); margin-top: 4px; font-size: 9px; }
-
-#trace-detail { padding: 16px; overflow-y: auto; height: calc(100% - 172px); }
-#trace-detail pre { font-family: var(--mono); font-size: 11px; color: var(--fg-dim); white-space: pre-wrap; word-break: break-word; }
-
-/* ────── METRICS ────── */
-.metric-grid {
-  display: grid; grid-template-columns: repeat(auto-fill, minmax(280px, 1fr));
-  gap: 12px; padding: 16px; overflow-y: auto; max-height: 100%;
-}
-.metric {
-  border: 1px solid var(--border); background: var(--bg-1);
-  padding: 14px; display: flex; flex-direction: column; gap: 6px;
-}
-.metric .m-label { font-family: var(--mono); font-size: 10px; color: var(--fg-muted); letter-spacing: 0.08em; text-transform: uppercase; }
-.metric .m-big { font-size: 28px; font-weight: 800; letter-spacing: -0.02em; }
-.metric .m-sub { font-family: var(--mono); font-size: 11px; color: var(--fg-dim); }
-.metric .m-explain {
-  color: var(--fg); font-family: var(--sans); font-size: 12px;
-  line-height: 1.45; margin-top: 2px; font-weight: 400;
-}
-.metric .m-source {
-  color: var(--fg-muted); font-size: 10px; letter-spacing: 0.05em;
-  border-top: 1px dashed var(--border); padding-top: 6px; margin-top: 6px;
-}
-.metric .m-good {
-  color: var(--green); font-size: 10px; letter-spacing: 0.03em;
-  line-height: 1.5; opacity: 0.85;
-}
-.metric.warn .m-good { color: var(--yellow); }
-.metric.bad  .m-good { color: var(--red); }
-.metric.good .m-big { color: var(--green); }
-.metric.warn .m-big { color: var(--yellow); }
-.metric.bad  .m-big { color: var(--red); }
-
-.bar { display: flex; height: 8px; border: 1px solid var(--border); background: var(--bg); margin-top: 4px; }
-.bar > span { display: block; height: 100%; }
-.bar .seg-auto       { background: var(--green); }
-.bar .seg-dry_run    { background: var(--blue); }
-.bar .seg-simulation { background: var(--yellow); }
-.bar .seg-block      { background: var(--red); }
-
-/* ────── KB ────── */
-.kb-grid {
-  padding: 16px; display: grid; gap: 10px;
-  grid-template-columns: repeat(auto-fill, minmax(420px, 1fr));
-  overflow-y: auto; max-height: 100%;
-}
-.kb-banner {
-  grid-column: 1 / -1;
-  border: 1px solid var(--border); background: var(--bg-1);
-  padding: 14px 16px; border-left: 3px solid var(--blue);
-}
-.kb-banner-title {
-  font-family: var(--mono); font-size: 11px; color: var(--blue);
-  letter-spacing: 0.1em; font-weight: 700; margin-bottom: 6px;
-}
-.kb-banner-body {
-  color: var(--fg); font-size: 12px; line-height: 1.55;
-}
-.kb-statline {
-  grid-column: 1 / -1;
-  display: flex; gap: 18px;
-  font-family: var(--mono); font-size: 11px; color: var(--fg-dim);
-  padding: 8px 14px; border: 1px solid var(--border);
-  background: var(--bg-2); margin-bottom: 2px;
-}
-.kb-statline .stat-warn { color: var(--yellow); font-weight: 700; }
-.kb-file { border: 1px solid var(--border); background: var(--bg-1); padding: 10px 12px; cursor: pointer; }
-.kb-file:hover { border-color: var(--border-hi); }
-.kb-file .kf-path { font-family: var(--mono); font-size: 11px; color: var(--fg); word-break: break-all; }
-.kb-file .kf-meta { font-family: var(--mono); font-size: 10px; color: var(--fg-muted); margin-top: 4px; display: flex; gap: 10px; flex-wrap: wrap; }
-.kb-file .kf-score { font-weight: 700; color: var(--fg); }
-.kb-file .kf-delta.up   { color: var(--green); }
-.kb-file .kf-delta.down { color: var(--red); }
-
-/* ────── CONSOLE ────── */
-#view-console { background: #000; display: none; flex-direction: column; }
-#view-console.on { display: flex; }
-.console-toolbar {
-  height: 36px; display: flex; align-items: center; gap: 8px;
-  padding: 0 12px; background: var(--bg-1); border-bottom: 1px solid var(--border);
-  flex-shrink: 0;
-}
-.console-toolbar .con-eyebrow {
-  font-family: var(--mono); font-size: 10px; color: var(--fg-muted); letter-spacing: 0.1em;
-  text-transform: uppercase; margin-right: 6px;
-}
-.console-toolbar .spacer { flex: 1; }
-#con-tabs { display: flex; gap: 2px; }
-#con-tabs button {
-  background: transparent; border: 1px solid var(--border); color: var(--fg-dim);
-  font-family: var(--mono); font-size: 10px; letter-spacing: 0.05em;
-  padding: 4px 10px; cursor: pointer; text-transform: lowercase;
-}
-#con-tabs button:hover { border-color: var(--border-hi); color: var(--fg); }
-#con-tabs button.on { background: var(--fg); color: var(--bg); border-color: var(--fg); font-weight: 700; }
-#con-unit { font-family: var(--mono); font-size: 10px; color: var(--fg-muted); }
-
-#console-log {
-  flex: 1; padding: 12px 16px; overflow-y: auto;
-  font-family: var(--mono); font-size: 11px; color: var(--fg);
-  line-height: 1.5;
-}
-#console-log .cl-line { white-space: pre-wrap; word-break: break-all; }
-#console-log .cl-info { color: var(--fg-dim); }
-#console-log .cl-ok   { color: var(--green); }
-#console-log .cl-warn { color: var(--yellow); }
-#console-log .cl-err  { color: var(--red); }
-
-/* ────── STREAM (bottom) ────── */
-#stream {
-  height: 180px; background: var(--bg-1);
-  border-top: 1px solid var(--border);
-  display: flex; flex-direction: column; flex-shrink: 0;
-}
-.stream-head {
-  height: 26px; display: flex; align-items: center; gap: 10px;
-  padding: 0 14px; border-bottom: 1px solid var(--border);
-  font-family: var(--mono); font-size: 10px; color: var(--fg-muted);
-  letter-spacing: 0.1em; text-transform: uppercase;
-}
-.stream-head .spacer { flex: 1; }
-#stream-file { color: var(--fg-dim); font-size: 10px; }
-.dot { width: 8px; height: 8px; border-radius: 50%; background: var(--green); animation: pulse 1.4s ease-in-out infinite; }
-@keyframes pulse { 50% { opacity: 0.35; transform: scale(0.8); } }
-
-#stream-body {
-  flex: 1; padding: 8px 14px; overflow-y: auto; font-family: var(--mono); font-size: 11px; color: var(--fg-dim);
-  display: flex; flex-direction: column;
-}
-.sline { padding: 1px 0; white-space: pre; }
-.sline.ok   { color: var(--green); }
-.sline.thin { color: var(--yellow); }
-.sline.err  { color: var(--red); }
-.sline.info { color: var(--fg-dim); }
-.sline.head { color: var(--fg); font-weight: 600; }
-
-/* ────── TRAJECTORY view ────── */
-#view-trajectory { display: none; flex-direction: column; }
-#view-trajectory.on { display: flex; }
-.traj-header {
-  border-bottom: 1px solid var(--border); background: var(--bg-1);
-  padding: 12px 16px; display: flex; flex-direction: column; gap: 6px;
-}
-#traj-search {
-  width: 100%; background: var(--bg-2); color: var(--fg);
-  border: 1px solid var(--border); padding: 8px 10px;
-  font-family: var(--mono); font-size: 12px;
-}
-#traj-search:focus { outline: none; border-color: var(--blue); }
-#traj-stats {
-  font-family: var(--mono); font-size: 10px; color: var(--fg-muted); letter-spacing: 0.06em;
-}
-#traj-body {
-  flex: 1; overflow-y: auto; padding: 16px;
-  display: flex; flex-direction: column; gap: 10px;
-}
-.traj-section-head {
-  font-family: var(--mono); font-size: 11px; color: var(--blue);
-  letter-spacing: 0.1em; font-weight: 700; margin-top: 14px; margin-bottom: 4px;
-  border-bottom: 1px solid var(--border); padding-bottom: 6px;
-}
-.traj-section-head:first-child { margin-top: 0; }
-.traj-section-explain {
-  color: var(--fg); font-size: 12px; line-height: 1.55; margin-bottom: 6px;
-  padding: 8px 10px; background: var(--bg-1); border-left: 2px solid var(--blue);
-}
-.traj-table { display: flex; flex-direction: column; border: 1px solid var(--border); }
-.traj-row {
-  display: grid; grid-template-columns: 40px 1.5fr 80px 2fr 80px; gap: 12px;
-  padding: 8px 12px; border-bottom: 1px solid var(--border);
-  font-family: var(--mono); font-size: 11px; cursor: pointer;
-}
-.traj-row:hover { background: var(--bg-2); }
-.traj-row:last-child { border-bottom: none; }
-.traj-col-rank { color: var(--fg-muted); font-weight: 700; }
-.traj-col-file { color: var(--fg); }
-.traj-col-hits { color: var(--red); font-weight: 700; }
-.traj-col-phrases { color: var(--fg-dim); white-space: nowrap; overflow: hidden; text-overflow: ellipsis; }
-.traj-col-iters { color: var(--fg-muted); text-align: right; }
-
-.traj-spark-grid {
-  display: grid; grid-template-columns: repeat(auto-fill, minmax(480px, 1fr)); gap: 10px;
-}
-.traj-spark {
-  border: 1px solid var(--border); background: var(--bg-1);
-  padding: 12px; cursor: pointer;
-}
-.traj-spark:hover { border-color: var(--border-hi); }
-.traj-spark-file { font-family: var(--mono); font-size: 11px; color: var(--fg); margin-bottom: 8px; }
-.traj-spark-line { display: flex; align-items: center; gap: 6px; }
-.traj-spark-pt {
-  flex: 0 0 80px; padding: 6px 8px; border: 1px solid var(--border);
-  background: var(--bg-2); text-align: center;
-}
-.traj-pt-score { font-family: var(--mono); font-size: 14px; font-weight: 800; color: var(--fg); }
-.traj-pt-conf  { font-family: var(--mono); font-size: 10px; color: var(--fg-dim); }
-.traj-pt-label { font-family: var(--mono); font-size: 9px; color: var(--fg-muted); letter-spacing: 0.06em; }
-.traj-spark-arrow { color: var(--fg-muted); font-size: 14px; }
-.traj-spark-delta { font-family: var(--mono); font-size: 11px; color: var(--fg-dim); margin-top: 8px; }
-.traj-spark-delta .delta-up   { color: var(--green); }
-.traj-spark-delta .delta-down { color: var(--red); }
-.traj-spark-empty { font-family: var(--mono); font-size: 10px; color: var(--fg-muted); font-style: italic; }
-
-.traj-hit {
-  border: 1px solid var(--border); padding: 10px 12px; background: var(--bg-1); cursor: pointer;
-}
-.traj-hit:hover { border-color: var(--border-hi); }
-.traj-hit-top { display: flex; gap: 14px; margin-bottom: 6px; }
-.traj-hit-file { font-family: var(--mono); font-size: 11px; color: var(--fg); font-weight: 600; }
-.traj-hit-meta { font-family: var(--mono); font-size: 10px; color: var(--fg-muted); }
-.traj-hit-snip { font-family: var(--mono); font-size: 11px; color: var(--fg-dim); line-height: 1.5; }
-

ui/ui.js

@@ -1,804 +0,0 @@
-// Visual Control Plane — client (vanilla JS, D3 from CDN)
-// Design note: KB data flows from local jsonl files we control, but we
-// still use DOM methods (createElement/textContent) for every
-// data-derived node to satisfy static analysis and keep a clean XSS
-// boundary if the UI ever gets exposed.
-
-const POLL_MS = 3000;
-
-const state = {
-  view: "map",
-  overlay: "status",
-  selected: null,
-  services: null,
-  reviews: [],
-  metrics: [],
-  overrides: [],
-  trust: [],
-  findings: [],
-};
-
-// ───── view switcher ─────
-document.querySelectorAll("#views button").forEach(b => {
-  b.addEventListener("click", () => {
-    document.querySelectorAll("#views button").forEach(x => x.classList.remove("on"));
-    b.classList.add("on");
-    state.view = b.dataset.view;
-    document.querySelectorAll(".view").forEach(v => v.classList.remove("on"));
-    document.getElementById(`view-${state.view}`).classList.add("on");
-    renderView();
-  });
-});
-
-document.querySelectorAll("#overlay-controls button").forEach(b => {
-  b.addEventListener("click", () => {
-    document.querySelectorAll("#overlay-controls button").forEach(x => x.classList.remove("on"));
-    b.classList.add("on");
-    state.overlay = b.dataset.ov;
-    if (state.services) drawMap(state.services);
-  });
-});
-
-// ───── helpers ─────
-function el(tag, opts = {}, ...kids) {
-  const n = document.createElement(tag);
-  if (opts.className) n.className = opts.className;
-  if (opts.text != null) n.textContent = String(opts.text);
-  if (opts.data) for (const k in opts.data) n.dataset[k] = opts.data[k];
-  if (opts.attrs) for (const k in opts.attrs) n.setAttribute(k, opts.attrs[k]);
-  if (opts.style) for (const k in opts.style) n.style[k] = opts.style[k];
-  for (const k of kids) if (k != null) n.append(k);
-  return n;
-}
-function clear(node) { while (node.firstChild) node.removeChild(node.firstChild); }
-function row(k, v, valClass) {
-  const r = el("div", { className: "ctx-row" });
-  r.append(el("span", { className: "k", text: k }));
-  const vv = el("span", { className: "v" + (valClass ? " " + valClass : ""), text: String(v ?? "-") });
-  r.append(vv);
-  return r;
-}
-function short(v) {
-  if (v == null) return "-";
-  if (typeof v === "object") return JSON.stringify(v).slice(0, 80);
-  return String(v).slice(0, 80);
-}
-
-// ───── polling ─────
-async function poll() {
-  try {
-    const [svc, rev, met, ov, tr, fin] = await Promise.all([
-      fetch("/data/services").then(r => r.json()),
-      fetch("/data/reviews?tail=80").then(r => r.json()),
-      fetch("/data/metrics").then(r => r.json()),
-      fetch("/data/overrides").then(r => r.json()),
-      fetch("/data/trust").then(r => r.json()),
-      fetch("/data/findings").then(r => r.json()),
-    ]);
-    state.services = svc;
-    state.reviews = Array.isArray(rev) ? rev : [];
-    state.metrics = Array.isArray(met) ? met : [];
-    state.overrides = Array.isArray(ov) ? ov : [];
-    state.trust = Array.isArray(tr) ? tr : [];
-    state.findings = Array.isArray(fin) ? fin : [];
-    document.getElementById("build-ts").textContent = new Date(svc.ts).toLocaleTimeString();
-    svc.nodes.forEach(n => {
-      const chip = document.querySelector(`.hbchip[data-svc="${n.id}"]`);
-      if (chip) chip.setAttribute("data-status", n.status);
-    });
-    renderView();
-    renderContext();
-    pollStream();
-  } catch (e) { console.error("poll error", e); }
-}
-
-async function pollStream() {
-  try {
-    const j = await fetch("/data/scrum_log").then(r => r.json());
-    if (!j.lines) return;
-    document.getElementById("stream-file").textContent = j.file ? j.file.split("/").pop() : "—";
-    const body = document.getElementById("stream-body");
-    clear(body);
-    j.lines.slice(-30).forEach(line => {
-      const cls = /✓ ACCEPTED/.test(line) ? "ok"
-        : /✗ thin/.test(line) ? "thin"
-        : /error|failed|FAIL/i.test(line) ? "err"
-        : /^\[scrum\] file:/.test(line) ? "head"
-        : "info";
-      body.append(el("div", { className: "sline " + cls, text: line }));
-    });
-    body.scrollTop = body.scrollHeight;
-  } catch {}
-}
-
-function renderView() {
-  if (!state.services) return;
-  if (state.view === "map") drawMap(state.services);
-  else if (state.view === "trace") drawTrace();
-  else if (state.view === "trajectory") drawTrajectory();
-  else if (state.view === "metrics") drawMetrics();
-  else if (state.view === "kb") drawKB();
-  else if (state.view === "console") drawConsole();
-}
-
-// ───── MAP ─────
-const NODES_STATIC = [
-  { id: "gateway",  x: 0.5,  y: 0.15 },
-  { id: "sidecar",  x: 0.2,  y: 0.3 },
-  { id: "observer", x: 0.8,  y: 0.3 },
-  { id: "mcp",      x: 0.85, y: 0.1 },
-  { id: "context7", x: 0.15, y: 0.1 },
-  { id: "journal",  x: 0.35, y: 0.55 },
-  { id: "vectord",  x: 0.5,  y: 0.5 },
-  { id: "playbook", x: 0.65, y: 0.55 },
-  { id: "agent",    x: 0.5,  y: 0.75 },
-  { id: "usage",    x: 0.2,  y: 0.75 },
-];
-const EDGES = [
-  ["gateway","sidecar"],["gateway","observer"],["gateway","mcp"],["gateway","context7"],
-  ["gateway","journal"],["gateway","vectord"],["gateway","playbook"],["gateway","agent"],["gateway","usage"],
-  ["vectord","playbook"],["agent","vectord"],["observer","playbook"],["sidecar","vectord"],
-];
-
-function drawMap(svc) {
-  const svg = d3.select("#map");
-  const box = svg.node().getBoundingClientRect();
-  const W = box.width, H = box.height;
-  svg.selectAll("*").remove();
-  const statusMap = {};
-  [...svc.nodes, ...svc.subsystems].forEach(n => statusMap[n.id] = n);
-  svg.selectAll(".edge").data(EDGES).enter().append("line")
-    .attr("class", d => "edge" + (overlayEdgeActive(d) ? " active" : ""))
-    .attr("x1", d => nodePos(d[0]).x * W).attr("y1", d => nodePos(d[0]).y * H)
-    .attr("x2", d => nodePos(d[1]).x * W).attr("y2", d => nodePos(d[1]).y * H);
-  const g = svg.selectAll(".node").data(NODES_STATIC).enter().append("g")
-    .attr("class", "node")
-    .attr("transform", d => `translate(${d.x * W}, ${d.y * H})`)
-    .on("click", (_ev, d) => { state.selected = { type:"node", id:d.id }; renderContext(); drawMap(svc); });
-  g.append("circle")
-    .attr("class", d => "node-circle" + (state.selected?.type==="node" && state.selected.id===d.id ? " node-selected" : ""))
-    .attr("r", d => nodeRadius(d, statusMap))
-    .attr("fill", d => nodeColor(d, statusMap));
-  // SVG tooltip — hover a node, browser shows a native tooltip with
-  // what this node DOES, not just its name.
-  g.append("title").text(d => nodeTooltip(d.id));
-  g.append("text").attr("class","node-label").attr("y", -30).text(d => nodeLabel(d.id));
-  g.append("text").attr("class","node-sub").attr("y", 40).text(d => nodeSub(d, statusMap));
-}
-function nodePos(id) { return NODES_STATIC.find(x => x.id === id) ?? { x:0, y:0 }; }
-function nodeLabel(id) {
-  return ({gateway:"GATEWAY",sidecar:"SIDECAR",observer:"OBSERVER",mcp:"MCP",context7:"CTX7",
-    journal:"JOURNAL",vectord:"VECTORD",playbook:"PLAYBOOK",agent:"AUTOTUNE",usage:"USAGE"})[id] ?? id;
-}
-function nodeRadius(d, m) {
-  const n = m[d.id];
-  if (state.overlay === "activity") {
-    if (d.id === "journal" && n?.stats?.total_events_created != null) return 14 + Math.min(20, Math.log2(n.stats.total_events_created + 1) * 2);
-    if (d.id === "vectord" && n?.stats?.count != null) return 14 + Math.min(20, Math.log2(n.stats.count + 1) * 2);
-    if (d.id === "playbook" && n?.stats?.total != null) return 14 + Math.min(20, Math.log2(n.stats.total + 1));
-    if (d.id === "observer" && n?.stats?.total != null) return 14 + Math.min(20, Math.log2(n.stats.total + 1));
-    if (d.id === "usage" && n?.stats?.requests != null) return 14 + Math.min(20, Math.log2(n.stats.requests + 1) * 2);
-  }
-  return 18;
-}
-function nodeColor(d, m) {
-  const n = m[d.id];
-  const ov = state.overlay;
-  if (ov === "status" || ov === "activity") {
-    const st = n?.status ?? (n?.stats ? "healthy" : "unknown");
-    return { healthy:"#3eed86", degraded:"#ffbf3c", down:"#ff4d6e", unknown:"#525c6f" }[st] ?? "#525c6f";
-  }
-  if (ov === "confidence") {
-    const c = recentAvgConfidence(d.id);
-    if (c == null) return "#525c6f";
-    if (c >= 88) return "#3eed86";
-    if (c >= 70) return "#55c5ff";
-    if (c >= 50) return "#ffbf3c";
-    return "#ff4d6e";
-  }
-  if (ov === "gradient") {
-    const t = recentGradientTier(d.id);
-    return t ? ({auto:"#3eed86",dry_run:"#55c5ff",simulation:"#ffbf3c",block:"#ff4d6e"}[t] ?? "#525c6f") : "#525c6f";
-  }
-  if (ov === "verdict") {
-    const v = recentVerdict(d.id);
-    return {pass:"#3eed86",needs_patch:"#ff9f43",fail:"#ff4d6e"}[v] ?? "#525c6f";
-  }
-  return "#55c5ff";
-}
-function nodeSub(d, m) {
-  const n = m[d.id];
-  if (!n) return "…";
-  if (d.id === "journal" && n.stats)  return `${n.stats.total_events_created ?? 0} events · ${n.stats.persisted_files ?? 0} parquet`;
-  if (d.id === "usage" && n.stats)    return `${n.stats.requests ?? 0} requests · ${Math.round((n.stats.total_tokens ?? 0)/1000)}k tokens`;
-  if (d.id === "vectord" && typeof n.stats === "object" && n.stats)  return `${n.stats.count ?? 0} indexes`;
-  if (d.id === "playbook" && n.stats) return `${n.stats.active ?? 0} active · ${n.stats.retired ?? 0} retired`;
-  if (d.id === "agent" && n.stats)    return `${n.stats.trials_run ?? 0} trials · ${n.stats.promotions ?? 0} promotions`;
-  if (d.id === "observer" && n.stats) return `${n.stats.total ?? 0} observed ops`;
-  return String(n.status ?? "");
-}
-
-// Describes what each node DOES — shown as SVG <title> tooltip.
-function nodeTooltip(id) {
-  return ({
-    gateway:  "GATEWAY — Rust/Axum HTTP on :3100. Every external call enters here: /v1/chat, /ingest, /query, /tools, /journal, /vectors. Also hosts gRPC on :3101.",
-    sidecar:  "SIDECAR — Python FastAPI on :3200. Adapter from Rust to local Ollama (:11434). Handles /embed /generate /rerank. Stateless.",
-    observer: "OBSERVER — Bun on :3800. Ring buffer of recent ops across the system. Feeds analyzeErrors + PLAYBOOK_BUILDER loops. Scrum events now land here (P45 fix).",
-    mcp:      "MCP — Bun on :3700. Model Context Protocol tool gateway. Agent-facing tool endpoints.",
-    context7: "CONTEXT7 — Bun on :3900. Doc-drift resolver — checks playbook doc_refs against current docs for version drift (Phase 45 target).",
-    journal:  "JOURNAL — ADR-012 append-only mutation log inside the gateway. Every ingest/delta-write/tombstone should record here. Currently ~1 real event (P9-001 still mostly unwired).",
-    vectord:  "VECTORD — Embeddings store + HNSW index + autotune harness. The 'indexes' count = named vector indexes live right now (one per source × model_version).",
-    playbook: "PLAYBOOK — Meta-index. Each entry = a successful past pattern + geo/role + 768d embedding. Active entries boost future vector-search results (Phase 19).",
-    agent:    "AUTOTUNE — Background agent that continuously proposes HNSW config trials, picks Pareto winners above min_recall, promotes, and rolls back. Self-tuning vector index.",
-    usage:    "USAGE — /v1/chat token counters. Tracks requests, prompt/completion tokens, per-provider breakdown. Grows with scrum + audit traffic.",
-  })[id] ?? id;
-}
-function overlayEdgeActive(edge) {
-  if (!state.reviews.length) return false;
-  const latest = state.reviews[state.reviews.length - 1];
-  if (!latest?.reviewed_at) return false;
-  const age = Date.now() - new Date(latest.reviewed_at).getTime();
-  if (age > 60000) return false;
-  return edge.includes("gateway") && (edge.includes("observer") || edge.includes("vectord"));
-}
-function matchesNode(r, id) {
-  if (!r?.file) return false;
-  const f = r.file.toLowerCase();
-  if (id === "gateway") return f.includes("/gateway/");
-  if (id === "vectord") return f.includes("/vectord");
-  if (id === "journal") return f.includes("/journald");
-  if (id === "playbook")return f.includes("playbook_memory");
-  if (id === "sidecar") return f.includes("sidecar");
-  if (id === "agent")   return f.includes("agent.rs") || f.includes("autotune");
-  return false;
-}
-function recentAvgConfidence(id) {
-  const rs = state.reviews.filter(r => matchesNode(r, id));
-  const vs = rs.map(r => r.confidence_avg).filter(v => v != null);
-  return vs.length ? vs.reduce((a,b)=>a+b,0)/vs.length : null;
-}
-function recentGradientTier(id) {
-  const rs = state.reviews.filter(r => matchesNode(r, id));
-  const ts = rs.map(r => r.gradient_tier).filter(Boolean);
-  return ts[ts.length - 1] ?? null;
-}
-function recentVerdict(id) {
-  const rs = state.reviews.filter(r => matchesNode(r, id));
-  const vs = rs.map(r => r.verdict).filter(Boolean);
-  return vs[vs.length - 1] ?? null;
-}
-
-// ───── CONTEXT ─────
-function renderContext() {
-  const target = document.getElementById("ctx-target");
-  const body = document.getElementById("ctx-body");
-  clear(body);
-  if (!state.selected) {
-    target.textContent = "no selection";
-    body.append(el("div", { className: "ctx-hint", text: "Click a node or a file in KB to inspect. Context persists across view switches." }));
-    body.append(el("div", { className: "ctx-section-hd", text: "System totals" }));
-    appendSummaryKV(body);
-    return;
-  }
-  if (state.selected.type === "node") renderNodeContext(state.selected.id, target, body);
-  else if (state.selected.type === "file") renderFileContext(state.selected.id, target, body);
-}
-
-function appendSummaryKV(body) {
-  const s = state.services;
-  if (!s) { body.append(el("div", { className: "ctx-hint", text: "loading…" })); return; }
-  const get = id => s.nodes.concat(s.subsystems).find(n => n.id === id);
-  const journal = get("journal")?.stats ?? {};
-  const usage = get("usage")?.stats ?? {};
-  const playbook = get("playbook")?.stats ?? {};
-  const agent = get("agent")?.stats ?? {};
-  const observer = get("observer")?.stats ?? {};
-  body.append(row("scrum reviews", state.reviews.length));
-  body.append(row("journal events", journal.total_events_created ?? 0));
-  body.append(row("usage tokens", (usage.total_tokens ?? 0).toLocaleString()));
-  body.append(row("playbook active", playbook.active ?? 0));
-  body.append(row("autotune trials", agent.trials_run ?? 0));
-  body.append(row("observer ops", observer.total ?? 0));
-  body.append(row("findings (h/m/l)", `${countFindingsSev("high")}/${countFindingsSev("medium")}/${countFindingsSev("low")}`));
-}
-
-function countFindingsSev(sev) {
-  let n = 0;
-  for (const row of state.findings) for (const f of row.findings ?? []) if (f.severity === sev) n++;
-  return n;
-}
-
-function renderNodeContext(id, target, body) {
-  target.textContent = `NODE · ${id.toUpperCase()}`;
-  const n = [...state.services.nodes, ...state.services.subsystems].find(x => x.id === id);
-  if (n?.health) {
-    body.append(el("div", { className: "ctx-section-hd", text: "Health" }));
-    // Fix 2026-04-24: some /health endpoints return a plain string like
-    // "lakehouse ok". Don't Object.entries() on strings — that iterates
-    // characters. Detect primitive vs object explicitly.
-    if (typeof n.health === "string" || typeof n.health === "number" || typeof n.health === "boolean") {
-      body.append(row("response", String(n.health).slice(0, 80)));
-    } else if (typeof n.health === "object" && n.health !== null) {
-      Object.entries(n.health).slice(0, 8).forEach(([k,v]) => body.append(row(k, short(v))));
-    }
-  }
-  if (n?.stats) {
-    body.append(el("div", { className: "ctx-section-hd", text: "Stats" }));
-    if (typeof n.stats === "string") {
-      body.append(row("raw", String(n.stats).slice(0, 80)));
-    } else if (typeof n.stats === "object" && n.stats !== null) {
-      Object.entries(n.stats).slice(0, 10).forEach(([k,v]) => body.append(row(k, short(v))));
-    }
-  }
-  const related = state.reviews.filter(r => matchesNode(r, id)).slice(-5).reverse();
-  if (related.length) {
-    body.append(el("div", { className: "ctx-section-hd", text: "Recent reviews" }));
-    related.forEach(r => {
-      const rr = row(r.file.split("/").pop(), `${r.confidence_avg ?? "-"}% · ${r.alignment_score ?? "?"}/10`);
-      rr.style.cursor = "pointer";
-      rr.addEventListener("click", () => { state.selected = { type:"file", id:r.file }; renderContext(); });
-      body.append(rr);
-    });
-  }
-  if (!body.firstChild) body.append(el("div", { className: "ctx-hint", text: "no data yet" }));
-}
-
-function renderFileContext(fpath, target, body) {
-  target.textContent = fpath.split("/").slice(-3).join("/");
-  const fileReviews = state.reviews.filter(r => r.file === fpath).slice(-6);
-  if (!fileReviews.length) {
-    body.append(el("div", { className: "ctx-hint", text: `no reviews for ${fpath}` }));
-    return;
-  }
-  const latest = fileReviews[fileReviews.length - 1];
-  const pillRow = el("div", { style: { paddingBottom: "6px" } });
-  if (latest.gradient_tier) pillRow.append(el("span", { className: `pill tier-${latest.gradient_tier}`, text: latest.gradient_tier }));
-  if (latest.verdict)       pillRow.append(el("span", { className: `pill ver-${latest.verdict}`, text: latest.verdict }));
-  if (latest.output_format) pillRow.append(el("span", { className: `pill fmt-${latest.output_format}`, text: latest.output_format }));
-  body.append(pillRow);
-  const rows = [
-    ["file", fpath],
-    ["score", latest.alignment_score != null ? `${latest.alignment_score}/10` : "-"],
-    ["conf avg", latest.confidence_avg != null ? `${latest.confidence_avg}%` : "-"],
-    ["conf min", latest.confidence_min != null ? `${latest.confidence_min}%` : "-"],
-    ["findings", latest.findings_count ?? 0],
-    ["critical", latest.critical_failures_count ?? 0],
-    ["verified", latest.verified_components_count ?? 0],
-    ["missing", latest.missing_components_count ?? 0],
-    ["model", latest.accepted_model ?? "-"],
-    ["attempts", latest.attempts_made ?? 1],
-    ["tree split", latest.tree_split_fired ? "yes" : "no"],
-  ];
-  rows.forEach(([k,v]) => body.append(row(k, short(v))));
-  body.append(el("div", { className: "ctx-section-hd", text: "Score history" }));
-  fileReviews.forEach(r => body.append(row(new Date(r.reviewed_at).toLocaleTimeString(), `${r.alignment_score ?? "?"}/10 · ${r.confidence_avg ?? "-"}%`)));
-  body.append(el("div", { className: "ctx-section-hd", text: "Preview" }));
-  const pre = el("pre", { text: latest.suggestions_preview ?? "", style: { whiteSpace: "pre-wrap", fontFamily: "var(--mono)", fontSize: "10px", color: "var(--fg-dim)", maxHeight: "200px", overflowY: "auto" } });
-  body.append(pre);
-  document.getElementById("stream-file").textContent = fpath.split("/").pop();
-}
-
-// ───── TRACE ─────
-async function drawTrace() {
-  const fpath = state.selected?.type === "file" ? state.selected.id : state.reviews[state.reviews.length-1]?.file;
-  const tl = document.getElementById("trace-timeline");
-  const detail = document.getElementById("trace-detail");
-  clear(tl); clear(detail);
-  document.getElementById("trace-file").textContent = fpath ?? "—";
-  if (!fpath) { tl.append(el("div", { className: "ctx-hint", text: "no file selected — pick one in KB view" })); return; }
-  const r = await fetch(`/data/file/${encodeURIComponent(fpath)}`).then(r => r.json());
-  const history = r.history ?? [];
-  document.getElementById("trace-runs").textContent = `${history.length} runs`;
-  history.forEach((h, i) => {
-    const node = el("div", { className: "trace-node" + (i === history.length - 1 ? " active" : "") });
-    node.append(el("div", { className: "tn-run", text: h.run_id }));
-    node.append(el("div", { className: "tn-score", text: h.score != null ? String(h.score) : "?" }));
-    node.append(el("div", { className: "tn-conf", text: `conf ${h.conf_avg ?? "-"}% · ${h.findings}f` }));
-    node.append(el("div", { className: "tn-model", text: (h.model ?? "").split("/").pop() }));
-    node.addEventListener("click", () => {
-      tl.querySelectorAll(".trace-node").forEach(x => x.classList.remove("active"));
-      node.classList.add("active");
-      clear(detail);
-      detail.append(el("pre", { text: h.preview ?? "" }));
-    });
-    tl.append(node);
-  });
-  if (history.length) { clear(detail); detail.append(el("pre", { text: history[history.length-1].preview ?? "" })); }
-}
-
-// ───── TRAJECTORY — refactor signals + reverse index + per-file delta ─────
-
-let trajectorySearchTimer = null;
-document.getElementById("traj-search")?.addEventListener("input", (e) => {
-  const q = e.target.value.trim();
-  clearTimeout(trajectorySearchTimer);
-  trajectorySearchTimer = setTimeout(() => runReverseIndex(q), 300);
-});
-
-async function runReverseIndex(query) {
-  const body = document.getElementById("traj-body");
-  if (!query) { drawTrajectory(); return; }
-  clear(body);
-  const res = await fetch(`/data/search?q=${encodeURIComponent(query)}`).then(r => r.json());
-  const hdr = el("div", { className: "traj-section-head", text: `REVERSE INDEX · "${query}" · ${res.hits?.length ?? 0} hits` });
-  body.append(hdr);
-  (res.hits ?? []).forEach(h => {
-    const card = el("div", { className: "traj-hit" });
-    card.append(el("div", { className: "traj-hit-top" },
-      el("span", { className: "traj-hit-file", text: h.file }),
-      el("span", { className: "traj-hit-meta", text: `${h.run_id} · ${(h.model ?? "").split("/").pop()}` })
-    ));
-    card.append(el("div", { className: "traj-hit-snip", text: h.snippet }));
-    card.addEventListener("click", () => {
-      state.selected = { type: "file", id: `/home/profit/lakehouse/${h.file}` };
-      renderContext();
-      document.querySelector('#views button[data-view="trace"]').click();
-    });
-    body.append(card);
-  });
-}
-
-async function drawTrajectory() {
-  const body = document.getElementById("traj-body");
-  clear(body);
-  const statsEl = document.getElementById("traj-stats");
-  clear(statsEl);
-
-  // SECTION 1 — refactor signals
-  const sig = await fetch("/data/refactor_signals").then(r => r.json());
-  const sigs = sig.signals ?? [];
-  const totalHits = sigs.reduce((a,s) => a + s.hits, 0);
-  statsEl.textContent = `${sig.scanned ?? 0} files scanned · ${sigs.length} with refactor hints · ${totalHits} phrase hits total`;
-
-  const sigHead = el("div", { className: "traj-section-head", text: "REFACTOR SIGNALS · files the scrum repeatedly flagged as dead / redundant / stub / needs-rewrite" });
-  body.append(sigHead);
-
-  const explain = el("div", { className: "traj-section-explain", text:
-    "Aggregates across all scrum iterations. A phrase hit = one time the reviewer used language like 'remove', 'duplicate', 'refactor', 'pseudocode', 'orphaned'. " +
-    "Files near the top are the strongest refactor candidates — the scrum keeps calling them out. Click a row to jump to its per-iteration trace."
-  });
-  body.append(explain);
-
-  const table = el("div", { className: "traj-table" });
-  sigs.slice(0, 30).forEach(s => {
-    const r = el("div", { className: "traj-row" });
-    r.append(el("div", { className: "traj-col-rank", text: String(sigs.indexOf(s) + 1) }));
-    r.append(el("div", { className: "traj-col-file", text: s.file }));
-    r.append(el("div", { className: "traj-col-hits", text: `${s.hits}×` }));
-    const topPhrases = Object.entries(s.phrases).sort((a,b)=>b[1]-a[1]).slice(0,3)
-      .map(([p,n]) => `${p} (${n})`).join(", ");
-    r.append(el("div", { className: "traj-col-phrases", text: topPhrases }));
-    r.append(el("div", { className: "traj-col-iters", text: `${s.iterations} iter` }));
-    r.addEventListener("click", () => {
-      state.selected = { type: "file", id: `/home/profit/lakehouse/${s.file}` };
-      renderContext();
-      document.querySelector('#views button[data-view="trace"]').click();
-    });
-    table.append(r);
-  });
-  body.append(table);
-
-  // SECTION 2 — per-file trajectory: pick the top-5 refactor candidates and
-  // show their score/conf delta across iterations inline.
-  if (sigs.length) {
-    body.append(el("div", { className: "traj-section-head", text: "SCORE TRAJECTORY — top refactor candidates" }));
-    const grid = el("div", { className: "traj-spark-grid" });
-    for (const s of sigs.slice(0, 6)) {
-      const card = el("div", { className: "traj-spark" });
-      card.append(el("div", { className: "traj-spark-file", text: s.file }));
-      // pull history
-      const hist = await fetch(`/data/file/${encodeURIComponent("/home/profit/lakehouse/" + s.file)}`)
-        .then(r => r.json()).catch(() => ({ history: [] }));
-      const runs = hist.history ?? [];
-      if (runs.length === 0) { card.append(el("div", { className: "traj-spark-empty", text: "no history" })); }
-      else {
-        const line = el("div", { className: "traj-spark-line" });
-        runs.forEach((h,i) => {
-          const pt = el("div", { className: "traj-spark-pt" });
-          pt.append(el("div", { className: "traj-pt-score", text: h.score != null ? `${h.score}/10` : "?" }));
-          pt.append(el("div", { className: "traj-pt-conf", text: `${h.conf_avg ?? "-"}%` }));
-          pt.append(el("div", { className: "traj-pt-label", text: `iter${i+1}` }));
-          line.append(pt);
-          if (i < runs.length - 1) line.append(el("div", { className: "traj-spark-arrow", text: "→" }));
-        });
-        card.append(line);
-        // delta summary
-        if (runs.length >= 2) {
-          const first = runs[0], last = runs[runs.length - 1];
-          const dScore = (last.score != null && first.score != null) ? (last.score - first.score) : null;
-          const dConf = (last.conf_avg != null && first.conf_avg != null) ? (last.conf_avg - first.conf_avg) : null;
-          const delta = el("div", { className: "traj-spark-delta" });
-          if (dScore != null) delta.append(el("span", { text: `Δscore ${dScore > 0 ? "+" : ""}${dScore.toFixed(1)}`, className: dScore < 0 ? "delta-down" : dScore > 0 ? "delta-up" : "" }));
-          if (dConf != null) delta.append(el("span", { text: ` · Δconf ${dConf > 0 ? "+" : ""}${dConf}%`, className: dConf > 0 ? "delta-up" : dConf < 0 ? "delta-down" : "" }));
-          card.append(delta);
-        }
-      }
-      card.addEventListener("click", () => {
-        state.selected = { type: "file", id: `/home/profit/lakehouse/${s.file}` };
-        renderContext();
-        document.querySelector('#views button[data-view="trace"]').click();
-      });
-      grid.append(card);
-    }
-    body.append(grid);
-  }
-}
-
-// ───── METRICS ─────
-function metricBox(label, big, kind, opts = {}) {
-  // opts: { source, good, explain }
-  // source = where the number comes from (data path)
-  // good   = the "what's a healthy value" sentence
-  // explain = one-line definition of what this counts
-  const box = el("div", { className: "metric" + (kind ? " " + kind : "") });
-  box.append(el("div", { className: "m-label", text: label }));
-  box.append(el("div", { className: "m-big", text: big }));
-  if (opts.explain) box.append(el("div", { className: "m-sub m-explain", text: opts.explain }));
-  if (opts.source)  box.append(el("div", { className: "m-sub m-source", text: "SOURCE · " + opts.source }));
-  if (opts.good)    box.append(el("div", { className: "m-sub m-good",   text: "GOOD · " + opts.good }));
-  return box;
-}
-function drawMetrics() {
-  const grid = document.getElementById("metric-grid");
-  clear(grid);
-  const byTier = { auto:0, dry_run:0, simulation:0, block:0, unknown:0 };
-  state.reviews.forEach(r => { const t = r.gradient_tier ?? "unknown"; if (byTier[t] != null) byTier[t]++; });
-  const total = state.reviews.length || 1;
-  const confRows = state.reviews.filter(r => r.confidence_avg != null);
-  const avg = confRows.length ? Math.round(confRows.reduce((a,r)=>a+r.confidence_avg,0)/confRows.length) : 0;
-  const verdictCount = { pass:0, needs_patch:0, fail:0, unknown:0 };
-  state.reviews.forEach(r => { const v=r.verdict??"unknown"; if(verdictCount[v]!=null) verdictCount[v]++; });
-  const findingsTotal = state.reviews.reduce((a,r)=>a+(r.findings_count??0),0);
-  const critTotal = state.reviews.reduce((a,r)=>a+(r.critical_failures_count??0),0);
-  const verTotal = state.reviews.reduce((a,r)=>a+(r.verified_components_count??0),0);
-  const usage = state.services?.subsystems?.find(n=>n.id==="usage")?.stats ?? {};
-  const journal = state.services?.subsystems?.find(n=>n.id==="journal")?.stats ?? {};
-
-  grid.append(metricBox("avg confidence", `${avg}%`, avg>=85?"good":avg>=70?"warn":"bad", {
-    explain: "Self-assessed probability per suggestion, averaged across every review.",
-    source: "scrum_reviews.jsonl .confidence_avg",
-    good: "≥85% — model is confident. 70-84% routine. <70% means the scrum is uncertain and findings need human review.",
-  }));
-  grid.append(metricBox("scrum reviews", String(state.reviews.length), "good", {
-    explain: "Every source file reviewed by the scrum master, across all iterations.",
-    source: `${state.metrics.length} scrum runs tracked in scrum_loop_metrics.jsonl`,
-    good: "Grows every run — 21 files × N iterations. Stall = pipeline broken.",
-  }));
-  grid.append(metricBox("critical failures", String(critTotal), critTotal>50?"bad":critTotal>10?"warn":"good", {
-    explain: "Hard FAILs flagged by the forensic reviewer — pseudocode, fake implementations, unwired invariants. Each one is a concrete code-level gap.",
-    source: "scrum_reviews.jsonl .critical_failures_count (forensic JSON format only)",
-    good: "Trending DOWN each iteration = fixes are landing. Rising = new gaps surfacing faster than we close them.",
-  }));
-  grid.append(metricBox("verified components", String(verTotal), verTotal>0?"good":"warn", {
-    explain: "What the scrum CONFIRMED is working — with file/line evidence. The inverse of critical_failures.",
-    source: "scrum_reviews.jsonl .verified_components_count",
-    good: "Trending UP = the system has more provably-real parts over time. Should grow as fixes land.",
-  }));
-  grid.append(metricBox("findings captured", String(findingsTotal), "good", {
-    explain: "Total individual suggestions the scrum produced across all reviews (tables + JSON).",
-    source: "scrum_reviews.jsonl .findings_count summed",
-    good: "Higher = more scrutiny per file. Per-file average ≥10 means the review is substantive.",
-  }));
-  grid.append(metricBox("journal events", String(journal.total_events_created ?? 0), "good", {
-    explain: "Mutation events recorded via ADR-012 append-only journal. Every ingest/delta-write should emit one.",
-    source: "/journal/stats → total_events_created",
-    good: "Should grow with ingest traffic. 1 = only a test probe fired; internal callers still unwired on most paths (P9-001).",
-  }));
-  grid.append(metricBox("v1 requests", String(usage.requests ?? 0), "good", {
-    explain: "Calls through the Universal API /v1/chat endpoint (Phase 38). Captures all scrum + audit traffic.",
-    source: `/v1/usage → requests. ${(usage.total_tokens ?? 0).toLocaleString()} tokens total`,
-    good: "Every iteration adds ~21 requests. Stall = scrum paused OR callers bypassing the gateway (P44-style bypass).",
-  }));
-
-  // gradient bar
-  const gb = el("div", { className: "metric" });
-  gb.append(el("div", { className: "m-label", text: "permission gradient" }));
-  gb.append(el("div", { className: "m-big", text: String(state.reviews.length) }));
-  gb.append(el("div", { className: "m-sub m-explain", text: "Tiers the scrum's suggestions by confidence: how much auto-apply we can trust per file." }));
-  const bar = el("div", { className: "bar" });
-  bar.append(el("span", { className: "seg-auto",       style: { width: `${100*byTier.auto/total}%` } }));
-  bar.append(el("span", { className: "seg-dry_run",    style: { width: `${100*byTier.dry_run/total}%` } }));
-  bar.append(el("span", { className: "seg-simulation", style: { width: `${100*byTier.simulation/total}%` } }));
-  bar.append(el("span", { className: "seg-block",      style: { width: `${100*byTier.block/total}%` } }));
-  gb.append(bar);
-  gb.append(el("div", { className: "m-sub", text: `auto ${byTier.auto} · dry_run ${byTier.dry_run} · sim ${byTier.simulation} · block ${byTier.block}` }));
-  gb.append(el("div", { className: "m-sub m-good", text:
-    "AUTO (≥90%): ship the suggestion. DRY_RUN (70-89): apply then diff. SIMULATION (50-69): test first. BLOCK (<50): human review — the model doesn't trust itself."
-  }));
-  grid.append(gb);
-
-  const vb = el("div", { className: "metric" });
-  vb.append(el("div", { className: "m-label", text: "verdict distribution" }));
-  vb.append(el("div", { className: "m-big", text: String(verdictCount.pass + verdictCount.needs_patch + verdictCount.fail) }));
-  vb.append(el("div", { className: "m-sub m-explain", text: "Forensic audit verdict per file: pass = works, needs_patch = fixable gaps, fail = not trustable." }));
-  vb.append(el("div", { className: "m-sub", text: `pass ${verdictCount.pass} · needs_patch ${verdictCount.needs_patch} · fail ${verdictCount.fail}` }));
-  vb.append(el("div", { className: "m-sub m-source", text: "SOURCE · scrum_reviews.jsonl .verdict (forensic JSON only — markdown rows count as unknown)" }));
-  grid.append(vb);
-}
-
-// ───── KB ─────
-function drawKB() {
-  const grid = document.getElementById("kb-grid");
-  clear(grid);
-
-  // Explanatory banner — each iteration the scrum re-reviews every
-  // target file and writes a row here. A card = one file's latest
-  // review. Click to drill into its trace across all iterations.
-  const banner = el("div", { className: "kb-banner" });
-  banner.append(el("div", { className: "kb-banner-title", text: "KNOWLEDGE BASE — every source file reviewed by the scrum master" }));
-  banner.append(el("div", { className: "kb-banner-body", text:
-    "Each card below is the LATEST scrum review of one source file. The review itself lives in data/_kb/scrum_reviews.jsonl. " +
-    "Fields: score (scrum's alignment rating, 1-10 vs PRD intent), conf (model's self-assessed confidence per suggestion, avg'd), " +
-    "findings (# of suggestions), crit (critical_failures — hard FAILs found), verified (verified_components — what's confirmed working). " +
-    "Pills show: permission gradient (can we trust auto-apply), verdict (pass/needs_patch/fail), output format (JSON = forensic, markdown = legacy). " +
-    "Click a card to see its trace across all iterations (iter 1 → iter N) and watch scores trend."
-  }));
-  grid.append(banner);
-
-  const byFile = new Map();
-  state.reviews.forEach(r => { if (r.file) byFile.set(r.file, r); });
-  const rows = [...byFile.values()].sort((a,b) => (b.confidence_avg??0) - (a.confidence_avg??0));
-
-  // Quick stats above the cards
-  const statLine = el("div", { className: "kb-statline" });
-  const avgConf = rows.length ? Math.round(rows.reduce((a,r)=>a+(r.confidence_avg??0),0) / rows.length) : 0;
-  const scoreMean = rows.filter(r=>r.alignment_score!=null);
-  const avgScore = scoreMean.length ? (scoreMean.reduce((a,r)=>a+r.alignment_score,0) / scoreMean.length).toFixed(1) : "?";
-  const blockCount = rows.filter(r => r.gradient_tier === "block").length;
-  statLine.append(el("span", { text: `${rows.length} files tracked` }));
-  statLine.append(el("span", { text: `mean score ${avgScore}/10` }));
-  statLine.append(el("span", { text: `mean confidence ${avgConf}%` }));
-  statLine.append(el("span", { text: `${blockCount} blocked (need human review)`, className: blockCount > 0 ? "stat-warn" : "" }));
-  grid.append(statLine);
-
-  rows.forEach(r => {
-    const card = el("div", { className: "kb-file", data: { file: r.file } });
-    card.append(el("div", { className: "kf-path", text: r.file }));
-    const meta = el("div", { className: "kf-meta" });
-    const scoreSpan = el("span", { className: "kf-score", text: `${r.alignment_score ?? "?"}/10` });
-    scoreSpan.title = "Scrum's alignment score (1-10) — how well this file matches PRD intent. Lower = more gaps.";
-    meta.append(scoreSpan);
-    const confSpan = el("span", { text: `conf ${r.confidence_avg ?? "-"}%` });
-    confSpan.title = "Average self-confidence across suggestions. <70% = model uncertain, treat carefully.";
-    meta.append(confSpan);
-    const findingsSpan = el("span", { text: `${r.findings_count ?? 0} findings` });
-    findingsSpan.title = "Total suggestions in this review (table rows or JSON array entries).";
-    meta.append(findingsSpan);
-    const critSpan = el("span", { text: `${r.critical_failures_count ?? 0} crit` });
-    critSpan.title = "Critical failures: pseudocode, fake implementations, unwired invariants. Hard FAILs.";
-    if ((r.critical_failures_count ?? 0) > 0) critSpan.style.color = "var(--red)";
-    meta.append(critSpan);
-    const verSpan = el("span", { text: `${r.verified_components_count ?? 0} verified` });
-    verSpan.title = "Verified components: things the scrum CONFIRMED work, with file/line evidence.";
-    if ((r.verified_components_count ?? 0) > 0) verSpan.style.color = "var(--green)";
-    meta.append(verSpan);
-    meta.append(el("span", { text: (r.accepted_model ?? "").split("/").pop(), attrs: { title: "Which model produced this review" } }));
-    card.append(meta);
-    const pills = el("div", { className: "kf-meta" });
-    if (r.gradient_tier) {
-      const p = el("span", { className: `pill tier-${r.gradient_tier}`, text: r.gradient_tier });
-      p.title = ({
-        auto: "AUTO — confidence ≥90%, suggestions safe to apply automatically",
-        dry_run: "DRY_RUN — confidence 70-89%, apply then review the diff",
-        simulation: "SIMULATION — confidence 50-69%, test in sandbox first",
-        block: "BLOCK — confidence <50%, requires human review, do not auto-apply",
-      })[r.gradient_tier] ?? r.gradient_tier;
-      pills.append(p);
-    }
-    if (r.verdict) {
-      const p = el("span", { className: `pill ver-${r.verdict}`, text: r.verdict });
-      p.title = ({
-        pass: "PASS — scrum confirms this file meets its PRD intent",
-        needs_patch: "NEEDS_PATCH — gaps exist but are fixable; scrum has concrete suggestions",
-        fail: "FAIL — file cannot be trusted for its claimed purpose without structural changes",
-      })[r.verdict] ?? r.verdict;
-      pills.append(p);
-    }
-    if (r.output_format) {
-      const p = el("span", { className: `pill fmt-${r.output_format}`, text: r.output_format });
-      p.title = r.output_format === "forensic_json"
-        ? "FORENSIC_JSON — structured output with verdict/critical/verified/missing fields. Richer signal."
-        : "MARKDOWN — legacy tabular output. Lower structure; we only extract confidence scalars from these.";
-      pills.append(p);
-    }
-    card.append(pills);
-    card.addEventListener("click", () => {
-      state.selected = { type: "file", id: r.file };
-      renderContext();
-      document.querySelector('#views button[data-view="trace"]').click();
-    });
-    grid.append(card);
-  });
-}
-
-// ───── CONSOLE ─────
-// Persistent selection across polls so tab switches survive.
-state.consoleSvc = "gateway";
-
-// Hook tab buttons once
-document.querySelectorAll("#con-tabs button").forEach(b => {
-  b.addEventListener("click", () => {
-    document.querySelectorAll("#con-tabs button").forEach(x => x.classList.remove("on"));
-    b.classList.add("on");
-    state.consoleSvc = b.dataset.svc;
-    drawConsole();
-  });
-});
-
-async function drawConsole() {
-  const log = document.getElementById("console-log");
-  clear(log);
-  const unit = document.getElementById("con-unit");
-  if (unit) unit.textContent = "";
-
-  if (state.consoleSvc === "summary") {
-    drawConsoleSummary(log);
-    return;
-  }
-
-  // Per-service log tail
-  const svc = state.consoleSvc;
-  try {
-    const res = await fetch(`/data/logs/${svc}?n=120`).then(r => r.json());
-    if (unit && res.unit) unit.textContent = `unit · ${res.unit}`;
-    if (res.error) {
-      log.append(lineInfo(`[error] ${res.error}`, "cl-err"));
-      return;
-    }
-    const lines = res.lines ?? [];
-    if (!lines.length) { log.append(lineInfo("(no log lines — unit may have just started)", "cl-info")); return; }
-    lines.forEach(l => {
-      const cls = /\berror\b|\bERROR\b|panic|\[ERROR|failed/.test(l) ? "cl-err"
-        : /\bwarn\b|\bWARN\b|\bwarning\b|\[WARN/.test(l) ? "cl-warn"
-        : /\baccepted\b|\bok\b|\bOK\b|success|complete|ready/.test(l) ? "cl-ok"
-        : "cl-info";
-      log.append(lineInfo(l, cls));
-    });
-    // autoscroll to bottom
-    log.scrollTop = log.scrollHeight;
-  } catch (e) {
-    log.append(lineInfo(`[fetch-error] ${e}`, "cl-err"));
-  }
-}
-
-function lineInfo(text, cls) {
-  return el("div", { className: "cl-line " + cls, text });
-}
-
-function drawConsoleSummary(log) {
-  const info = t => lineInfo(t, "cl-info");
-  const ok   = t => lineInfo(t, "cl-ok");
-  const warn = t => lineInfo(t, "cl-warn");
-  const err  = t => lineInfo(t, "cl-err");
-  log.append(info(`# Lakehouse VCP · ${new Date().toLocaleTimeString()}`));
-  log.append(info(`# Services`));
-  for (const n of state.services?.nodes ?? []) {
-    const line = `[${String(n.status).padEnd(8)}] ${n.label}`;
-    log.append(n.status === "healthy" ? ok(line) : n.status === "down" ? err(line) : warn(line));
-  }
-  log.append(info(`# Subsystems`));
-  for (const s of state.services?.subsystems ?? []) {
-    log.append(info(`  ${String(s.id).padEnd(10)} ${JSON.stringify(s.stats ?? {}).slice(0, 120)}`));
-  }
-  log.append(info(`# Recent overrides (layer 10)`));
-  for (const o of state.overrides.slice(-6)) {
-    log.append(warn(`  [${o.ts}] ${o.task_signature}: ${o.human_fix}`));
-  }
-  log.append(info(`# Model trust accumulated`));
-  const agg = {};
-  for (const t of state.trust) {
-    const k = t.accepted_model ?? "?";
-    agg[k] = agg[k] ?? { accepts:0, thin:0, attempts:0 };
-    agg[k].accepts++;
-    agg[k].thin += t.thin_rejections ?? 0;
-    agg[k].attempts += t.attempts_made ?? 0;
-  }
-  for (const [m, s] of Object.entries(agg)) {
-    log.append(info(`  ${String(m).padEnd(48)} accepts=${s.accepts} thin=${s.thin} attempts=${s.attempts}`));
-  }
-}
-
-// ───── boot ─────
-poll();
-setInterval(poll, POLL_MS);
-window.addEventListener("resize", () => { if (state.services && state.view === "map") drawMap(state.services); });