Function tryRecoverExpiredLockDir

src/utils/fs-lock.ts:100–126

(
  lockDir: string,
  purpose: string,
  now: number,
  leaseMs: number,
)

}

async function tryRecoverExpiredLockDir(
  lockDir: string,
  purpose: string,
  now: number,
  leaseMs: number,
): Promise<boolean> {
  const recovery = await shouldRecoverLockDir(lockDir, purpose, now, leaseMs);
  if (!recovery.recover) {
    return false;
  }

  const quarantineDir = await quarantineLockDir(lockDir);
  if (!quarantineDir) {
    return false;
  }

  if (recovery.owner) {
    const quarantinedOwner = await readLockOwner(quarantineDir);
    if (!fsLockOwnersEqual(quarantinedOwner, recovery.owner)) {
      await restoreQuarantinedLockDir(quarantineDir, lockDir);
      return false;
    }
  }

  await removeLockDir(quarantineDir);
  return true;
}

async function createLock(lockDir: string, owner: FsLockOwner): Promise<AcquiredFsLock> {
  await fs.mkdir(lockDir, { mode: 0o700 });