87 lines
5.0 KiB
JavaScript
87 lines
5.0 KiB
JavaScript
import fs from "node:fs";
|
|
import path from "node:path";
|
|
import { spawnSync } from "node:child_process";
|
|
import { fileURLToPath } from "node:url";
|
|
|
|
const root = path.resolve(path.dirname(fileURLToPath(import.meta.url)), "../..");
|
|
const abs = (file) => path.join(root, file);
|
|
const read = (file) => fs.readFileSync(abs(file), "utf8");
|
|
const maxArg = process.argv.indexOf("--max-iterations");
|
|
const maxIterations = maxArg >= 0 ? Number(process.argv[maxArg + 1]) : 0;
|
|
if (!Number.isSafeInteger(maxIterations) || maxIterations < 0) throw new Error("--max-iterations must be a non-negative integer; 0 means unlimited");
|
|
const commitEnabled = process.argv.includes("--commit");
|
|
const pushEnabled = process.argv.includes("--push");
|
|
const shellQuote = (value) => `'${value.replaceAll("'", "'\\''")}'`;
|
|
|
|
function command(command, logPath) {
|
|
const result = spawnSync("bash", ["-lc", command], { cwd: root, encoding: "utf8", maxBuffer: 16 * 1024 * 1024 });
|
|
const output = `${result.stdout ?? ""}${result.stderr ?? ""}`;
|
|
if (logPath) fs.writeFileSync(abs(logPath), output);
|
|
return { code: result.status ?? 1, output };
|
|
}
|
|
|
|
function currentTask() {
|
|
const queue = read("docs/EXECUTION_QUEUE.md");
|
|
const task = queue.match(/\| 当前任务 \| `(WBV2-P\d+-\d+)` \|/u)?.[1];
|
|
const parentManifest = queue.match(/\| parent manifest \| `([^`]+)` \|/u)?.[1];
|
|
if (!task || !parentManifest) throw new Error("queue pointer is incomplete");
|
|
return { task, parentManifest };
|
|
}
|
|
|
|
function taskCommand(task) {
|
|
const card = read(`docs/tasks/${task}.md`);
|
|
const match = card.match(/- Implementation entrypoint: `([^`]+)`/u);
|
|
if (!match) throw new Error(`task card has no implementation entrypoint: ${task}`);
|
|
return match[1];
|
|
}
|
|
|
|
function assertContext() {
|
|
const result = command("node tools/web/print-task-context.mjs && node tools/web/check-task-context.mjs", "tests/golden/WBV2/continuous-context.log");
|
|
if (result.code !== 0) throw new Error(`context gate failed (exit ${result.code})`);
|
|
}
|
|
|
|
let iterations = 0;
|
|
const summary = [];
|
|
while (maxIterations === 0 || iterations < maxIterations) {
|
|
const before = currentTask();
|
|
assertContext();
|
|
const focused = taskCommand(before.task);
|
|
const logPath = `tests/golden/${before.task}/continuous-runner.log`;
|
|
const focusedResult = command(focused, logPath);
|
|
if (focusedResult.code !== 0) throw new Error(`${before.task} focused command failed (exit ${focusedResult.code}); log=${logPath}`);
|
|
const after = currentTask();
|
|
if (after.task === before.task) throw new Error(`${before.task} focused command exited 0 without advancing queue; log=${logPath}`);
|
|
const gates = command("node tools/web/check-context-governance.mjs && node tools/web/check-execution-control-plane.mjs --allow-unrunnable && node tools/web/check-v2-task-index.mjs && node tools/web/check-v2-handoff.mjs && npm --prefix web run typecheck && npm --prefix web run lint && git diff --check", `tests/golden/${before.task}/continuous-gates.log`);
|
|
if (gates.code !== 0) throw new Error(`${before.task} post-handoff gate failed (exit ${gates.code}); log=tests/golden/${before.task}/continuous-gates.log`);
|
|
iterations += 1;
|
|
summary.push({ task: before.task, command: focused, nextTask: after.task, log: logPath });
|
|
process.stdout.write(`continuous-iteration=${iterations} task=${before.task} next=${after.task}\n`);
|
|
if (commitEnabled) {
|
|
const manifestPath = `tests/golden/${before.task}/manifest.json`;
|
|
const artifactPaths = fs.existsSync(abs(manifestPath))
|
|
? Object.values(JSON.parse(read(manifestPath).toString()).artifacts ?? {}).map((artifact) => artifact?.path).filter((file) => typeof file === "string")
|
|
: [];
|
|
const handoffPaths = [
|
|
"docs/EXECUTION_QUEUE.md",
|
|
"nextTask.md",
|
|
`docs/tasks/${before.task}.md`,
|
|
`docs/tasks/${after.task}.md`,
|
|
`docs/status/${before.task}.md`,
|
|
`docs/status/${after.task}.md`,
|
|
manifestPath,
|
|
...artifactPaths,
|
|
"tests/golden/WBV2/task-index.json",
|
|
"tests/golden/WBV2/task-catalog.jsonl",
|
|
].filter((file, index, all) => file && all.indexOf(file) === index && fs.existsSync(abs(file)));
|
|
const commit = command(`git add ${handoffPaths.map(shellQuote).join(" ")}`, `tests/golden/${before.task}/continuous-commit.log`);
|
|
if (commit.code !== 0) throw new Error(`${before.task} staging failed; log=tests/golden/${before.task}/continuous-commit.log`);
|
|
const commitResult = command(`git diff --cached --quiet || git commit -m "chore(web): continuous handoff ${before.task}"`, `tests/golden/${before.task}/continuous-commit-result.log`);
|
|
if (commitResult.code !== 0) throw new Error(`${before.task} commit failed; log=tests/golden/${before.task}/continuous-commit-result.log`);
|
|
if (pushEnabled) {
|
|
const push = command("git push origin main", `tests/golden/${before.task}/continuous-push.log`);
|
|
if (push.code !== 0) throw new Error(`${before.task} push failed; log=tests/golden/${before.task}/continuous-push.log`);
|
|
}
|
|
}
|
|
}
|
|
process.stdout.write(`continuous-run-complete iterations=${iterations} current=${currentTask().task} committed=${commitEnabled} pushed=${pushEnabled}\n`);
|