Function spawnDaemonAsLockHolder

apps/cli/src/main.ts:539–604

(input: {
  host: string;
  scopeId: string;
  preferredPort: number;
  allowedHosts: ReadonlyArray<string>;
})

  error.message.includes("Another daemon startup is already in progress");

const spawnDaemonAsLockHolder = (input: {
  host: string;
  scopeId: string;
  preferredPort: number;
  allowedHosts: ReadonlyArray<string>;
}): Effect.Effect<string, Error, FileSystem.FileSystem | PlatformPath.Path> =>
  Effect.gen(function* () {
    const existing = yield* readDaemonPointer({ hostname: input.host, scopeId: input.scopeId });
    if (existing && isPidAlive(existing.pid)) {
      const existingUrl = daemonBaseUrl(existing.hostname, existing.port);
      if (yield* isServerReachable(existingUrl)) {
        return existingUrl;
      }
    }

    const selectedPort = yield* chooseDaemonPort({
      preferredPort: input.preferredPort,
      hostname: input.host,
    });

    if (selectedPort !== input.preferredPort) {
      console.error(
        `Port ${input.preferredPort} is in use. Starting daemon on available port ${selectedPort} instead.`,
      );
    }

    const spec = yield* Effect.try({
      try: () =>
        buildDaemonSpawnSpec({
          port: selectedPort,
          hostname: input.host,
          isDevMode,
          scriptPath: script,
          executablePath: process.execPath,
          allowedHosts: input.allowedHosts,
        }),
      catch: (cause) =>
        cause instanceof Error
          ? cause
          : new Error(`Failed to build daemon command: ${String(cause)}`),
    });

    const startBaseUrl = daemonBaseUrl(input.host, selectedPort);
    console.error(`Starting daemon on ${input.host}:${selectedPort}...`);
    const child = yield* spawnDetached({
      command: spec.command,
      args: spec.args,
      env: process.env,
    });

    const readyBaseUrl = yield* waitForDaemonStartupTarget({ requestedBaseUrl: startBaseUrl });

    if (!readyBaseUrl) {
      yield* terminateSpawnedDetachedProcess(child).pipe(Effect.ignore);
      return yield* Effect.fail(
        new Error(
          [
            `Daemon did not become reachable at ${startBaseUrl} and no reachable local server manifest appeared within ${DAEMON_BOOT_TIMEOUT_MS}ms.`,