Logs
+ Select a run and a stage (T1, T2, T3, T3 Reflection, T4, Apply, Turn). Use the search box to filter entries. Perf logs are optional and off by default.
-
+
-
-
-
-
-
+
+
+
+
+
+
+
diff --git a/frontend/src/components/logs.ts b/frontend/src/components/logs.ts
index 26e9468..e201992 100644
--- a/frontend/src/components/logs.ts
+++ b/frontend/src/components/logs.ts
@@ -1,42 +1,118 @@
import { el, clear } from "../util/dom.js";
import { stableSort } from "../util/sort.js";
import { renderJSONPre } from "../ui/jsonview.js";
-import type { RunBundle } from "../state.js";
+import type { RunBundle, Stage } from "../state.js";
-export function renderLogs(container: HTMLElement, bundle: RunBundle, showPerf: boolean, selected: string | null) {
+/**
+ * Renders Logs with basic UX:
+ * - Run selector (#logRunSelect) populated from bundle.runs or single-run fallback
+ * - Stage chips (.stagetab[data-stage]) filter entries
+ * - Optional text search (#logSearch) over JSON stringified entries
+ * - Perf panel remains as before (gated by showPerf)
+ */
+export function renderLogs(container: HTMLElement, bundle: RunBundle, showPerf: boolean, selectedPerfKey: string | null) {
clear(container);
- // Base logs
- const base = el("div", { class: "log-block" }, [
- el("h4", {}, ["Logs"]),
- ]);
- container.append(base);
- renderJSONPre(base.appendChild(el("pre")), bundle.logs ?? {});
-
- // Perf logs (gated)
- if (!showPerf) return;
-
- const perf = bundle.perf ?? {};
- const keys = stableSort(Object.keys(perf), k => k);
- const header = el("div", { class: "perf-header" }, [el("h4", {}, ["Perf logs (experimental)"])]);
- const select = el("select") as HTMLSelectElement;
- select.append(el("option", { value: "" }, ["— pick a file —"]));
- for (const k of keys) select.append(el("option", { value: k, selected: selected === k }, [k]));
- header.append(select);
- container.append(header);
-
- const pane = el("div", { class: "perf-pane" });
- container.append(pane);
-
- const renderOne = (k: string) => {
- clear(pane);
- if (!k) return;
- pane.append(el("h5", {}, [k]));
- const entries = perf[k] ?? [];
- pane.append(el("div", { class: "perf-count" }, [`${entries.length} entries`]));
- renderJSONPre(pane.appendChild(el("pre")), entries);
- };
-
- renderOne(selected ?? "");
- select.addEventListener("change", () => renderOne(select.value));
+ // Normalize to runs[]
+ type RunLike = { id: string; logs: Record };
+ const runs: RunLike[] = Array.isArray(bundle.runs) && (bundle.runs as any[]).length
+ ? (bundle.runs as any[]).map((r, i) => ({ id: String((r as any).id ?? `run-${i+1}`), logs: (r as any).logs ?? {} }))
+ : [{ id: "run-1", logs: bundle.logs ?? {} }];
+
+ // Wire run select
+ const runSel = document.querySelector("#logRunSelect");
+ if (runSel) {
+ const prev = runSel.value;
+ runSel.innerHTML = "";
+ runs.forEach((r, i) => {
+ const opt = document.createElement("option");
+ opt.value = String(i);
+ opt.textContent = r.id;
+ runSel.appendChild(opt);
+ });
+ const idx = /^\d+$/.test(prev) && Number(prev) < runs.length ? Number(prev) : 0;
+ runSel.value = String(idx);
+ }
+
+ // Stage selection via chips
+ const stages: Stage[] = ["t1", "t2", "t3", "t3_reflection", "t4", "apply", "turn"];
+ const chips = Array.from(document.querySelectorAll(".log-tabs .stagetab"));
+ const activeChip = chips.find(b => b.classList.contains("active"));
+ let selectedStage: Stage = (activeChip?.dataset.stage as Stage) || "t1";
+
+ // Search box
+ const searchBox = document.querySelector("#logSearch");
+
+ // Counts header
+ const countsPane = document.querySelector("#logCounts");
+
+ function filterEntries(arr: unknown[]): unknown[] {
+ const q = searchBox?.value?.trim() ?? "";
+ if (!q) return arr;
+ const needle = q.toLowerCase();
+ return arr.filter(e => {
+ try { return JSON.stringify(e).toLowerCase().includes(needle); } catch { return false; }
+ });
+ }
+
+ function renderBody() {
+ clear(container);
+ const runIdx = runSel ? Math.min(Math.max(parseInt(runSel.value || "0", 10) || 0, 0), runs.length - 1) : 0;
+ const run = runs[runIdx];
+
+ // counts
+ const stageCounts: Record = {};
+ stages.forEach(s => { stageCounts[s] = Array.isArray((run.logs as any)[s]) ? ((run.logs as any)[s] as any[]).length : 0; });
+ if (countsPane) {
+ countsPane.textContent = stages.map(s => `${s.toUpperCase()}: ${stageCounts[s]}`).join(" • ");
+ }
+
+ // render selected stage entries
+ const entries: unknown[] = Array.isArray((run.logs as any)[selectedStage]) ? ((run.logs as any)[selectedStage] as unknown[]) : [];
+ const filtered = filterEntries(entries);
+
+ const base = el("div", { class: "log-block" }, [
+ el("h4", {}, [`Logs — ${selectedStage.toUpperCase()} (${filtered.length})`]),
+ ]);
+ container.append(base);
+ renderJSONPre(base.appendChild(el("pre")), filtered);
+
+ // Perf logs (gated)
+ if (showPerf) {
+ const perf = (bundle as any).perf ?? {};
+ const keys = stableSort(Object.keys(perf), k => k);
+ const header = el("div", { class: "perf-header" }, [el("h4", {}, ["Perf logs (experimental)"])]);
+ const select = el("select") as HTMLSelectElement;
+ select.append(el("option", { value: "" }, ["— pick a file —"]));
+ for (const k of keys) select.append(el("option", { value: k, selected: selectedPerfKey === k }, [k]));
+ header.append(select);
+ container.append(header);
+
+ const pane = el("div", { class: "perf-pane" });
+ container.append(pane);
+ const renderPerf = (k: string) => {
+ clear(pane);
+ if (!k) return;
+ pane.append(el("h5", {}, [k]));
+ const entries = (perf as any)[k] ?? [];
+ pane.append(el("div", { class: "perf-count" }, [`${entries.length} entries`]));
+ renderJSONPre(pane.appendChild(el("pre")), entries);
+ };
+ renderPerf(select.value || "");
+ select.addEventListener("change", () => renderPerf(select.value));
+ }
+ }
+
+ // Wire events once per render (cheap)
+ chips.forEach(b => {
+ b.addEventListener("click", () => {
+ chips.forEach(x => x.classList.toggle("active", x === b));
+ selectedStage = (b.dataset.stage as Stage) || "t1";
+ renderBody();
+ });
+ });
+ if (runSel) runSel.addEventListener("change", renderBody);
+ if (searchBox) searchBox.addEventListener("input", () => { renderBody(); });
+
+ renderBody();
}
diff --git a/frontend/src/state.ts b/frontend/src/state.ts
index 3a45932..58f5190 100644
--- a/frontend/src/state.ts
+++ b/frontend/src/state.ts
@@ -1,10 +1,21 @@
-export type Stage = "t1" | "t2" | "t4" | "apply" | "turn";
+export type Stage = "t1" | "t2" | "t3" | "t3_reflection" | "t4" | "apply" | "turn";
export interface RunBundle {
meta?: Record;
runs?: unknown[];
snapshots?: unknown[];
- logs?: Record;
+ logs?: {
+ t1?: unknown[];
+ t2?: unknown[];
+ t3?: unknown[];
+ t3_plan?: unknown[];
+ t3_dialogue?: unknown[];
+ t3_reflection?: unknown[];
+ t4?: unknown[];
+ apply?: unknown[];
+ turn?: unknown[];
+ [k: string]: unknown;
+ };
perf?: Record;
stage_order?: Stage[];
}
diff --git a/frontend/tsdist/assets/components/logs.js b/frontend/tsdist/assets/components/logs.js
index be559e4..af05014 100644
--- a/frontend/tsdist/assets/components/logs.js
+++ b/frontend/tsdist/assets/components/logs.js
@@ -1,37 +1,110 @@
import { el, clear } from "../util/dom.js";
import { stableSort } from "../util/sort.js";
import { renderJSONPre } from "../ui/jsonview.js";
-export function renderLogs(container, bundle, showPerf, selected) {
+/**
+ * Renders Logs with basic UX:
+ * - Run selector (#logRunSelect) populated from bundle.runs or single-run fallback
+ * - Stage chips (.stagetab[data-stage]) filter entries
+ * - Optional text search (#logSearch) over JSON stringified entries
+ * - Perf panel remains as before (gated by showPerf)
+ */
+export function renderLogs(container, bundle, showPerf, selectedPerfKey) {
clear(container);
- // Base logs
- const base = el("div", { class: "log-block" }, [
- el("h4", {}, ["Logs"]),
- ]);
- container.append(base);
- renderJSONPre(base.appendChild(el("pre")), bundle.logs ?? {});
- // Perf logs (gated)
- if (!showPerf)
- return;
- const perf = bundle.perf ?? {};
- const keys = stableSort(Object.keys(perf), k => k);
- const header = el("div", { class: "perf-header" }, [el("h4", {}, ["Perf logs (experimental)"])]);
- const select = el("select");
- select.append(el("option", { value: "" }, ["— pick a file —"]));
- for (const k of keys)
- select.append(el("option", { value: k, selected: selected === k }, [k]));
- header.append(select);
- container.append(header);
- const pane = el("div", { class: "perf-pane" });
- container.append(pane);
- const renderOne = (k) => {
- clear(pane);
- if (!k)
- return;
- pane.append(el("h5", {}, [k]));
- const entries = perf[k] ?? [];
- pane.append(el("div", { class: "perf-count" }, [`${entries.length} entries`]));
- renderJSONPre(pane.appendChild(el("pre")), entries);
- };
- renderOne(selected ?? "");
- select.addEventListener("change", () => renderOne(select.value));
+ const runs = Array.isArray(bundle.runs) && bundle.runs.length
+ ? bundle.runs.map((r, i) => ({ id: String(r.id ?? `run-${i + 1}`), logs: r.logs ?? {} }))
+ : [{ id: "run-1", logs: bundle.logs ?? {} }];
+ // Wire run select
+ const runSel = document.querySelector("#logRunSelect");
+ if (runSel) {
+ const prev = runSel.value;
+ runSel.innerHTML = "";
+ runs.forEach((r, i) => {
+ const opt = document.createElement("option");
+ opt.value = String(i);
+ opt.textContent = r.id;
+ runSel.appendChild(opt);
+ });
+ const idx = /^\d+$/.test(prev) && Number(prev) < runs.length ? Number(prev) : 0;
+ runSel.value = String(idx);
+ }
+ // Stage selection via chips
+ const stages = ["t1", "t2", "t3", "t3_reflection", "t4", "apply", "turn"];
+ const chips = Array.from(document.querySelectorAll(".log-tabs .stagetab"));
+ const activeChip = chips.find(b => b.classList.contains("active"));
+ let selectedStage = activeChip?.dataset.stage || "t1";
+ // Search box
+ const searchBox = document.querySelector("#logSearch");
+ // Counts header
+ const countsPane = document.querySelector("#logCounts");
+ function filterEntries(arr) {
+ const q = searchBox?.value?.trim() ?? "";
+ if (!q)
+ return arr;
+ const needle = q.toLowerCase();
+ return arr.filter(e => {
+ try {
+ return JSON.stringify(e).toLowerCase().includes(needle);
+ }
+ catch {
+ return false;
+ }
+ });
+ }
+ function renderBody() {
+ clear(container);
+ const runIdx = runSel ? Math.min(Math.max(parseInt(runSel.value || "0", 10) || 0, 0), runs.length - 1) : 0;
+ const run = runs[runIdx];
+ // counts
+ const stageCounts = {};
+ stages.forEach(s => { stageCounts[s] = Array.isArray(run.logs[s]) ? run.logs[s].length : 0; });
+ if (countsPane) {
+ countsPane.textContent = stages.map(s => `${s.toUpperCase()}: ${stageCounts[s]}`).join(" • ");
+ }
+ // render selected stage entries
+ const entries = Array.isArray(run.logs[selectedStage]) ? run.logs[selectedStage] : [];
+ const filtered = filterEntries(entries);
+ const base = el("div", { class: "log-block" }, [
+ el("h4", {}, [`Logs — ${selectedStage.toUpperCase()} (${filtered.length})`]),
+ ]);
+ container.append(base);
+ renderJSONPre(base.appendChild(el("pre")), filtered);
+ // Perf logs (gated)
+ if (showPerf) {
+ const perf = bundle.perf ?? {};
+ const keys = stableSort(Object.keys(perf), k => k);
+ const header = el("div", { class: "perf-header" }, [el("h4", {}, ["Perf logs (experimental)"])]);
+ const select = el("select");
+ select.append(el("option", { value: "" }, ["— pick a file —"]));
+ for (const k of keys)
+ select.append(el("option", { value: k, selected: selectedPerfKey === k }, [k]));
+ header.append(select);
+ container.append(header);
+ const pane = el("div", { class: "perf-pane" });
+ container.append(pane);
+ const renderPerf = (k) => {
+ clear(pane);
+ if (!k)
+ return;
+ pane.append(el("h5", {}, [k]));
+ const entries = perf[k] ?? [];
+ pane.append(el("div", { class: "perf-count" }, [`${entries.length} entries`]));
+ renderJSONPre(pane.appendChild(el("pre")), entries);
+ };
+ renderPerf(select.value || "");
+ select.addEventListener("change", () => renderPerf(select.value));
+ }
+ }
+ // Wire events once per render (cheap)
+ chips.forEach(b => {
+ b.addEventListener("click", () => {
+ chips.forEach(x => x.classList.toggle("active", x === b));
+ selectedStage = b.dataset.stage || "t1";
+ renderBody();
+ });
+ });
+ if (runSel)
+ runSel.addEventListener("change", renderBody);
+ if (searchBox)
+ searchBox.addEventListener("input", () => { renderBody(); });
+ renderBody();
}
diff --git a/man/clematis-bench-t4.1 b/man/clematis-bench-t4.1
index 9bec7d0..8f2f94c 100644
--- a/man/clematis-bench-t4.1
+++ b/man/clematis-bench-t4.1
@@ -1,4 +1,4 @@
-.TH clematis-bench-t4 1 "2024-01-01" "Clematis 0.10.0" "User Commands"
+.TH clematis-bench-t4 1 "2024-01-01" "Clematis 0.10.2" "User Commands"
.SH NAME
clematis\-bench\-t4 \\\- Delegates to scripts/ for 'bench\-t4'
.SH SYNOPSIS
diff --git a/man/clematis-console.1 b/man/clematis-console.1
index 4162829..156d36f 100644
--- a/man/clematis-console.1
+++ b/man/clematis-console.1
@@ -1,4 +1,4 @@
-.TH clematis-console 1 "2024-01-01" "Clematis 0.10.0" "User Commands"
+.TH clematis-console 1 "2024-01-01" "Clematis 0.10.2" "User Commands"
.SH NAME
clematis\-console \\\- Delegates to scripts/ for 'console'
.SH SYNOPSIS
diff --git a/man/clematis-demo.1 b/man/clematis-demo.1
index 71aac33..cdd0834 100644
--- a/man/clematis-demo.1
+++ b/man/clematis-demo.1
@@ -1,4 +1,4 @@
-.TH clematis-demo 1 "2024-01-01" "Clematis 0.10.0" "User Commands"
+.TH clematis-demo 1 "2024-01-01" "Clematis 0.10.2" "User Commands"
.SH NAME
clematis\-demo \\\- Delegates to scripts/ for 'demo'
.SH SYNOPSIS
diff --git a/man/clematis-export-logs.1 b/man/clematis-export-logs.1
index 38cef55..a4d3ed9 100644
--- a/man/clematis-export-logs.1
+++ b/man/clematis-export-logs.1
@@ -1,4 +1,4 @@
-.TH clematis-export-logs 1 "2024-01-01" "Clematis 0.10.0" "User Commands"
+.TH clematis-export-logs 1 "2024-01-01" "Clematis 0.10.2" "User Commands"
.SH NAME
clematis\-export\-logs \\\- Delegates to scripts/ for 'export\-logs'
.SH SYNOPSIS
diff --git a/man/clematis-inspect-snapshot.1 b/man/clematis-inspect-snapshot.1
index 890c48a..2ba6f65 100644
--- a/man/clematis-inspect-snapshot.1
+++ b/man/clematis-inspect-snapshot.1
@@ -1,4 +1,4 @@
-.TH clematis-inspect-snapshot 1 "2024-01-01" "Clematis 0.10.0" "User Commands"
+.TH clematis-inspect-snapshot 1 "2024-01-01" "Clematis 0.10.2" "User Commands"
.SH NAME
clematis\-inspect\-snapshot \\\- Delegates to scripts/ for 'inspect\-snapshot'
.SH SYNOPSIS
diff --git a/man/clematis-rotate-logs.1 b/man/clematis-rotate-logs.1
index 203403c..868c790 100644
--- a/man/clematis-rotate-logs.1
+++ b/man/clematis-rotate-logs.1
@@ -1,4 +1,4 @@
-.TH clematis-rotate-logs 1 "2024-01-01" "Clematis 0.10.0" "User Commands"
+.TH clematis-rotate-logs 1 "2024-01-01" "Clematis 0.10.2" "User Commands"
.SH NAME
clematis\-rotate\-logs \\\- Delegates to scripts/ for 'rotate\-logs'
.SH SYNOPSIS
diff --git a/man/clematis-seed-lance-demo.1 b/man/clematis-seed-lance-demo.1
index 0ccabc2..9e4867b 100644
--- a/man/clematis-seed-lance-demo.1
+++ b/man/clematis-seed-lance-demo.1
@@ -1,4 +1,4 @@
-.TH clematis-seed-lance-demo 1 "2024-01-01" "Clematis 0.10.0" "User Commands"
+.TH clematis-seed-lance-demo 1 "2024-01-01" "Clematis 0.10.2" "User Commands"
.SH NAME
clematis\-seed\-lance\-demo \\\- Delegates to scripts/ for 'seed\-lance\-demo'
.SH SYNOPSIS
diff --git a/man/clematis-validate.1 b/man/clematis-validate.1
index 2f732ae..b198e83 100644
--- a/man/clematis-validate.1
+++ b/man/clematis-validate.1
@@ -1,4 +1,4 @@
-.TH clematis-validate 1 "2024-01-01" "Clematis 0.10.0" "User Commands"
+.TH clematis-validate 1 "2024-01-01" "Clematis 0.10.2" "User Commands"
.SH NAME
clematis\-validate \\\- Delegates to scripts/ for 'validate'
.SH SYNOPSIS
diff --git a/man/clematis.1 b/man/clematis.1
index 81c51cd..4ccc062 100644
--- a/man/clematis.1
+++ b/man/clematis.1
@@ -1,4 +1,4 @@
-.TH clematis 1 "2024-01-01" "Clematis 0.10.0" "User Commands"
+.TH clematis 1 "2024-01-01" "Clematis 0.10.2" "User Commands"
.SH NAME
clematis \\\- umbrella CLI for Clematis
.SH SYNOPSIS
@@ -9,7 +9,7 @@ umbrella CLI for Clematis
.nf
usage: clematis [\-h] [\-\-version] ...
-Clematis umbrella CLI (v0.10.0)
+Clematis umbrella CLI (v0.10.2)
options:
\-h, \-\-help show this help message and exit
diff --git a/scripts/console.py b/scripts/console.py
index e9f403d..97f283a 100644
--- a/scripts/console.py
+++ b/scripts/console.py
@@ -141,10 +141,52 @@ def adapter_step(state: dict, now_ms: int, input_text: str):
# Prepare deterministic context
try:
from types import SimpleNamespace
- # Stages (e.g., t1) access ctx.cfg.t1 and expect a dict there.
- # Provide empty sections; orchestrator will derive budgets on the fly.
- cfg_ns = SimpleNamespace(t1={}, t2={}, t3={}, scheduler={})
+ # Build a small t3 config from environment flags so orchestrator can pick it up
+ _t3_allow = (os.environ.get("CLEMATIS_T3_ALLOW") == "1")
+ _t3_apply = (os.environ.get("CLEMATIS_T3_APPLY_OPS") == "1")
+ _llm_mode = os.environ.get("CLEMATIS_LLM_MODE", "mock")
+ _llm_cassette = os.environ.get("CLEMATIS_LLM_CASSETTE")
+ _backend = "rulebased" if _llm_mode == "rulebased" else "llm"
+
+ cfg_ns = SimpleNamespace(
+ t1={},
+ t2={},
+ t3={
+ "enabled": _t3_allow,
+ "allow": _t3_allow, # alias accepted by orchestrator
+ "apply_ops": _t3_apply,
+ "backend": _backend,
+ "llm": {"mode": _llm_mode, "cassette": _llm_cassette},
+ "max_rag_loops": 1,
+ },
+ scheduler={},
+ )
ctx = SimpleNamespace(now_ms=now_ms, turn_id="1", agent_id="console", cfg=cfg_ns)
+
+ # Best-effort: attach an adapter if available for mock/replay/live; silently skip if not present
+ try:
+ if _backend == "llm":
+ if _llm_mode == "mock":
+ try:
+ from clematis.adapters.llm import FixtureLLMAdapter # type: ignore
+ ctx.llm_adapter = FixtureLLMAdapter()
+ except Exception:
+ pass
+ elif _llm_mode == "replay" and _llm_cassette:
+ try:
+ from clematis.adapters.llm import ReplayLLMAdapter # type: ignore
+ ctx.llm_adapter = ReplayLLMAdapter(_llm_cassette)
+ except Exception:
+ pass
+ elif _llm_mode == "live":
+ try:
+ from clematis.adapters.llm import LiveOpenAIAdapter # type: ignore
+ ctx.llm_adapter = LiveOpenAIAdapter.from_env() # may raise; ok to skip
+ except Exception:
+ pass
+ except Exception:
+ # never let adapter wiring break deterministic runs
+ pass
except Exception:
# Fallback (shouldn't happen): minimal mapping shape
ctx = {"now_ms": now_ms, "cfg": {"t1": {}, "t2": {}, "t3": {}, "scheduler": {}}}
@@ -292,7 +334,9 @@ def canonical(o: Any) -> Any:
return [canonical(x) for x in o]
return o
data = json.dumps(canonical(obj), indent=2, ensure_ascii=False)
- pathlib.Path(path).write_text(data + "\n", encoding="utf-8")
+ p = pathlib.Path(path)
+ p.parent.mkdir(parents=True, exist_ok=True)
+ p.write_text(data + "\n", encoding="utf-8")
def load_json(path: str) -> Dict[str, Any]:
with open(path, "r", encoding="utf-8") as f:
@@ -300,7 +344,7 @@ def load_json(path: str) -> Dict[str, Any]:
def summarize_bundle(bundle: Dict[str, Any]) -> Dict[str, Any]:
logs = bundle.get("logs") or {}
- stages = ("t1", "t2", "t4", "apply", "turn")
+ stages = ("t1", "t2", "t3", "t3_reflection", "t4", "apply", "turn")
counts = {k: len(logs.get(k, [])) for k in stages}
snaps_list = bundle.get("snapshots")
if isinstance(snaps_list, list):
@@ -352,6 +396,15 @@ def cmd_step(args: argparse.Namespace) -> int:
warn_nondeterminism()
st = adapter_reset(args.snapshot) if args.snapshot else adapter_reset(None)
now_ms = args.now_ms if args.now_ms is not None else DEFAULT_NOW_MS
+ # Propagate T3/LLM flags via env so the orchestrator gate can see them
+ if getattr(args, "t3", False):
+ os.environ["CLEMATIS_T3_ALLOW"] = "1"
+ if getattr(args, "t3_apply_ops", False):
+ os.environ["CLEMATIS_T3_APPLY_OPS"] = "1"
+ if getattr(args, "llm_mode", None):
+ os.environ["CLEMATIS_LLM_MODE"] = args.llm_mode
+ if getattr(args, "llm_cassette", None):
+ os.environ["CLEMATIS_LLM_CASSETTE"] = args.llm_cassette
st2, logs = adapter_step(st, now_ms=now_ms, input_text=(args.input or ""))
if args.out:
write_json(args.out, logs)
@@ -380,6 +433,21 @@ def build_parser() -> argparse.ArgumentParser:
p_step.add_argument("--snapshot", type=str, default=None, help="snapshot .json path (default: latest)")
p_step.add_argument("--now-ms", type=int, default=None, help=f"logical time (default: {DEFAULT_NOW_MS})")
p_step.add_argument("--input", type=str, default="", help="input text for the turn")
+ # T3 / LLM gating
+ p_step.add_argument("--t3", action="store_true", help="enable T3 (planner/dialogue/ops)")
+ p_step.add_argument("--t3-apply-ops", action="store_true", help="apply T3 ops to state (off by default)")
+ p_step.add_argument(
+ "--llm-mode",
+ choices=["mock", "replay", "live", "rulebased"],
+ default=os.environ.get("CLEMATIS_LLM_MODE", "mock"),
+ help="LLM backend mode (default: mock). 'rulebased' forces non-LLM speak",
+ )
+ p_step.add_argument(
+ "--llm-cassette",
+ type=str,
+ default=os.environ.get("CLEMATIS_LLM_CASSETTE"),
+ help="Path to replay cassette when --llm-mode=replay",
+ )
p_step.add_argument("--out", type=str, default=None, help="write logs to file (default: stdout)")
p_step.set_defaults(fn=cmd_step)
diff --git a/tests/frontend/test_example_bundle.py b/tests/frontend/test_example_bundle.py
new file mode 100644
index 0000000..cd2e023
--- /dev/null
+++ b/tests/frontend/test_example_bundle.py
@@ -0,0 +1,87 @@
+# tests/frontend/test_example_bundle.py
+"""
+Smoke test: the packaged demo bundle loads in the offline viewer (file://)
+
+- Uses importlib.resources to resolve both the viewer entry (index.html)
+ and the committed demo bundle under clematis/examples/run_bundles/.
+- Does NOT perform any network requests; we keep this minimal and rely on
+ existing offline tests for strict network banning.
+- Skips if frontend/dist/index.html is not present in the installed package.
+"""
+
+from pathlib import Path
+import pytest
+
+try:
+ from importlib.resources import files as r_files # Python 3.9+
+except Exception: # pragma: no cover
+ pytest.skip("importlib.resources.files unavailable", allow_module_level=True)
+
+PLAYWRIGHT = pytest.importorskip("playwright.sync_api")
+
+# Resolve packaged resources
+DIST_INDEX = r_files("clematis").joinpath("frontend/dist/index.html")
+DEMO_BUNDLE = r_files("clematis").joinpath("examples/run_bundles/run_demo_bundle.json")
+
+pytestmark = pytest.mark.skipif(
+ not Path(str(DIST_INDEX)).exists(),
+ reason="frontend/dist/index.html missing; run: make frontend-build",
+)
+
+def _file_url(p: Path) -> str:
+ return Path(p).resolve().as_uri()
+
+def _msg_text(msg):
+ # Robust across Playwright versions: method vs property vs str
+ try:
+ return msg.text() # method (older Python API)
+ except Exception:
+ try:
+ return msg.text # property (some builds)
+ except Exception:
+ return str(msg)
+
+def test_example_bundle_loads_without_network():
+ from playwright.sync_api import sync_playwright
+
+ idx = Path(str(DIST_INDEX))
+ bundle = Path(str(DEMO_BUNDLE))
+
+ assert bundle.exists(), "Demo bundle not present in package data"
+
+ with sync_playwright() as pw:
+ browser = pw.chromium.launch()
+ page = browser.new_page()
+
+ # Capture console for sanity (no http(s) errors expected)
+ logs = []
+ page.on("console", lambda msg: logs.append(_msg_text(msg)))
+
+ # Open viewer over file://
+ page.goto(_file_url(idx))
+
+ # Viewer UI should be present
+ page.wait_for_selector("#fileInput", state="attached")
+
+ # Attach the committed demo bundle via the file input
+ page.set_input_files("#fileInput", str(bundle))
+
+ # Wait until snapshot panel gets content (more stable than runsList items)
+ page.wait_for_selector("#snapshot", state="attached", timeout=10000)
+ page.wait_for_function(
+ "document.querySelector('#snapshot') && document.querySelector('#snapshot').textContent && document.querySelector('#snapshot').textContent.trim().length > 0",
+ timeout=10000,
+ )
+
+ # Snapshot panel should render some text
+ snap_txt = page.inner_text("#snapshot")
+ assert snap_txt.strip(), "Snapshot panel is empty after loading demo bundle"
+
+ # Quick sanity: no obvious http(s) errors in console
+ page.wait_for_timeout(100)
+ assert not any(
+ ("http://" in s.lower()) or ("https://" in s.lower()) or ("network" in s.lower())
+ for s in logs
+ ), f"Unexpected network-looking console logs: {logs}"
+
+ browser.close()