Function prompt_async

crates/opencode-server/src/routes.rs:1991–2021

(
    State(state): State<Arc<ServerState>>,
    Path(id): Path<String>,
    Json(req): Json<PromptAsyncRequest>,
)

}

async fn prompt_async(
    State(state): State<Arc<ServerState>>,
    Path(id): Path<String>,
    Json(req): Json<PromptAsyncRequest>,
) -> Result<Json<serde_json::Value>> {
    let mut sessions = state.sessions.lock().await;
    let session = sessions
        .get_mut(&id)
        .ok_or_else(|| ApiError::SessionNotFound(id.clone()))?;
    let message_text: String = req
        .message
        .clone()
        .or_else(|| {
            req.parts.as_ref().map(|p| {
                let s = text_from_parts(p);
                if s.is_empty() { None } else { Some(s) }
            }).flatten()
        })
        .unwrap_or_default();
    session.add_user_message(&message_text);
    let assistant = session.add_assistant_message();
    let assistant_id = assistant.id.clone();
    drop(sessions);
    persist_sessions_if_enabled(&state).await;

    Ok(Json(serde_json::json!({
        "status": "queued",
        "message_id": assistant_id,
        "model": req.model,
    })))
}

#[derive(Debug, Deserialize)]
pub struct InitSessionRequest {