Function spawnAndWaitForDaemon

apps/cli/src/main.ts:601–646

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

  });

const spawnAndWaitForDaemon = (input: {
  host: string;
  scopeId: string;
  preferredPort: number;
  allowedHosts: ReadonlyArray<string>;
}): Effect.Effect<string, Error, FileSystem.FileSystem | PlatformPath.Path> =>
  Effect.gen(function* () {
    const requestedBaseUrl = daemonBaseUrl(input.host, input.preferredPort);

    for (let attempt = 1; attempt <= MAX_DAEMON_ELECTION_ATTEMPTS; attempt++) {
      const acquired = yield* acquireDaemonStartLock({
        hostname: input.host,
        scopeId: input.scopeId,
      }).pipe(
        Effect.map((lock) => ({ held: true as const, lock })),
        Effect.catch((error) =>
          isStartLockContention(error)
            ? Effect.succeed({ held: false as const, lock: null })
            : Effect.fail(error),
        ),
      );

      if (acquired.held) {
        const lock = acquired.lock;
        return yield* spawnDaemonAsLockHolder(input).pipe(
          Effect.ensuring(releaseDaemonStartLock(lock).pipe(Effect.ignore)),
        );
      }

      // Lost the lock: wait for the current holder to advertise a manifest.
      const ready = yield* waitForDaemonStartupTarget({ requestedBaseUrl });
      if (ready) return ready;
      // Timed out with no manifest. The holder may have died mid-startup; loop to
      // re-acquire, which reclaims its now-stale lock.
    }

    return yield* Effect.fail(
      new Error(
        [
          `Could not elect or attach to a local Executor daemon after ${MAX_DAEMON_ELECTION_ATTEMPTS} attempts.`,
          "A daemon startup may be stuck. Stop any partial daemon and retry, or run it in the foreground:",
          `${cliPrefix} daemon run --foreground --port ${input.preferredPort} --hostname ${input.host}`,
        ].join("\n"),
      ),
    );
  });

// Auto-start a local daemon on demand so commands like `executor call` work without the
// user having to run `daemon run` first. Refuses non-local hosts because spawning a