Function acquireLeaseMutationLock

src/node/services/workflows/WorkflowRunStore.ts:1231–1259

(
  lockDir: string,
  nowMs: number,
  staleLeaseMs: number
)

}

async function acquireLeaseMutationLock(
  lockDir: string,
  nowMs: number,
  staleLeaseMs: number
): Promise<boolean> {
  try {
    await fs.mkdir(lockDir);
    return true;
  } catch (error) {
    if (!isErrno(error, "EEXIST")) {
      throw error;
    }
  }

  try {
    const stat = await fs.stat(lockDir);
    if (nowMs - stat.mtimeMs <= staleLeaseMs) {
      return false;
    }
    await fs.rm(lockDir, { recursive: true, force: true });
    await fs.mkdir(lockDir);
    return true;
  } catch (error) {
    if (isErrno(error, "EEXIST") || isErrno(error, "ENOENT")) {
      return false;
    }
    throw error;
  }
}

function isErrno(error: unknown, code: string): boolean {
  return error instanceof Error && "code" in error && error.code === code;