ext/hyperframes
2
0
Fork 0
mirror of https://github.com/heygen-com/hyperframes.git synced 2026-09-03 04:38:33 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(producer): reset distributed plan scratch state

Browse Source
This commit is contained in:
James
2026-07-26 18:12:15 +00:00
parent d699cbf014
commit ebb02cafe7
2 changed files with 31 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/producer/src/services/distributed/plan.ts
+6 -1
View File
@@ -839,7 +839,12 @@ export async function plan(
}
const workDir = join(planDir, ".plan-work");
if (!existsSync(workDir)) mkdirSync(workDir, { recursive: true });
// `.plan-work` is planner-owned scratch space. A prior attempt can fail
// before the end-of-plan cleanup and leave compiled assets behind; cpSync
// and compileStage both overlay their outputs, so reusing that directory
// would let stale bytes contaminate the new plan and its size check.
rmSync(workDir, { recursive: true, force: true });
mkdirSync(workDir, { recursive: true });
const compiledDir = join(workDir, "compiled");
// Pre-seed the compiled directory with `projectDir`'s local assets
packages/producer/src/services/distributed/planSizeCap.test.ts
+25
View File
@@ -320,6 +320,31 @@ describe("plan() early size budget", () => {
});
describe("plan() reused directory size check", () => {
it("clears stale compiled scratch from a failed prior attempt", async () => {
const projectDir = mkdtempSync(join(runRoot, "project-reused-work-dir-"));
writeFileSync(join(projectDir, "index.html"), FIXTURE_HTML, "utf-8");
const planDir = mkdtempSync(join(runRoot, "plandir-reused-work-dir-"));
const staleCompiledDir = join(planDir, ".plan-work", "compiled");
mkdirSync(staleCompiledDir, { recursive: true });
writeFileSync(join(staleCompiledDir, "stale-large-asset.bin"), Buffer.alloc(100_000));
const result = await plan(
projectDir,
{
fps: 30,
width: 320,
height: 240,
format: "mp4",
planDirSizeLimitBytes: 4_096,
},
planDir,
);
expect(result.planHash).toMatch(/^[0-9a-f]{64}$/);
expect(existsSync(join(planDir, "compiled", "stale-large-asset.bin"))).toBe(false);
expect(measurePlanDirBytes(planDir)).toBeLessThan(4_096);
}, 30_000);
it("ignores stale freeze-owned metadata that the new plan overwrites", async () => {
const projectDir = mkdtempSync(join(runRoot, "project-reused-plan-dir-"));
writeFileSync(join(projectDir, "index.html"), FIXTURE_HTML, "utf-8");