${_shortName(p)}
@@ -2570,10 +2738,11 @@ function _renderConsortiumLive(source) {
const stream = source || window._dashboardLastStream || {};
const lastChat = stream.last_chat || {};
const router = stream.router || {};
- const backend = (lastChat.meta && lastChat.meta.backend) || router.v2_last_winner;
- const route = (lastChat.meta && lastChat.meta.v2_path) || router.v2_last_path || 'local';
+ const meta = lastChat.meta || {};
+ const backend = meta.selected_backend || meta.backend || router.v2_last_winner;
+ const route = meta.routing_decision || meta.v2_path || router.v2_last_path || 'local';
const scores = lastChat.meta && lastChat.meta.scores;
- const isJudge = /panel|judge|frugal|v2/i.test(route || '');
+ const isJudge = !!meta.judge_used || /panel|judge|frugal|v2|consensus/i.test(route || '');
if (!backend) {
status.textContent = 'pas encore de décision';
winner.textContent = 'Aucun backend récent';
@@ -2583,12 +2752,12 @@ function _renderConsortiumLive(source) {
pill.style.color = '#778';
return;
}
- status.textContent = isJudge ? 'consortium actif' : 'réponse directe';
+ status.textContent = isJudge ? 'consortium actif' : (meta.router_used ? 'router actif' : 'panel non utilisé');
winner.textContent = backend;
path.textContent = `Chemin ${route}`;
note.textContent = scores && typeof scores === 'object' && Object.keys(scores).length
? `Scores observés : ${Object.entries(scores).map(([k,v]) => `${k} ${Number(v).toFixed ? Number(v).toFixed(1) : v}`).join(' · ')}`
- : 'Pas de scores détaillés sur ce tour; le chemin ou la latence ont probablement suffi à décider.';
+ : (meta.selection_reason || 'Pas de scores détaillés sur ce tour; le chemin, la latence ou un guardrail ont suffi à décider.');
pill.textContent = isJudge ? `consortium ${backend}` : `chat ${backend}`;
pill.style.color = isJudge ? '#93b7ff' : '#8fd5b8';
}
@@ -3018,8 +3187,8 @@ async function _fetchLastEmergence() {
const ce = document.getElementById('hb-em-content') || document.getElementById('cb-emergence');
if (!ce) return;
const ageS = Math.round(Date.now()/1000 - (last.ts||0));
- ce.innerHTML = `
action: ${last.action} · il y a ${_fmtAge(ageS)}
` +
- `
${(last.response||'').slice(0,300)}
`;
+ ce.innerHTML = `
dernière action: ${last.action || 'n/a'} · il y a ${_fmtAge(ageS)}
` +
+ `
${(last.response||'').slice(0,300) || 'résultat indisponible'}
`;
window._cbLastEmergenceTs = (last.ts||0) * 1000;
} catch(e) {}
}
@@ -3673,7 +3842,7 @@ window.sendChat = async () => {
appendChatMessage({speaker:'cortex', msg, response, meta:d.meta || {}});
// Hook playtest pour chat normal aussi (Sam : "Cortex a répondu mais playtest n'a pas bougé")
if (typeof window._playtestSetFromCode === 'function') {
- try { window._playtestSetFromCode(response); } catch(e) {}
+ try { window._playtestSetFromCode(d); } catch(e) {}
}
} catch(e) {
if (pending?.text) {
@@ -3684,6 +3853,11 @@ window.sendChat = async () => {
}
}
};
+document.addEventListener('keydown', (event) => {
+ if (event.key === 'Escape') {
+ window._closeBrainDetail();
+ }
+});
let _calibRecog = null, _calibActive = false;
let _calibGoodCount = 0;
const CALIB_TARGET = 5; // 5 segments avec bon score = profil validé
diff --git a/scripts/brain/dashboard/serve.py b/scripts/brain/dashboard/serve.py
index eac57e9f5f..48bcbb1f2a 100644
--- a/scripts/brain/dashboard/serve.py
+++ b/scripts/brain/dashboard/serve.py
@@ -16,6 +16,7 @@ import json
import time
import os
import socketserver
+import subprocess
import sys
import threading
from pathlib import Path
@@ -31,6 +32,10 @@ HERE = Path(__file__).parent
PORT = int(os.environ.get("BRAIN_DASHBOARD_PORT", "8765"))
CHAT_STREAM_FILE = VAULT / ".cortex-chat-stream.jsonl"
EMERGENCE_STREAM_FILE = VAULT / ".cortex-emergence-stream.jsonl"
+PLAYTEST_DIR = HERE / "playtests"
+PLAYTEST_BASE_URL = f"http://127.0.0.1:{PORT}/playtests"
+ROUTER_BENCHMARK_FILE = HERE / "state" / "router_benchmarks.json"
+OPENCODE_CMD = Path(r"C:\Users\Smedj\AppData\Roaming\npm\opencode.cmd")
GRAPH_FILE = VAULT / ".vault-graph.json"
LAYOUT_FILE = VAULT / ".vault-graph-layout.json"
@@ -44,6 +49,44 @@ JEPA_STATUS = VAULT / ".vault-jepa-status.json"
_cache: dict = {"snapshot": None, "snapshot_mtime": 0}
_lock = threading.Lock()
+CONFIGURED_MODEL_PRIORS = {
+ "minimax_fast": {
+ "strengths": ["fast", "french", "chat", "summarization"],
+ "weaknesses": ["deep_reasoning", "complex_code"],
+ "cost": "low",
+ },
+ "gpt_5_nano": {
+ "strengths": ["structured", "fast_reasoning"],
+ "weaknesses": [],
+ "cost": "low",
+ },
+ "big_pickle": {
+ "strengths": ["math", "short_factual"],
+ "weaknesses": [],
+ "cost": "low",
+ },
+ "hy3_preview": {
+ "strengths": ["reasoning"],
+ "weaknesses": [],
+ "cost": "low",
+ },
+ "nemotron_3_super": {
+ "strengths": ["reasoning", "long_answer"],
+ "weaknesses": [],
+ "cost": "low",
+ },
+ "playtest_builder": {
+ "strengths": ["playtest_html"],
+ "weaknesses": [],
+ "cost": "low",
+ },
+ "direct_guardrail": {
+ "strengths": ["truth", "safe_direct_answer"],
+ "weaknesses": [],
+ "cost": "low",
+ },
+}
+
def _is_chat_entry(entry: dict | None) -> bool:
if not isinstance(entry, dict):
@@ -56,6 +99,316 @@ def _append_jsonl(path: Path, entry: dict):
with open(path, "a", encoding="utf-8") as f:
f.write(json.dumps(entry, ensure_ascii=False) + "\n")
+
+def _write_json_atomic(path: Path, payload: dict):
+ path.parent.mkdir(parents=True, exist_ok=True)
+ tmp = path.with_suffix(path.suffix + ".tmp")
+ tmp.write_text(json.dumps(payload, ensure_ascii=False, indent=2), encoding="utf-8")
+ os.replace(tmp, path)
+
+
+def _safe_int(value, default: int = 0) -> int:
+ try:
+ return int(value)
+ except Exception:
+ return default
+
+
+def _safe_float(value, default: float = 0.0) -> float:
+ try:
+ return float(value)
+ except Exception:
+ return default
+
+
+def _infer_complexity(message: str, intent_name: str = "") -> str:
+ text = (message or "").strip().lower()
+ if intent_name in ("recent_web_search", "playtest_dashboard_help", "identity"):
+ return "simple"
+ if intent_name == "playtest_code_task":
+ return "hard"
+ if len(text) > 500:
+ return "hard"
+ hard_markers = [
+ "architecture", "stabiliser", "stabilize", "debug", "diagnostic",
+ "plan", "planifie", "pourquoi", "analyse", "compare", "router",
+ "judge", "consortium", "server", "crash", "timeout",
+ ]
+ medium_markers = [
+ "explique", "comment", "résume", "resume", "problème", "probleme",
+ "mémoire", "memoire", "vault", "fichier", "repo",
+ ]
+ if any(marker in text for marker in hard_markers):
+ return "hard"
+ if any(marker in text for marker in medium_markers):
+ return "medium"
+ return "simple"
+
+
+def _is_simple_fact_question(message: str) -> bool:
+ text = (message or "").strip().lower()
+ if not text or len(text) > 160:
+ return False
+ if any(marker in text for marker in ["```", "/code", "debug", "architecture", "plan", "analyse", "compare"]):
+ return False
+ return any(text.startswith(prefix) for prefix in [
+ "quelle", "quel", "qui", "où", "ou", "quand", "combien", "c'est quoi", "explique-moi brièvement",
+ ])
+
+
+def _is_playtest_code_request(message: str) -> bool:
+ text = (message or "").strip().lower()
+ if not text.startswith("/code"):
+ return False
+ markers = ["playtest", "app", "application", "html", "interface", "calculatrice", "todo", "kanban", "dashboard"]
+ return any(marker in text for marker in markers)
+
+
+def _read_recent_history(max_turns: int = 4, include_responses: bool = True) -> list[dict]:
+ turns: list[dict] = []
+ if not CHAT_STREAM_FILE.exists():
+ return turns
+ try:
+ lines = CHAT_STREAM_FILE.read_text(encoding="utf-8", errors="replace").splitlines()[-120:]
+ except Exception:
+ return turns
+ for raw in reversed(lines):
+ try:
+ entry = json.loads(raw)
+ except Exception:
+ continue
+ if not _is_chat_entry(entry):
+ continue
+ msg = (entry.get("msg") or "").strip()
+ response = (entry.get("response") or "").strip()
+ if not msg and not response:
+ continue
+ turns.append({
+ "msg": msg[:400],
+ "response": response[:500] if include_responses else "",
+ "speaker": entry.get("speaker") or "cortex",
+ "meta": entry.get("meta") or {},
+ })
+ if len(turns) >= max_turns:
+ break
+ turns.reverse()
+ return turns
+
+
+def _history_prompt(turns: list[dict], for_code: bool = False) -> tuple[str, int]:
+ if not turns:
+ return "", 0
+ chunks = []
+ for turn in turns[-5:]:
+ msg = (turn.get("msg") or "").strip()
+ response = (turn.get("response") or "").strip()
+ if not msg:
+ continue
+ if for_code:
+ chunks.append(f"Sam: {msg[:220]}")
+ else:
+ block = f"Sam: {msg[:220]}"
+ if response:
+ block += f"\nCortex: {response[:260]}"
+ chunks.append(block)
+ if not chunks:
+ return "", 0
+ return "\n\nHistorique utile récent:\n" + "\n---\n".join(chunks), len(chunks)
+
+
+def _extract_html_document(text: str) -> str:
+ raw = (text or "").strip()
+ if not raw:
+ return ""
+ if raw.startswith("```"):
+ parts = raw.split("```")
+ for part in parts:
+ candidate = part.strip()
+ if "
= 0:
+ raw = raw[start:]
+ end = raw.lower().rfind("