test(tasks): guard task-registry import boundary (#57487)

* refactor(tasks): add executor facade

* refactor(tasks): extract delivery policy

* refactor(tasks): route acp through executor

* refactor(tasks): route subagents through executor

* refactor(cron): split main and detached dispatch

* refactor(tasks): guard executor-only producer writes

* refactor(tasks): clarify detached run surfaces

* test(tasks): guard task-registry import boundary
This commit is contained in:
Vincent Koc
2026-03-29 22:02:48 -07:00
committed by GitHub
parent 3a37421251
commit 4a1f231f1e

View File

@@ -0,0 +1,45 @@
import fs from "node:fs/promises";
import path from "node:path";
import { describe, expect, it } from "vitest";
const TASK_ROOT = path.resolve(import.meta.dirname);
const SRC_ROOT = path.resolve(TASK_ROOT, "..");
const ALLOWED_IMPORTERS = new Set([
"auto-reply/reply/commands-acp/runtime-options.ts",
"auto-reply/reply/commands-subagents/action-info.ts",
"commands/tasks.ts",
"tasks/task-executor.ts",
"tasks/task-registry.maintenance.ts",
]);
async function listSourceFiles(root: string): Promise<string[]> {
const entries = await fs.readdir(root, { withFileTypes: true });
const files: string[] = [];
for (const entry of entries) {
const fullPath = path.join(root, entry.name);
if (entry.isDirectory()) {
files.push(...(await listSourceFiles(fullPath)));
continue;
}
if (!entry.isFile() || !entry.name.endsWith(".ts") || entry.name.endsWith(".test.ts")) {
continue;
}
files.push(fullPath);
}
return files;
}
describe("task registry import boundary", () => {
it("keeps direct task-registry imports on the approved read-model seam", async () => {
const importers: string[] = [];
for (const file of await listSourceFiles(SRC_ROOT)) {
const relative = path.relative(SRC_ROOT, file).replaceAll(path.sep, "/");
const source = await fs.readFile(file, "utf8");
if (source.includes("task-registry.js")) {
importers.push(relative);
}
}
expect(importers.toSorted()).toEqual([...ALLOWED_IMPORTERS].toSorted());
});
});