chore: update ZeroClaw 1min watcher docs and stack bootstrap

This commit is contained in:
Clément SAILLANT
2026-02-21 19:08:05 +01:00
parent ce7b712624
commit 382b752d7c
3 changed files with 682 additions and 9 deletions
+17
View File
@@ -37,6 +37,23 @@ Format:
- Evidence: `tools/ai/ollama_local_setup.sh --no-pull --no-warmup` + config `default_provider = "ollama"`.
- Status: `2026-02-21` done (`llama3.2:1b` local); mode local est optionnel via `ZEROCLAW_PREFER_LOCAL_AI=1` pour garder la fiabilite webhook par defaut.
- [x] T-007 - Renforcer mode local-only agentic (ZeroClaw + OpenClaw)
- AC: `tools/ai/zeroclaw_dual_chat.sh <repo> --local-only --provider-check` choisit un provider local (`ollama` ou `lmstudio`) sinon exit explicite.
- Evidence: sortie provider-check + `openclaw models status --plain`.
- Status: `2026-02-21` done (`openclaw` default model force sur `ollama/llama3.2:1b`, fallbacks `openai-codex` puis `openrouter`).
- [x] T-008 - Scanner les options provider/agentic disponibles
- AC: rapport local avec statut runtime `openclaw/ollama/lmstudio/litellm` et matrice providers ZeroClaw.
- Evidence: `tools/ai/zeroclaw_provider_scan.sh --no-refresh` -> `artifacts/zeroclaw/provider_options.md`.
- Status: `2026-02-21` done.
- [x] T-009 - Verrouiller le mapping matériel par cible
- AC: la détection automatique affecte `zacus` aux ports `usbmodem`/S3 et `rtc` à lAudio Kit (pas dinterversion habituelle).
- Evidence:
- `ZEROCLAW_ZACUS_UPLOAD_PORT_HINT="1a86,usbmodem,ch340,freenove" tools/ai/zeroclaw_hw_firmware_loop.sh zacus --port '' --monitor-secs 5`
- `ZEROCLAW_RTC_UPLOAD_PORT_HINT="cp2102,10c4,esp32audiokit,audio" tools/ai/zeroclaw_hw_firmware_loop.sh rtc --port '' --monitor-secs 5`
- Status: `2026-02-21` done (`usbmodem` prioritaire pour zacus, `usbmodem` pénalisé pour rtc).
## Boucle hardware RTC
- [x] T-101 - Discover hardware RTC
+8
View File
@@ -9,6 +9,9 @@ Last updated: 2026-02-21
- [x] I-003 - Ensure local Prometheus backend exists (`prometheus` binary installed).
- [x] I-004 - Resolve open mirror PR redundancy (`PR #7` merge/close decision).
- [x] I-005 - Enable local AI fallback (`ollama` + local model) for credit savings.
- [x] I-006 - Enforce local-only chat mode option (`--local-only`) with `ollama/lmstudio` detection.
- [x] I-007 - Align OpenClaw default model to local `ollama/llama3.2:1b` + cloud fallbacks for continuity.
- [x] I-008 - Add provider/agentic scanner (`tools/ai/zeroclaw_provider_scan.sh`) for live capability matrix.
## Daily autonomous sequence
@@ -31,6 +34,11 @@ Last updated: 2026-02-21
- status: `2026-02-21` done (ESP32-S3 mismatch auto-corrected to `freenove_esp32s3`).
- [x] D-005 - Review `artifacts/zeroclaw/gateway.log` + `conversations.jsonl`.
- [x] D-006 - Corriger l'association cible↔port
- `RTC_UPLOAD_PORT_HINT` cible Audio Kit (`cp2102`, `esp32audiokit`, `audio`).
- `ZACUS_UPLOAD_PORT_HINT` cible Freenove/S3 (`usbmodem`, `1a86`, `ch340`, `freenove`).
- status: `2026-02-21` done.
## Hardware safety gates
- [x] H-001 - Flash/upload/monitor are forced by default when a board is detected.
+657 -9
View File
@@ -34,6 +34,9 @@ PREFER_LOCAL_AI="${ZEROCLAW_PREFER_LOCAL_AI:-0}"
OLLAMA_MODEL="${ZEROCLAW_OLLAMA_MODEL:-llama3.2:1b}"
OLLAMA_AUTO_PULL="${ZEROCLAW_OLLAMA_AUTO_PULL:-0}"
OLLAMA_WARMUP="${ZEROCLAW_OLLAMA_WARMUP:-1}"
LMSTUDIO_BASE_URL="${ZEROCLAW_LMSTUDIO_BASE_URL:-http://127.0.0.1:1234/v1}"
LMSTUDIO_MODEL="${ZEROCLAW_LMSTUDIO_MODEL:-}"
LOCAL_PROVIDER_ORDER="${ZEROCLAW_LOCAL_PROVIDER_ORDER:-ollama,lmstudio}"
GW_PID_FILE="$ART_DIR/gateway.pid"
FW_PID_FILE="$ART_DIR/follow.pid"
@@ -52,6 +55,7 @@ GW_MANAGED_FILE="$ART_DIR/gateway.managed"
FW_MANAGED_FILE="$ART_DIR/follow.managed"
PROM_MANAGED_FILE="$ART_DIR/prometheus.managed"
WATCHER_SCRIPT="$ROOT_DIR/tools/ai/zeroclaw_watch_1min.sh"
ORCHESTRATOR_SERVER="$ROOT_DIR/tools/ai/zeroclaw_orchestrator_server.py"
RT_LOG="$ART_DIR/realtime_1min.log"
mkdir -p "$ART_DIR"
@@ -164,9 +168,67 @@ PY
return 1
}
if ensure_ollama_ready; then
preferred_provider="ollama"
preferred_model="$OLLAMA_MODEL"
lmstudio_first_model() {
python3 - "$LMSTUDIO_BASE_URL" <<'PY'
import json
import sys
import urllib.request
base = sys.argv[1].rstrip("/")
url = f"{base}/models"
try:
req = urllib.request.Request(url, headers={"Accept": "application/json"})
with urllib.request.urlopen(req, timeout=3) as resp:
payload = json.loads(resp.read().decode("utf-8", "replace"))
models = payload.get("data", [])
if isinstance(models, list):
for item in models:
if isinstance(item, dict):
model_id = str(item.get("id", "")).strip()
if model_id:
print(model_id)
raise SystemExit(0)
except Exception:
pass
raise SystemExit(1)
PY
}
ensure_lmstudio_ready() {
[[ "$PREFER_LOCAL_AI" == "1" ]] || return 1
local discovered
discovered="$(lmstudio_first_model 2>/dev/null || true)"
[[ -n "$discovered" ]] || return 1
LMSTUDIO_MODEL="$discovered"
export LMSTUDIO_BASE_URL
export LMSTUDIO_API_KEY="${LMSTUDIO_API_KEY:-lm-studio}"
return 0
}
if [[ "$PREFER_LOCAL_AI" == "1" ]]; then
IFS=',' read -r -a local_provider_order <<<"$LOCAL_PROVIDER_ORDER"
for local_provider in "${local_provider_order[@]}"; do
case "${local_provider// /}" in
ollama)
if ensure_ollama_ready; then
preferred_provider="ollama"
preferred_model="$OLLAMA_MODEL"
break
fi
;;
lmstudio)
if ensure_lmstudio_ready; then
preferred_provider="lmstudio"
preferred_model="$LMSTUDIO_MODEL"
break
fi
;;
esac
done
fi
if [[ -n "$preferred_provider" ]]; then
:
elif env -u ZEROCLAW_WORKSPACE "$ZEROCLAW_BIN" auth status 2>/dev/null | rg -q "openai-codex:"; then
preferred_provider="openai-codex"
preferred_model="$OPENAI_CODEX_MODEL"
@@ -177,7 +239,7 @@ PY
return 0
fi
if [[ "$preferred_provider" == "ollama" ]]; then
if [[ "$preferred_provider" == "ollama" || "$preferred_provider" == "lmstudio" ]]; then
if env -u ZEROCLAW_WORKSPACE "$ZEROCLAW_BIN" auth status 2>/dev/null | rg -q "openai-codex:"; then
fallback_csv="openai-codex"
fallback_models_csv="$OPENAI_CODEX_MODEL"
@@ -592,7 +654,18 @@ elif [[ -n "$(listener_pid_on_port "$FOLLOW_PORT")" ]]; then
printf '%s\n' "$existing_follow_pid" >"$FW_PID_FILE"
rm -f "$FW_MANAGED_FILE"
else
nohup python3 -m http.server "$FOLLOW_PORT" --bind 127.0.0.1 --directory "$ART_DIR" >"$FW_LOG" 2>&1 &
if [[ -f "$ORCHESTRATOR_SERVER" ]]; then
nohup python3 "$ORCHESTRATOR_SERVER" \
--host 127.0.0.1 \
--port "$FOLLOW_PORT" \
--directory "$ART_DIR" \
--root-dir "$ROOT_DIR" \
--gateway-url "http://$GATEWAY_HOST:$GATEWAY_PORT" \
--prom-url "http://$PROM_HOST:$PROM_PORT" \
>"$FW_LOG" 2>&1 &
else
nohup python3 -m http.server "$FOLLOW_PORT" --bind 127.0.0.1 --directory "$ART_DIR" >"$FW_LOG" 2>&1 &
fi
echo "$!" >"$FW_PID_FILE"
printf '%s\n' "1" >"$FW_MANAGED_FILE"
fi
@@ -646,7 +719,7 @@ cat >"$INDEX_FILE" <<EOF
<head>
<meta charset="utf-8" />
<meta name="viewport" content="width=device-width, initial-scale=1" />
<title>ZeroClaw Live Follow</title>
<title>ZeroClaw Orchestrator</title>
<style>
:root {
--bg: #f7f8fa;
@@ -693,6 +766,25 @@ cat >"$INDEX_FILE" <<EOF
padding: 5px 10px;
font-size: 13px;
}
.alert-banner {
border: 1px solid #d97706;
background: #fff7ed;
color: #9a3412;
border-radius: 10px;
padding: 8px 10px;
margin-bottom: 12px;
font-size: 13px;
display: none;
}
.alert-banner.show {
display: block;
}
.ops-grid {
display: grid;
grid-template-columns: 1fr 1fr;
gap: 12px;
margin-bottom: 12px;
}
.grid {
display: grid;
grid-template-columns: 1fr 1fr;
@@ -714,9 +806,16 @@ cat >"$INDEX_FILE" <<EOF
border-bottom: 1px solid var(--line);
font-size: 16px;
}
.panel .body {
padding: 12px 14px;
display: flex;
flex-direction: column;
gap: 10px;
flex: 1;
}
.panel pre {
margin: 0;
padding: 12px 14px;
padding: 10px 12px;
overflow: auto;
white-space: pre-wrap;
word-break: break-word;
@@ -724,6 +823,124 @@ cat >"$INDEX_FILE" <<EOF
font-size: 12px;
line-height: 1.4;
flex: 1;
background: #fafbfd;
border: 1px solid var(--line);
border-radius: 8px;
}
textarea {
width: 100%;
min-height: 64px;
resize: vertical;
padding: 8px;
font-size: 13px;
border: 1px solid var(--line);
border-radius: 8px;
font-family: "SF Pro Text", "Segoe UI", Arial, sans-serif;
}
.btn-row {
display: flex;
flex-wrap: wrap;
gap: 8px;
}
button {
border: 1px solid var(--line);
background: #fdfefe;
color: var(--ink);
border-radius: 8px;
padding: 8px 10px;
cursor: pointer;
font-size: 12px;
}
button.primary {
border-color: #245fa1;
color: #fff;
background: #245fa1;
}
button:disabled {
opacity: 0.5;
cursor: not-allowed;
}
.hint {
color: var(--muted);
font-size: 12px;
margin: 0;
}
.status-block {
color: var(--muted);
font-size: 12px;
border: 1px dashed var(--line);
border-radius: 8px;
padding: 8px 10px;
}
.questions-grid {
display: grid;
grid-template-columns: 1fr 1fr;
gap: 12px;
margin-bottom: 12px;
}
.question-item {
border: 1px solid var(--line);
border-radius: 8px;
padding: 8px;
background: #fcfdff;
margin-bottom: 8px;
}
.question-item.blocking {
border-color: #f59e0b;
background: #fffaf0;
}
.question-title {
font-size: 13px;
font-weight: 600;
margin-bottom: 4px;
}
.question-meta {
font-size: 11px;
color: var(--muted);
margin-bottom: 6px;
}
.question-context {
font-size: 12px;
white-space: pre-wrap;
border: 1px solid var(--line);
border-radius: 8px;
padding: 6px;
background: #fff;
margin-bottom: 8px;
}
.question-answer {
min-height: 52px;
margin-bottom: 6px;
}
.modal {
position: fixed;
inset: 0;
background: rgba(15, 23, 42, 0.5);
display: none;
align-items: center;
justify-content: center;
z-index: 9999;
padding: 16px;
}
.modal.open {
display: flex;
}
.modal-card {
width: min(760px, 100%);
background: #fff;
border: 1px solid var(--line);
border-radius: 12px;
box-shadow: 0 12px 40px rgba(17, 26, 41, 0.25);
padding: 14px;
}
.modal-card h3 {
margin: 0 0 8px;
font-size: 18px;
}
.modal-card .small {
margin: 0 0 8px;
font-size: 12px;
color: var(--muted);
}
.status {
margin-top: 10px;
@@ -731,6 +948,8 @@ cat >"$INDEX_FILE" <<EOF
font-size: 12px;
}
@media (max-width: 980px) {
.ops-grid { grid-template-columns: 1fr; }
.questions-grid { grid-template-columns: 1fr; }
.grid { grid-template-columns: 1fr; }
.panel { min-height: 320px; }
}
@@ -738,23 +957,96 @@ cat >"$INDEX_FILE" <<EOF
</head>
<body>
<main>
<h1>ZeroClaw Live Follow</h1>
<h1>ZeroClaw Orchestrator</h1>
<div class="meta">
Follow URL: <code>http://127.0.0.1:$FOLLOW_PORT/</code> |
Polling interval: <code>1s</code> |
Display cap: <code>500 lines/panel</code> |
Prometheus: <code>$PROM_STATUS</code>
Prometheus: <code>$PROM_STATUS</code> |
API: <code>/api/status</code> <code>/api/run</code>
</div>
<div id="questionAlert" class="alert-banner"></div>
<div class="links">
<a href="/conversations.jsonl">/conversations.jsonl</a>
<a href="/gateway.log">/gateway.log</a>
<a href="/realtime_1min.log">/realtime_1min.log</a>
<a href="/orchestrator.log">/orchestrator.log</a>
<a href="/prometheus.yml">/prometheus.yml</a>
<a href="http://$GATEWAY_HOST:$GATEWAY_PORT/health">/health</a>
<a href="http://$GATEWAY_HOST:$GATEWAY_PORT/metrics">/metrics</a>
<a href="http://$PROM_HOST:$PROM_PORT/targets">prometheus /targets</a>
<a href="http://$PROM_HOST:$PROM_PORT/graph">prometheus /graph</a>
</div>
<div class="ops-grid">
<section class="panel">
<h2>Orchestration Controls</h2>
<div class="body">
<p class="hint">Prompt general (source)</p>
<textarea id="generalPromptInput">Autonomy heartbeat: return concise status and blockers</textarea>
<div class="btn-row">
<button onclick="setGeneralPrompt('RTC post-flash check: verify audio wifi status and recent errors')">General RTC Quick</button>
<button onclick="setGeneralPrompt('Zacus post-flash check: verify network ui audio story state and recent errors')">General Zacus Quick</button>
<button onclick="setGeneralPrompt('Autonomy heartbeat: return concise status and blockers')">General Heartbeat</button>
<button onclick="deriveRepoPrompts()">Generate RTC+Zacus Prompts</button>
<button class="primary" onclick="runAction('general_prompt_fanout', true)">Send General -> RTC+Zacus</button>
</div>
<p class="hint">Prompt RTC</p>
<textarea id="rtcPromptInput">RTC post-flash check: verify audio wifi status and recent errors</textarea>
<p class="hint">Prompt Zacus</p>
<textarea id="zacusPromptInput">Zacus post-flash check: verify network ui audio story state and recent errors</textarea>
<div class="btn-row">
<button onclick="runAction('rtc_webhook', true)">Send RTC Prompt</button>
<button onclick="runAction('zacus_webhook', true)">Send Zacus Prompt</button>
</div>
<p class="hint">Operator presets (one-click chains with progress in Job panel)</p>
<div class="btn-row">
<button class="primary" onclick="runPreset('rtc_operator_chain', 'RTC post-flash check: verify audio wifi status and recent errors', true)">Run RTC Operator Chain</button>
<button class="primary" onclick="runPreset('zacus_operator_chain', 'Zacus post-flash check: verify network ui audio story state and recent errors', true)">Run Zacus Operator Chain</button>
<button class="primary" onclick="runPreset('daily_chain', '', false)">Run Daily Chain</button>
</div>
<div class="btn-row">
<button onclick="runAction('provider_scan', false)">Provider Scan</button>
<button onclick="runAction('rtc_provider_check', false)">RTC Provider Check</button>
<button onclick="runAction('zacus_provider_check', false)">Zacus Provider Check</button>
<button onclick="runAction('rtc_firmware_loop', false)">RTC Build/Flash/Monitor</button>
<button onclick="runAction('zacus_firmware_loop', false)">Zacus Build/Flash/Monitor</button>
<button onclick="stopJob()">Stop Current Job</button>
</div>
<div class="status-block" id="opsStatus">Waiting for API status...</div>
</div>
</section>
<section class="panel">
<h2>Job Progress</h2>
<div class="body">
<pre id="jobInfo">No job yet.</pre>
<pre id="jobTail">(job output)</pre>
</div>
</section>
</div>
<div class="questions-grid">
<section class="panel">
<h2>Questions / Decisions</h2>
<div class="body">
<p class="hint">Create a blocking question when a decision is needed.</p>
<textarea id="questionTitleInput">Decision needed</textarea>
<textarea id="questionContextInput">Context and current blocker...</textarea>
<textarea id="questionOptionsInput">A | B | C</textarea>
<textarea id="questionRecommendationInput">Recommended: B</textarea>
<div class="btn-row">
<label class="hint"><input type="checkbox" id="questionBlockingInput" checked> blocking</label>
<button class="primary" onclick="raiseQuestion()">Raise Question</button>
<button onclick="refreshQuestions()">Refresh Questions</button>
</div>
<div class="status-block" id="questionsSummary">No questions loaded.</div>
</div>
</section>
<section class="panel">
<h2>Open Questions</h2>
<div class="body">
<div id="openQuestions">(no open questions)</div>
</div>
</section>
</div>
<div class="grid">
<section class="panel">
<h2>Conversations (JSONL live)</h2>
@@ -767,15 +1059,28 @@ cat >"$INDEX_FILE" <<EOF
</div>
<div class="status" id="status">Polling started...</div>
</main>
<div id="questionPopup" class="modal">
<div class="modal-card">
<h3>Blocking Question</h3>
<p class="small" id="popupMeta"></p>
<pre id="popupBody"></pre>
<div class="btn-row">
<button onclick="closeQuestionPopup()">Close</button>
</div>
</div>
</div>
<script>
const MAX_LINES = 500;
const POLL_MS = 1000;
const API_POLL_MS = 1500;
let convoCount = 0;
let gatewayCount = 0;
let convoBuf = [];
let gatewayBuf = [];
let lastOk = null;
let runInFlight = false;
let lastPopupQuestionId = Number(localStorage.getItem("zc_last_popup_question_id") || "0");
function trimTail(lines) {
if (lines.length <= MAX_LINES) return lines;
@@ -838,6 +1143,345 @@ cat >"$INDEX_FILE" <<EOF
}
}
async function fetchJson(url) {
const response = await fetch(url + "?t=" + Date.now(), { cache: "no-store" });
const body = await response.text();
let parsed = {};
try {
parsed = body ? JSON.parse(body) : {};
} catch (error) {
parsed = { raw: body };
}
if (!response.ok) {
const msg = parsed.error || ("HTTP " + response.status);
throw new Error(msg);
}
return parsed;
}
function boolText(value) {
if (value === true) return "yes";
if (value === false) return "no";
return "unknown";
}
function closeQuestionPopup() {
document.getElementById("questionPopup").classList.remove("open");
}
function showQuestionPopup(question) {
if (!question) return;
const meta =
"id=" + safeText(question.id) +
" blocking=" + boolText(question.blocking) +
" created=" + safeText(question.created_at);
let body = safeText(question.title);
if (question.context) body += "\n\n" + safeText(question.context);
const options = Array.isArray(question.options) ? question.options : [];
if (options.length) body += "\n\nOptions: " + options.join(" | ");
if (question.recommendation) body += "\nRecommendation: " + safeText(question.recommendation);
document.getElementById("popupMeta").textContent = meta;
document.getElementById("popupBody").textContent = body;
document.getElementById("questionPopup").classList.add("open");
}
function renderOpenQuestions(openItems) {
const root = document.getElementById("openQuestions");
root.innerHTML = "";
if (!openItems.length) {
root.textContent = "(no open questions)";
return;
}
for (const q of openItems) {
const box = document.createElement("div");
box.className = "question-item" + (q.blocking ? " blocking" : "");
const title = document.createElement("div");
title.className = "question-title";
title.textContent = "#" + safeText(q.id) + " " + safeText(q.title);
box.appendChild(title);
const meta = document.createElement("div");
meta.className = "question-meta";
meta.textContent = "blocking=" + boolText(q.blocking) + " created=" + safeText(q.created_at);
box.appendChild(meta);
const ctx = document.createElement("div");
ctx.className = "question-context";
let ctxText = safeText(q.context || "");
const options = Array.isArray(q.options) ? q.options : [];
if (options.length) ctxText += (ctxText ? "\n" : "") + "Options: " + options.join(" | ");
if (q.recommendation) ctxText += (ctxText ? "\n" : "") + "Recommendation: " + safeText(q.recommendation);
ctx.textContent = ctxText || "(no context)";
box.appendChild(ctx);
const answer = document.createElement("textarea");
answer.className = "question-answer";
answer.id = "q-answer-" + safeText(q.id);
answer.placeholder = "Decision / answer...";
box.appendChild(answer);
const row = document.createElement("div");
row.className = "btn-row";
const resolveBtn = document.createElement("button");
resolveBtn.textContent = "Resolve";
resolveBtn.onclick = function () {
resolveQuestion(q.id);
};
const popupBtn = document.createElement("button");
popupBtn.textContent = "Popup";
popupBtn.onclick = function () {
showQuestionPopup(q);
};
row.appendChild(resolveBtn);
row.appendChild(popupBtn);
box.appendChild(row);
root.appendChild(box);
}
}
async function refreshQuestions() {
try {
const data = await fetchJson("/api/questions");
const openItems = Array.isArray(data.open_items) ? data.open_items : [];
const summary =
"open=" + safeText(data.open_count) +
" blocking_open=" + safeText(data.blocking_open_count) +
" total=" + safeText(Array.isArray(data.items) ? data.items.length : 0);
document.getElementById("questionsSummary").textContent = summary;
renderOpenQuestions(openItems);
const alertBox = document.getElementById("questionAlert");
if ((data.blocking_open_count || 0) > 0) {
alertBox.classList.add("show");
alertBox.textContent = "Blocking question open: " + safeText(data.blocking_open_count) + " (see Questions / Decisions)";
} else {
alertBox.classList.remove("show");
alertBox.textContent = "";
}
const latest = data.latest_open;
if (latest && latest.blocking && Number(latest.id) > lastPopupQuestionId) {
lastPopupQuestionId = Number(latest.id);
localStorage.setItem("zc_last_popup_question_id", String(lastPopupQuestionId));
showQuestionPopup(latest);
window.alert("New blocking question #" + safeText(latest.id) + ": " + safeText(latest.title));
}
} catch (error) {
document.getElementById("questionsSummary").textContent = "questions api error: " + error.message;
}
}
async function raiseQuestion() {
const payload = {
title: document.getElementById("questionTitleInput").value.trim(),
context: document.getElementById("questionContextInput").value.trim(),
options: document.getElementById("questionOptionsInput").value.trim(),
recommendation: document.getElementById("questionRecommendationInput").value.trim(),
blocking: document.getElementById("questionBlockingInput").checked,
};
try {
const response = await fetch("/api/questions", {
method: "POST",
headers: { "Content-Type": "application/json" },
body: JSON.stringify(payload),
});
const body = await response.text();
let parsed = {};
try {
parsed = body ? JSON.parse(body) : {};
} catch (error) {
parsed = { raw: body };
}
if (!response.ok) {
throw new Error(parsed.error || ("HTTP " + response.status));
}
setStatus("question raised", false);
await refreshQuestions();
} catch (error) {
setStatus("raise question failed: " + error.message, true);
}
}
async function resolveQuestion(id) {
const input = document.getElementById("q-answer-" + safeText(id));
const responseText = input ? input.value.trim() : "";
try {
const response = await fetch("/api/questions/resolve", {
method: "POST",
headers: { "Content-Type": "application/json" },
body: JSON.stringify({ id: id, response: responseText }),
});
const body = await response.text();
let parsed = {};
try {
parsed = body ? JSON.parse(body) : {};
} catch (error) {
parsed = { raw: body };
}
if (!response.ok) {
throw new Error(parsed.error || ("HTTP " + response.status));
}
setStatus("question resolved #" + safeText(id), false);
await refreshQuestions();
} catch (error) {
setStatus("resolve question failed: " + error.message, true);
}
}
async function refreshOps() {
try {
const status = await fetchJson("/api/status");
const health = status.health || {};
const last = status.last || {};
const job = status.job || {};
const ops =
"gateway_ok=" + boolText(health.gateway_ok) +
" status=" + safeText(health.gateway_status) +
" paired=" + boolText(health.paired) +
" prom_ok=" + boolText(health.prometheus_ok) +
" prom_status=" + safeText(health.prometheus_status) +
"\nlast_convo: " + safeText(last.conversation || "(none)") +
"\nlast_rt1m: " + safeText(last.realtime_1min || "(none)");
document.getElementById("opsStatus").textContent = ops;
const jobInfo =
"job_id=" + safeText(job.job_id) +
" running=" + boolText(job.running) +
" action=" + safeText(job.action) +
"\nstarted_at=" + safeText(job.started_at) +
" ended_at=" + safeText(job.ended_at) +
" returncode=" + safeText(job.returncode);
document.getElementById("jobInfo").textContent = jobInfo;
const tail = Array.isArray(job.tail) ? job.tail : [];
document.getElementById("jobTail").textContent = tail.length ? tail.join("\n") : "(job output)";
} catch (error) {
document.getElementById("opsStatus").textContent = "api status error: " + error.message;
}
}
function setButtonsDisabled(disabled) {
const buttons = document.querySelectorAll("button");
for (const btn of buttons) {
btn.disabled = disabled;
}
}
function setGeneralPrompt(text) {
document.getElementById("generalPromptInput").value = text;
setStatus("general prompt template loaded", false);
}
function deriveRepoPrompts() {
const general = document.getElementById("generalPromptInput").value.trim();
if (!general) {
setStatus("general prompt is required", true);
return;
}
const rtcPrompt =
general +
"\\nContexte cible: RTC_BL_PHONE sur ESP32 Audio Kit." +
"\\nAttendu: diagnostic audio/Bluetooth/WiFi/WebServer + erreurs recentes + prochaine action concise.";
const zacusPrompt =
general +
"\\nContexte cible: le-mystere-professeur-zacus sur Freenove ESP32-S3 (usbmodem)." +
"\\nAttendu: diagnostic UI/story/audio/network + erreurs recentes + prochaine action concise.";
document.getElementById("rtcPromptInput").value = rtcPrompt;
document.getElementById("zacusPromptInput").value = zacusPrompt;
setStatus("rtc/zacus prompts generated from general prompt", false);
}
function getPromptForAction(action) {
if (action === "rtc_webhook" || action === "rtc_operator_chain") {
return document.getElementById("rtcPromptInput").value.trim();
}
if (action === "zacus_webhook" || action === "zacus_operator_chain") {
return document.getElementById("zacusPromptInput").value.trim();
}
if (action === "general_prompt_fanout") {
return document.getElementById("generalPromptInput").value.trim();
}
return document.getElementById("generalPromptInput").value.trim();
}
async function runPreset(action, defaultPrompt, needsMessage) {
if (needsMessage) {
let input = null;
if (action === "rtc_operator_chain") input = document.getElementById("rtcPromptInput");
if (action === "zacus_operator_chain") input = document.getElementById("zacusPromptInput");
if (!input) input = document.getElementById("generalPromptInput");
if (!input.value.trim() && defaultPrompt) {
input.value = defaultPrompt;
}
}
await runAction(action, needsMessage);
}
async function runAction(action, needsMessage) {
if (runInFlight) return;
const payload = { action: action };
if (needsMessage) {
const message = getPromptForAction(action);
if (!message) {
setStatus("prompt is required for " + action, true);
return;
}
payload.message = message;
}
runInFlight = true;
setButtonsDisabled(true);
try {
const response = await fetch("/api/run", {
method: "POST",
headers: { "Content-Type": "application/json" },
body: JSON.stringify(payload),
});
const body = await response.text();
let parsed = {};
try {
parsed = body ? JSON.parse(body) : {};
} catch (error) {
parsed = { raw: body };
}
if (!response.ok) {
throw new Error(parsed.error || ("HTTP " + response.status));
}
setStatus("action started: " + action, false);
} catch (error) {
setStatus("action failed: " + action + " -> " + error.message, true);
} finally {
runInFlight = false;
setButtonsDisabled(false);
await refreshOps();
}
}
async function stopJob() {
try {
const response = await fetch("/api/stop", {
method: "POST",
headers: { "Content-Type": "application/json" },
body: "{}",
});
const body = await response.text();
let parsed = {};
try {
parsed = body ? JSON.parse(body) : {};
} catch (error) {
parsed = { raw: body };
}
if (!response.ok) {
throw new Error(parsed.error || ("HTTP " + response.status));
}
setStatus("job stop requested", false);
} catch (error) {
setStatus("stop failed: " + error.message, true);
} finally {
await refreshOps();
}
}
function setStatus(message, isError) {
const now = new Date().toISOString();
lastOk = !isError;
@@ -859,6 +1503,10 @@ cat >"$INDEX_FILE" <<EOF
tick();
setInterval(tick, POLL_MS);
refreshOps();
setInterval(refreshOps, API_POLL_MS);
refreshQuestions();
setInterval(refreshQuestions, API_POLL_MS);
</script>
</body>
</html>