Function tryAcquireFsLock

src/utils/fs-lock.ts:185–233

(
  options: TryAcquireFsLockOptions,
)

}

export async function tryAcquireFsLock(
  options: TryAcquireFsLockOptions,
): Promise<AcquiredFsLock | null> {
  const now = options.now ?? Date.now();
  const owner: FsLockOwner = {
    token: randomUUID(),
    pid: options.pid ?? process.pid,
    purpose: options.purpose,
    acquiredAtMs: now,
    expiresAtMs: now + options.leaseMs,
  };

  try {
    await fs.mkdir(path.dirname(options.lockDir), { recursive: true, mode: 0o700 });
    const guard = await tryAcquireGuard(options.lockDir, options.purpose, options.leaseMs, now);
    if (!guard) {
      return null;
    }

    try {
      for (let attempt = 0; attempt < 2; attempt += 1) {
        try {
          return await createLock(options.lockDir, owner);
        } catch (error) {
          const code = (error as NodeJS.ErrnoException).code;
          if (code !== 'EEXIST') {
            return null;
          }

          const recovered = await tryRecoverExpiredLockDir(
            options.lockDir,
            options.purpose,
            now,
            options.leaseMs,
          );
          if (!recovered) {
            return null;
          }
        }
      }
    } finally {
      await guard.release();
    }
  } catch {
    return null;
  }

  return null;
}