ldy26098
/
BMAD-METHOD
mirror of https://github.com/bmad-code-org/BMAD-METHOD.git
1
0
Fork 0
Code Packages Projects Releases Wiki Activity

bug: fixed atomicwrites

This commit is contained in:
pbean 2026-05-23 22:13:25 -07:00
parent a0fba4b824
commit 1fb1cf5ee6
1 changed files with 26 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
src/core-skills/bmad-module/scripts/lib/fs-safe.mjs
View File

@ -64,13 +64,33 @@ export async function copyDir(srcDir, destDir, shouldSkip = () => false) {
return copied;
}
// Atomically replace `targetDir` with `stagedDir` contents. If `targetDir`
// exists it's removed first; then `stagedDir` is renamed in. Best effort —
// not truly atomic across filesystems but minimizes the inconsistent window.
// Atomically replace `targetDir` with `stagedDir` contents. Best effort —
// not truly atomic, but minimizes the inconsistent window.
//
// `stagedDir` usually lives under the OS temp dir, which is frequently a
// separate filesystem (e.g. tmpfs on /tmp) from the target. rename() cannot
// move across filesystems and throws EXDEV there, so we first land the staged
// tree onto the target's own filesystem as a sibling — by rename when they
// already share a filesystem, by copy when they don't — and then rename that
// sibling into place, which is always an intra-filesystem atomic swap.
export async function atomicSwapDir(stagedDir, targetDir) {
await fsp.rm(targetDir, { recursive: true, force: true });
await fsp.mkdir(path.dirname(targetDir), { recursive: true });
await fsp.rename(stagedDir, targetDir);
const parent = path.dirname(targetDir);
await fsp.mkdir(parent, { recursive: true });
const sibling = path.join(parent, `.${path.basename(targetDir)}.bmad-tmp-${crypto.randomBytes(6).toString('hex')}`);
try {
try {
await fsp.rename(stagedDir, sibling);
} catch (e) {
if (e.code !== 'EXDEV') throw e;
await copyDir(stagedDir, sibling);
await fsp.rm(stagedDir, { recursive: true, force: true });
}
await fsp.rm(targetDir, { recursive: true, force: true });
await fsp.rename(sibling, targetDir);
} catch (e) {
await fsp.rm(sibling, { recursive: true, force: true });
throw e;
}
}
// Remove empty parent directories upward until a non-empty one is hit,