Function acquireDaemonStartLock

apps/cli/src/daemon-state.ts:312–370

(input: {
  hostname: string;
  scopeId: string;
})

};

export const acquireDaemonStartLock = (input: {
  hostname: string;
  scopeId: string;
}): Effect.Effect<DaemonStartLock, Error, FileSystem.FileSystem | Path.Path> =>
  Effect.gen(function* () {
    const fs = yield* FileSystem.FileSystem;
    const path = yield* Path.Path;
    const dataDir = resolveDaemonDataDir(path);
    yield* fs.makeDirectory(dataDir, { recursive: true });

    const lockPath = daemonStartLockPath(path, input);
    const lockPayload = JSON.stringify(
      {
        pid: process.pid,
        hostname: canonicalDaemonHost(input.hostname),
        scopeId: input.scopeId,
        startedAt: new Date().toISOString(),
      },
      null,
      2,
    );

    const tryAcquire = () =>
      fs.writeFileString(lockPath, `${lockPayload}\n`, { flag: "wx" }).pipe(
        Effect.as(true),
        Effect.catchCause(() => Effect.succeed(false)),
      );

    if (yield* tryAcquire()) {
      return {
        path: lockPath,
        hostname: canonicalDaemonHost(input.hostname),
        scopeId: input.scopeId,
      };
    }

    const existingRaw = yield* fs
      .readFileString(lockPath)
      .pipe(Effect.catchCause(() => Effect.succeed(null)));
    if (existingRaw !== null) {
      const existingPid = parseLockPid(existingRaw);
      if (existingPid !== null && !isPidAlive(existingPid)) {
        yield* fs.remove(lockPath, { force: true });
        if (yield* tryAcquire()) {
          return {
            path: lockPath,
            hostname: canonicalDaemonHost(input.hostname),
            scopeId: input.scopeId,
          };
        }
      }
    }

    return yield* Effect.fail(
      new Error(
        `Another daemon startup is already in progress for ${canonicalDaemonHost(input.hostname)} (${input.scopeId}).`,
      ),
    );