Function wait_for_healthy

e2e/rust/src/harness/cli.rs:27–52

(timeout: Duration)

}

pub async fn wait_for_healthy(timeout: Duration) -> Result<(), String> {
    let start = Instant::now();
    let mut last_output: String;

    loop {
        let (output, code) = run_cli(&["status"]).await;
        let clean = strip_ansi(&output);
        let lower = clean.to_lowercase();
        if code == 0
            && (lower.contains("healthy")
                || lower.contains("running")
                || lower.contains("connected"))
        {
            return Ok(());
        }
        last_output = clean;

        if start.elapsed() > timeout {
            return Err(format!(
                "gateway did not become healthy within {}s. Last output:\n{last_output}",
                timeout.as_secs()
            ));
        }
        sleep(Duration::from_secs(2)).await;
    }
}

pub async fn sandbox_names() -> Result<Vec<String>, String> {
    let (output, code) = run_cli(&["sandbox", "list", "--names"]).await;