shumengya/sproutclaw
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(coding-agent): preserve file mutation queue ordering

Browse Source
This commit is contained in:
Mario Zechner
2026-03-21 23:57:24 +01:00
parent dcc569c09b
commit d38ad0cd6b
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
packages/coding-agent/src/core/tools/file-mutation-queue.ts
View File

@@ -1,12 +1,12 @@
import { realpath } from "node:fs/promises"; import { realpathSync } from "node:fs";
import { resolve } from "node:path"; import { resolve } from "node:path";
const fileMutationQueues = new Map<string, Promise<void>>(); const fileMutationQueues = new Map<string, Promise<void>>();
async function getMutationQueueKey(filePath: string): Promise<string> { function getMutationQueueKey(filePath: string): string {
const resolvedPath = resolve(filePath); const resolvedPath = resolve(filePath);
try { try {
return await realpath(resolvedPath); return realpathSync.native(resolvedPath);
} catch { } catch {
return resolvedPath; return resolvedPath;
} }
@@ -17,7 +17,7 @@ async function getMutationQueueKey(filePath: string): Promise<string> {
* Operations for different files still run in parallel. * Operations for different files still run in parallel.
*/ */
export async function withFileMutationQueue<T>(filePath: string, fn: () => Promise<T>): Promise<T> { export async function withFileMutationQueue<T>(filePath: string, fn: () => Promise<T>): Promise<T> {
const key = await getMutationQueueKey(filePath); const key = getMutationQueueKey(filePath);
const currentQueue = fileMutationQueues.get(key) ?? Promise.resolve(); const currentQueue = fileMutationQueues.get(key) ?? Promise.resolve();
let releaseNext!: () => void; let releaseNext!: () => void;