diff --git a/packages/ghost/lib/city-client.mjs b/packages/ghost/lib/city-client.mjs
index 632117a..8d8dbb8 100644
--- a/packages/ghost/lib/city-client.mjs
+++ b/packages/ghost/lib/city-client.mjs
@@ -31,6 +31,7 @@ const ICON = {
file: icon('' + GHOST(24, "ghost-mark--glow") + "
0 samples yet — point the recorder at your app (--app-url) so health samples arrive.
' + GHOST(24, "ghost-mark--glow") + "
the probe answered, but returned no rss/cpu numbers yet — check /api/health on your app.
' + value + " ";
+ }).join("");
+ const right = [0, 0.5, 1].map((f) => {
+ const value = Math.round(maxLat * f);
+ return '' + value + " ";
+ }).join("");
+
+ const region = anomalyIdx >= 0
+ ? '+' + delta + " MB / sample "
+ : "";
+
return '' +
- '' + samples.length + " samples
" +
- '' +
- '' + Math.round(scaleR / 1024 / 1024) + " MB peak " +
- '' + Math.round(scaleC) + "% cpu " +
+ "" +
+ '' +
+ 'threshold ' + threshold + " MB " +
+ 't' + activeN + " " +
+ leader +
+ ' ";
}
+function bindChart() {
+ const hit = $("chartHit");
+ const layer = $("chartHover");
+ if (!hit || !layer) return;
+ const W = 560, H = 250, padL = 44, padR = 46, padT = 30, padB = 30;
+ const samples = state.samples;
+ const mem = samples.map((s) => Math.round(((s.metrics || {}).rss || 0) / 1048576));
+ const lat = samples.map((s) => Math.round((s.metrics || {}).latencyMs || 0));
+ const maxMem = Math.max(400, Math.max.apply(null, mem)) * 1.02;
+ const maxLat = Math.max(300, Math.max.apply(null, lat)) * 1.08;
+ const x = (i) => padL + (i / Math.max(1, samples.length - 1)) * (W - padL - padR);
+ const yMem = (v) => H - padB - (v / maxMem) * (H - padT - padB);
+ const yLat = (v) => H - padB - (v / maxLat) * (H - padT - padB);
+
+ const indexAt = (event) => {
+ const rect = hit.ownerSVGElement.getBoundingClientRect();
+ const local = ((event.clientX - rect.left) / rect.width) * W;
+ const ratio = (local - padL) / (W - padL - padR);
+ return Math.max(0, Math.min(samples.length - 1, Math.round(ratio * (samples.length - 1))));
+ };
+
+ hit.addEventListener("pointermove", (event) => {
+ const i = indexAt(event);
+ const s = samples[i];
+ const tooltipW = 156;
+ const tx = Math.min(W - tooltipW - 6, Math.max(6, x(i) - tooltipW / 2));
+ const metrics = s.metrics || {};
+ layer.innerHTML =
+ '' +
+ 't' + (s.turnNumber || 0) + " · " + mem[i] + " MB " +
+ '' + lat[i] + " ms p95 · " + Math.round(metrics.cpu || 0) + "% cpu " +
+ '' + (metrics.errors || 0) + " errors ";
+ });
+ hit.addEventListener("pointerleave", () => { layer.innerHTML = ""; });
+ hit.addEventListener("click", (event) => {
+ const s = samples[indexAt(event)];
+ const idx = state.turns.findIndex((t) => t.n === (s.turnNumber || 0));
+ if (idx >= 0) selectTurn(idx);
+ });
+}
+
function renderAutopsy() {
const turn = state.turns[state.active] || null;
const anomaly = state.anomaly;
@@ -349,13 +446,36 @@ function renderAutopsy() {
(turn.sha ? 'checkpoint ' + esc(String(turn.sha).slice(0, 10)) + ' No patch for this turn — the recorder only stores diffs when git shadow checkpoints exist.
Runtime ' + state.samples.length + " samples
" + chartSvg(state.samples) + "
Runtime metrics ' + state.samples.length + " samples
" + chartSvg(state.samples) + "
Fix prompt ' +
+ (state.anomaly ? '' + ICON.copy + "Copy " : "") +
+ '
' + esc(fixPrompt) + "
Copied ";
+ setTimeout(() => {
+ if (!copyFix.isConnected) return;
+ copyFix.dataset.copied = "false";
+ copyFix.innerHTML = ICON.copy + "Copy ";
+ }, 1800);
+ } catch {
+ copyFix.dataset.copied = "false";
+ }
+ };
+ bindChart();
const viewPatch = $("viewPatch");
if (viewPatch) viewPatch.onclick = () => {
const d = document.querySelector(".pg-details");
@@ -630,7 +750,7 @@ function overviewDist() {
const ext = state.towers.length
? Math.max(...state.towers.map((t) => Math.max(Math.abs(t.x), Math.abs(t.z))))
: 12;
- return clamp(ext * 2.4 + 16, 36, 86);
+ return clamp(ext * 3.0 + 20, 44, 100);
}
function pick(e) {
diff --git a/packages/ghost/lib/city.css b/packages/ghost/lib/city.css
index eb4f725..a5515ae 100644
--- a/packages/ghost/lib/city.css
+++ b/packages/ghost/lib/city.css
@@ -1582,3 +1582,34 @@ canvas{display:block;max-width:100%}
}
@media (min-width:901px){.pg-stage__empty p{max-width:420px}}
+.copy-btn {
+ display: inline-flex;
+ align-items: center;
+ gap: 6px;
+ height: 26px;
+ padding: 0 8px;
+ border: 1px solid var(--line);
+ border-radius: 6px;
+ color: var(--fg-2);
+ font-family: var(--font-mono-stack);
+ font-size: 9px;
+ letter-spacing: 0.06em;
+ text-transform: uppercase;
+ transition: color .25s, border-color .25s, background-color .25s;
+}
+
+.copy-btn:hover {
+ color: var(--fg);
+ border-color: var(--line-strong);
+ background: rgba(255, 255, 255, .04);
+}
+
+.copy-btn[data-copied="true"] {
+ color: var(--emerald);
+ border-color: rgba(94, 234, 212, .28);
+}
+
+.copy-btn svg {
+ width: 12px;
+ height: 12px;
+}
diff --git a/packages/ghost/lib/probes.mjs b/packages/ghost/lib/probes.mjs
index ad707e4..5cbd342 100644
--- a/packages/ghost/lib/probes.mjs
+++ b/packages/ghost/lib/probes.mjs
@@ -11,8 +11,10 @@ export function createProbes({ url, intervalMs = 4000, fetchImpl = globalThis.fe
async function sample() {
const ts = new Date().toISOString();
try {
+ const started = Date.now();
const res = await fetchImpl(url, { headers: { accept: "application/json" }, signal: AbortSignal.timeout(5000) });
- if (!res.ok) return push(ts, { errors: 1, httpStatus: res.status }, true);
+ const latencyMs = Date.now() - started;
+ if (!res.ok) return push(ts, { errors: 1, httpStatus: res.status, latencyMs }, true);
const body = await res.json().catch(() => ({}));
const cpu = Number(body.cpuPercent ?? body.cpu ?? 0) || 0;
let cpuDelta = cpu;
@@ -22,7 +24,7 @@ export function createProbes({ url, intervalMs = 4000, fetchImpl = globalThis.fe
cpu: Number((cpuDelta * 100 + cpu).toFixed(2)),
rss: Number(body.rss ?? 0),
heap: Number(body.heap ?? 0),
- latencyMs: null,
+ latencyMs,
errors: 0,
uptime: Number(body.uptime ?? 0),
}, false);
diff --git a/packages/ghost/lib/shadowgit.mjs b/packages/ghost/lib/shadowgit.mjs
index 6fead45..ed8bd9f 100644
--- a/packages/ghost/lib/shadowgit.mjs
+++ b/packages/ghost/lib/shadowgit.mjs
@@ -17,26 +17,50 @@ const IGNORE_SET = new Set([
* diff is a unified diff patch versus HEAD ("" when the worktree matches HEAD).
*/
export function commitSnapshot(repo, message = "ghost checkpoint") {
- const idx = path.join(repo, ".ghost", "shadow-index");
+ // One index file per recorder process. Two recorders watching the same repo
+ // (a leftover demo run + a manual `ghost watch`, say) would otherwise fight
+ // over a single .ghost/shadow-index.lock, and every `git add` after the first
+ // would die with "File exists" — the city silently froze at a couple of towers.
+ const idx = path.join(repo, ".ghost", `shadow-index-${process.pid}`);
fs.mkdirSync(path.dirname(idx), { recursive: true });
+ // A killed recorder leaves its lock behind; this pid is ours now, so anything
+ // left under this exact name is dead weight.
+ for (const stale of [idx, `${idx}.lock`]) {
+ try { fs.unlinkSync(stale); } catch { /* nothing to clean */ }
+ }
const env = { ...process.env, GIT_INDEX_FILE: idx };
const git = (args, extraEnv = {}) =>
- execFileSync("git", args, { cwd: repo, env: { ...env, ...extraEnv }, encoding: "utf8", stdio: ["ignore", "pipe", "ignore"] }).trim();
+ execFileSync("git", args, {
+ cwd: repo,
+ env: { ...env, ...extraEnv },
+ encoding: "utf8",
+ stdio: ["ignore", "pipe", "pipe"],
+ maxBuffer: 1024 * 1024 * 64,
+ }).trim();
+ // execFileSync only exposes stderr when we ask for it; without this the CLI
+ // printed a bare "Command failed: git add -A -- ." and hid the real reason.
+ const run = (args, extraEnv) => {
+ try { return git(args, extraEnv); }
+ catch (e) {
+ const detail = String(e.stderr || "").trim().split(/\r?\n/).filter(Boolean).pop();
+ throw new Error(`git ${args[0]} failed: ${detail || e.message}`);
+ }
+ };
- try { git(["read-tree", "HEAD"]); } catch { /* empty repo without HEAD */ }
+ try { run(["read-tree", "HEAD"]); } catch { /* empty repo without HEAD */ }
// .ghost is the recorder's own bookkeeping (shadow index + patches). Staging
// it would grow every snapshot by megabytes and eventually blow maxBuffer —
// the city would silently stop growing. Add it to the repo-local exclude
// (never committed, never touches the user's .gitignore) so a plain add
// skips it everywhere, including repos that do not ignore .ghost.
ensureExcluded(repo);
- git(["add", "-A", "--", "."]);
- const tree = git(["write-tree"]);
+ run(["add", "-A", "--", "."]);
+ const tree = run(["write-tree"]);
let parent = null;
- try { parent = git(["rev-parse", "HEAD"]); } catch { /* first snapshot */ }
+ try { parent = run(["rev-parse", "HEAD"]); } catch { /* first snapshot */ }
const commitArgs = parent ? ["commit-tree", tree, "-p", parent, "-m", message] : ["commit-tree", tree, "-m", message];
- const sha = git(commitArgs, { GIT_AUTHOR_DATE: new Date().toISOString(), GIT_COMMITTER_DATE: new Date().toISOString() });
+ const sha = run(commitArgs, { GIT_AUTHOR_DATE: new Date().toISOString(), GIT_COMMITTER_DATE: new Date().toISOString() });
const diffOut = execFileSync(
"git", ["diff", "--binary", ...(parent ? [parent] : ["4b825dc642cb6eb9a060e54bf8d69288fbee4904"]), sha],
{ cwd: repo, encoding: "utf8", maxBuffer: 1024 * 1024 * 64 },