Function run_non_interactive_attach

crates/opencode-cli/src/main.rs:1284–1331

(
    base_url: String,
    input: String,
    command: Option<String>,
    continue_last: bool,
    session: Option<String>,
    fork: bool,
    share: bool,
    model: Option<String>,
    variant: O

}

async fn run_non_interactive_attach(
    base_url: String,
    input: String,
    command: Option<String>,
    continue_last: bool,
    session: Option<String>,
    fork: bool,
    share: bool,
    model: Option<String>,
    variant: Option<String>,
    format: RunOutputFormat,
    title: Option<String>,
) -> anyhow::Result<()> {
    let client = reqwest::Client::new();
    let session_id =
        resolve_remote_session(&client, &base_url, continue_last, session, fork, title).await?;
    maybe_share_remote_session(&client, &base_url, &session_id, share).await?;

    let content = if let Some(command_name) = command {
        if input.trim().is_empty() {
            format!("/{}", command_name)
        } else {
            format!("/{} {}", command_name, input)
        }
    } else {
        input
    };

    let endpoint = server_url(&base_url, &format!("/session/{}/stream", session_id));
    let response = client
        .post(endpoint)
        .json(&serde_json::json!({
            "content": content,
            "model": model,
            "variant": variant,
            "stream": true
        }))
        .send()
        .await?;

    if !response.status().is_success() {
        let status = response.status();
        let body = response.text().await.unwrap_or_default();
        anyhow::bail!("Remote run failed ({}): {}", status, body);
    }

    consume_remote_sse(response, &session_id, format).await
}

async fn run_non_interactive(
    message: Vec<String>,