Function waitForDaemonStartupTarget

apps/cli/src/main.ts:483–513

(input: {
  readonly requestedBaseUrl: string;
})

  });

const waitForDaemonStartupTarget = (input: {
  readonly requestedBaseUrl: string;
}): Effect.Effect<string | null, never, FileSystem.FileSystem | PlatformPath.Path> =>
  Effect.gen(function* () {
    let readyBaseUrl: string | null = null;
    let requestedFallbackBaseUrl: string | null = null;
    const ready = yield* waitForReachable({
      check: Effect.gen(function* () {
        // Prefer the manifest: it is written after the server has opened the
        // owned DB and started serving, and it carries the bearer token the next
        // API call needs. A bare health response on the requested URL is only a
        // last-ditch fallback; keep polling for the manifest so tool calls do
        // not race ahead without auth.
        const manifest = yield* readReachableLocalServerHint();
        if (manifest) {
          readyBaseUrl = manifest.connection.origin;
          return true;
        }

        if (yield* isServerReachable(input.requestedBaseUrl)) {
          requestedFallbackBaseUrl = input.requestedBaseUrl;
        }

        return false;
      }),
      timeoutMs: DAEMON_BOOT_TIMEOUT_MS,
      intervalMs: DAEMON_BOOT_POLL_MS,
    });

    return ready ? readyBaseUrl : requestedFallbackBaseUrl;
  });

// Serialize daemon startup behind a filesystem lock so concurrent CLI invocations don't
// each spawn their own daemon. The post-lock pointer recheck catches the case where