cb57093d03
## Summary Wave 17 organizes Fusion into **domain folders** (stacks on #2397). ### Layout - **core/types/** — board, task, agents, settings, merge, workflow, mesh, … - **core/src/** — agents, ai, async-stores, workflows, tasks, config, db, … - **dashboard/app/api/** — client, tasks, agents, git, missions, planning, … - **engine/src/** — agents, auth, execution, merge, missions, overseer, worktree, … Root keepers retained for large entrypoints (`store.ts`, `executor.ts`, `merger.ts`, …). Public barrels (`@fusion/core`, `@fusion/engine`, `app/api.ts` → legacy) stay stable. ## Test plan - [x] `@fusion/core` typecheck - [x] `@fusion/engine` typecheck (pre-existing playwright-core noise only) - [ ] CI merge gate **Stack:** #2394 → #2397 → **this PR**
97 lines
2.7 KiB
TypeScript
97 lines
2.7 KiB
TypeScript
import { exec, execSync } from "node:child_process";
|
|
import { promisify } from "node:util";
|
|
|
|
import type { RunAuditor } from "../util/run-audit.js";
|
|
|
|
const execAsync = promisify(exec);
|
|
const PRUNE_TIMEOUT_MS = 30_000;
|
|
const PRUNE_MAX_BUFFER = 10 * 1024 * 1024;
|
|
|
|
type PruneAuditPayload = {
|
|
success: boolean;
|
|
reason: string;
|
|
target?: string;
|
|
error?: string;
|
|
};
|
|
|
|
export type PruneWorktreeAdminEntriesOptions = {
|
|
rootDir: string;
|
|
auditor?: Pick<RunAuditor, "git">;
|
|
reason: string;
|
|
target?: string;
|
|
logger?: { log: (m: string) => void };
|
|
};
|
|
|
|
async function emitAudit(
|
|
opts: PruneWorktreeAdminEntriesOptions,
|
|
metadata: PruneAuditPayload,
|
|
): Promise<void> {
|
|
await opts.auditor?.git({
|
|
type: "worktree:admin-entry-pruned",
|
|
target: opts.target ?? opts.rootDir,
|
|
metadata,
|
|
});
|
|
}
|
|
|
|
export async function pruneWorktreeAdminEntries(opts: PruneWorktreeAdminEntriesOptions): Promise<void> {
|
|
try {
|
|
await execAsync("git worktree prune", {
|
|
cwd: opts.rootDir,
|
|
timeout: PRUNE_TIMEOUT_MS,
|
|
maxBuffer: PRUNE_MAX_BUFFER,
|
|
encoding: "utf-8",
|
|
});
|
|
|
|
opts.logger?.log?.(
|
|
`[worktree-prune] git worktree prune succeeded (reason=${opts.reason}${opts.target ? ` target=${opts.target}` : ""})`,
|
|
);
|
|
await emitAudit(opts, {
|
|
success: true,
|
|
reason: opts.reason,
|
|
target: opts.target,
|
|
});
|
|
} catch (error) {
|
|
const errorMessage = error instanceof Error ? error.message : String(error);
|
|
opts.logger?.log?.(
|
|
`[worktree-prune] git worktree prune failed (reason=${opts.reason}${opts.target ? ` target=${opts.target}` : ""}): ${errorMessage}`,
|
|
);
|
|
await emitAudit(opts, {
|
|
success: false,
|
|
reason: opts.reason,
|
|
target: opts.target,
|
|
error: errorMessage,
|
|
});
|
|
}
|
|
}
|
|
|
|
export function pruneWorktreeAdminEntriesSync(opts: PruneWorktreeAdminEntriesOptions): void {
|
|
try {
|
|
execSync("git worktree prune", {
|
|
cwd: opts.rootDir,
|
|
timeout: PRUNE_TIMEOUT_MS,
|
|
maxBuffer: PRUNE_MAX_BUFFER,
|
|
encoding: "utf-8",
|
|
});
|
|
|
|
opts.logger?.log?.(
|
|
`[worktree-prune] git worktree prune (sync) succeeded (reason=${opts.reason}${opts.target ? ` target=${opts.target}` : ""})`,
|
|
);
|
|
void emitAudit(opts, {
|
|
success: true,
|
|
reason: opts.reason,
|
|
target: opts.target,
|
|
});
|
|
} catch (error) {
|
|
const errorMessage = error instanceof Error ? error.message : String(error);
|
|
opts.logger?.log?.(
|
|
`[worktree-prune] git worktree prune (sync) failed (reason=${opts.reason}${opts.target ? ` target=${opts.target}` : ""}): ${errorMessage}`,
|
|
);
|
|
void emitAudit(opts, {
|
|
success: false,
|
|
reason: opts.reason,
|
|
target: opts.target,
|
|
error: errorMessage,
|
|
});
|
|
}
|
|
}
|