nntrivi2001
198fbb7980
- GET /api/workflows: one LEAD() window pass in a read worker (read-pool.js, workflow-stats.js); idx_events_session restored, idx_events_tool added - compat-sqlite gains function/pluck/readonly so a plugin install without a better-sqlite3 build boots again; antigravity-usage uses db.js's Database - install-hooks adds no checkout hooks while the agenthub plugin is enabled (events were doubled) - terminal attach runs the live tmux server's own binary; the pane scrollbar gets a visible 2-column style, and claude panes start with CLAUDE_CODE_DISABLE_ALTERNATE_SCREEN=1 so tmux keeps history to scroll - Codex sessions' conversation in GET /api/sessions/:id/transcript - Codex/Antigravity sessions claimed by their workspace without hooks - UI-audit follow-ups, docs and OpenAPI
87 lines
3.7 KiB
JavaScript
87 lines
3.7 KiB
JavaScript
/**
|
|
* @file Tests for the persisted run history (`server/lib/dashboard-runs.js`).
|
|
* A run's id is its tmux pane name, which every Start in that pane reuses, so
|
|
* a new run must ARCHIVE the previous row under its own id instead of
|
|
* overwriting it; and a row is flagged dead only when its tmux session is
|
|
* really gone — panes outlive a server restart.
|
|
* @author Nguyễn Ngọc Trí Vĩ <vinnt@smartgift.vn>
|
|
*/
|
|
|
|
const { describe, it, before, after } = require("node:test");
|
|
const assert = require("node:assert/strict");
|
|
const fs = require("node:fs");
|
|
const os = require("node:os");
|
|
const path = require("node:path");
|
|
|
|
const ROOT = fs.mkdtempSync(path.join(os.tmpdir(), "dashboard-runs-"));
|
|
process.env.DASHBOARD_DB_PATH = path.join(ROOT, "t.db");
|
|
|
|
let runs;
|
|
before(() => {
|
|
runs = require("../lib/dashboard-runs");
|
|
});
|
|
after(() => fs.rmSync(ROOT, { recursive: true, force: true }));
|
|
|
|
const start = (id, extra = {}) =>
|
|
runs.recordRun({ id, mode: "interactive", cwd: "/r", status: "running", laneId: 4, ...extra });
|
|
|
|
describe("dashboard-runs", () => {
|
|
it("keeps the previous run of a pane as history when the pane starts again", () => {
|
|
start("agenthub-lane-4", { startedAt: Date.parse("2026-10-01T10:00:00Z"), sessionId: "s-old" });
|
|
start("agenthub-lane-4", { startedAt: Date.parse("2026-10-02T10:00:00Z"), sessionId: "s-new" });
|
|
const current = runs.getRun("agenthub-lane-4");
|
|
assert.equal(current.session_id, "s-new");
|
|
const history = runs.listRuns({ laneId: 4 });
|
|
assert.equal(history.length, 2);
|
|
const old = history.find((r) => r.session_id === "s-old");
|
|
assert.notEqual(old.id, "agenthub-lane-4");
|
|
assert.ok(old.id.startsWith("agenthub-lane-4@"), old.id);
|
|
// A pane that is being replaced is not running any more.
|
|
assert.equal(old.status, "abandoned");
|
|
assert.ok(old.ended_at);
|
|
});
|
|
|
|
it("flags as abandoned only the running rows whose pane is gone", () => {
|
|
start("agenthub-lane-5", { laneId: 5 });
|
|
start("agenthub-lane-6", { laneId: 6 });
|
|
const n = runs.reconcileOrphans((id) => id !== "agenthub-lane-6");
|
|
assert.equal(n, 1);
|
|
assert.equal(runs.getRun("agenthub-lane-5").status, "running");
|
|
assert.equal(runs.getRun("agenthub-lane-6").status, "abandoned");
|
|
});
|
|
|
|
it("gives a hookless tool's session the lane of the run it started in", () => {
|
|
const { db } = require("../db");
|
|
start("agenthub-lane-7-1", {
|
|
laneId: 7,
|
|
cwd: "/w",
|
|
tool: "antigravity",
|
|
startedAt: Date.parse("2026-10-05T08:49:57.145Z"),
|
|
});
|
|
runs.patchRun({
|
|
id: "agenthub-lane-7-1",
|
|
status: "killed",
|
|
endedAt: Date.parse("2026-10-05T08:50:10.740Z"),
|
|
});
|
|
const add = db.prepare(
|
|
"INSERT INTO sessions (id, name, status, cwd, started_at, tool) VALUES (?, 'x', 'completed', ?, ?, ?)"
|
|
);
|
|
add.run("in", "/w", "2026-10-05T08:50:01Z", "antigravity");
|
|
add.run("before", "/w", "2026-10-05T08:40:00Z", "antigravity");
|
|
add.run("after", "/w", "2026-10-05T09:00:00Z", "antigravity");
|
|
add.run("elsewhere", "/x", "2026-10-05T08:50:01Z", "antigravity");
|
|
add.run("other-tool", "/w", "2026-10-05T08:50:01Z", "codex");
|
|
add.run("claude", "/w", "2026-10-05T08:50:01Z", "claude");
|
|
runs.claimToolSessions();
|
|
const lane = (id) => db.prepare("SELECT lane_id FROM sessions WHERE id = ?").get(id).lane_id;
|
|
assert.equal(lane("in"), 7);
|
|
for (const id of ["before", "after", "elsewhere", "other-tool", "claude"]) {
|
|
assert.equal(lane(id), null, id);
|
|
}
|
|
// One session at a time also becomes its run's session.
|
|
assert.equal(runs.getRun("agenthub-lane-7-1").session_id, null);
|
|
runs.claimToolSessions("in");
|
|
assert.equal(runs.getRun("agenthub-lane-7-1").session_id, "in");
|
|
});
|
|
});
|