Function session_prompt

crates/opencode-server/src/routes.rs:1632–1803

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

}

async fn session_prompt(
    State(state): State<Arc<ServerState>>,
    Path(id): Path<String>,
    Json(req): Json<SessionPromptRequest>,
) -> Result<Json<serde_json::Value>> {
    let prompt_text = if let Some(message) = req.message.as_deref() {
        message.to_string()
    } else if let Some(command) = req.command.as_deref() {
        req.arguments
            .as_deref()
            .map(|args| format!("/{command} {args}"))
            .unwrap_or_else(|| format!("/{command}"))
    } else {
        return Err(ApiError::BadRequest(
            "Either `message` or `command` must be provided".to_string(),
        ));
    };

    {
        let sessions = state.sessions.lock().await;
        if sessions.get(&id).is_none() {
            return Err(ApiError::SessionNotFound(id));
        }
    }

    let config = CONFIG_STATE.read().await;
    let (provider, provider_id, model_id) =
        resolve_provider_and_model(&state, req.model.as_deref(), config.model.as_deref(), None)?;
    drop(config);

    let task_state = state.clone();
    let session_id = id.clone();
    let task_variant = req.variant.clone();
    let task_agent = req.agent.clone();
    let task_model = model_id.clone();
    let task_provider = provider_id.clone();
    tokio::spawn(async move {
        let mut session = {
            let sessions = task_state.sessions.lock().await;
            let Some(session) = sessions.get(&session_id).cloned() else {
                return;
            };
            session
        };
        set_session_run_status(&task_state, &session_id, SessionRunStatus::Busy).await;

        if let Some(variant) = task_variant.as_deref() {
            session
                .metadata
                .insert("model_variant".to_string(), serde_json::json!(variant));
        } else {
            session.metadata.remove("model_variant");
        }
        session.metadata.insert(
            "model_provider".to_string(),
            serde_json::json!(&task_provider),
        );
        session