refactor(cli): replace race-condition sleeps with readiness probes

src/lib/core/wait.ts

@@ -21,3 +21,53 @@ export function sleepMs(ms: number): void {
 export function sleepSeconds(seconds: number): void {
   sleepMs(seconds * 1000);
 }
+
+/**
+ * Synchronously wait until a condition is met.
+ */
+export function waitUntil(
+  conditionFn: () => boolean,
+  timeoutSeconds = 10,
+  pollIntervalMs = 250,
+): boolean {
+  const start = Date.now();
+  while (Date.now() - start < timeoutSeconds * 1000) {
+    if (conditionFn()) return true;
+    sleepMs(pollIntervalMs);
+  }
+  return false;
+}
+
+/**
+ * Synchronously wait for a TCP port to become reachable on localhost.
+ */
+export function waitForPort(port: number, timeoutSeconds = 5): boolean {
+  const { spawnSync } = require("node:child_process");
+  return waitUntil(() => {
+    try {
+      const result = spawnSync("nc", ["-z", "127.0.0.1", String(port)], { stdio: "ignore" });
+      return result.status === 0;
+    } catch {
+      return false;
+    }
+  }, timeoutSeconds, 200);
+}
+
+/**
+ * Synchronously wait for an HTTP endpoint to return a success status code.
+ */
+export function waitForHttp(url: string, timeoutSeconds = 5): boolean {
+  const { spawnSync } = require("node:child_process");
+  return waitUntil(() => {
+    try {
+      const result = spawnSync(
+        "curl",
+        ["-sf", "--connect-timeout", "1", "--max-time", "1", url],
+        { stdio: "ignore" },
+      );
+      return result.status === 0;
+    } catch {
+      return false;
+    }
+  }, timeoutSeconds, 200);
+}

src/lib/inference/ollama/proxy.ts

@@ -12,6 +12,7 @@ const { spawn, spawnSync } = require("child_process");
 const http = require("http");
 const { ROOT, SCRIPTS, run, runCapture, shellQuote } = require("../../runner");
 const { OLLAMA_PORT, OLLAMA_PROXY_PORT } = require("../../core/ports");
+const { waitForPort } = require("../../core/wait");
 const {
   getDefaultOllamaModel,
   getBootstrapOllamaModelOptions,
@@ -157,7 +158,12 @@ function startOllamaAuthProxy(): boolean {
   // If the user backs out to a different provider, the token stays in memory
   // only and is discarded.
   const pid = spawnOllamaAuthProxy(proxyToken);
-  sleep(1);
+  if (!waitForPort(OLLAMA_PROXY_PORT, 2)) {
+    console.error(
+      `  Error: Ollama auth proxy did not become ready on :${OLLAMA_PROXY_PORT} within timeout.`,
+    );
+    return false;
+  }
   if (!isOllamaProxyProcess(pid)) {
     console.error(`  Error: Ollama auth proxy failed to start on :${OLLAMA_PROXY_PORT}`);
     console.error(`  Containers will not be able to reach Ollama without the proxy.`);