Function withQueueMutationLock

apps/kimi-code/src/tui/goal-queue-store.ts:176–195

(
  session: GoalQueueSession,
  work: () => Promise<T>,
)

}

async function withQueueMutationLock<T>(
  session: GoalQueueSession,
  work: () => Promise<T>,
): Promise<T> {
  const filePath = goalQueuePath(session);
  const previous = queueMutationLocks.get(filePath) ?? Promise.resolve();
  const run = previous.catch(() => undefined).then(work);
  const lock = run.then(
    () => undefined,
    () => undefined,
  );
  queueMutationLocks.set(filePath, lock);
  try {
    return await run;
  } finally {
    if (queueMutationLocks.get(filePath) === lock) {
      queueMutationLocks.delete(filePath);
    }
  }
}

function emptyQueueFile(): GoalQueueFile {
  return { version: GOAL_QUEUE_VERSION, goals: [] };