Function withBoardMutex

design/src/daemon.ts:122–136

(id: string, fn: () => Promise<T>)

}

async function withBoardMutex<T>(id: string, fn: () => Promise<T>): Promise<T> {
  const prev = boardMutex.get(id) || Promise.resolve();
  let release!: () => void;
  const next = new Promise<void>((r) => {
    release = r;
  });
  boardMutex.set(id, prev.then(() => next));
  await prev;
  try {
    return await fn();
  } finally {
    release();
    if (boardMutex.get(id) === next) boardMutex.delete(id);
  }
}

function markMeaningfulActivity(): void {
  lastMeaningfulActivity = Date.now();