Function run_init_agents_md

src/apps/desktop/src/api/agentic_api.rs:1193–1252

(
    coordinator: State<'_, Arc<ConversationCoordinator>>,
    scheduler: State<'_, Arc<DialogScheduler>>,
    app_state: State<'_, AppState>,
    request: RunInitAgentsMdRequest,
)

#[tauri::command]
pub async fn run_init_agents_md(
    coordinator: State<'_, Arc<ConversationCoordinator>>,
    scheduler: State<'_, Arc<DialogScheduler>>,
    app_state: State<'_, AppState>,
    request: RunInitAgentsMdRequest,
) -> Result<StartDialogTurnResponse, String> {
    let session_id = request.session_id.trim();
    if session_id.is_empty() {
        return Err("session_id is required".to_string());
    }

    if coordinator
        .get_session_manager()
        .get_session(session_id)
        .is_none()
    {
        let workspace_path = request
            .workspace_path
            .as_deref()
            .map(str::trim)
            .filter(|value| !value.is_empty())
            .ok_or_else(|| {
                "workspace_path is required when the session is not loaded".to_string()
            })?;
        let effective = desktop_effective_session_storage_path(
            &app_state,
            workspace_path,
            request.remote_connection_id.as_deref(),
            request.remote_ssh_host.as_deref(),
        )
        .await;
        coordinator
            .restore_session_from_storage_path(&effective, session_id)
            .await
            .map_err(|e| format!("Failed to restore session before running /init: {e}"))?;
    }

    let workspace_path = request
        .workspace_path
        .as_deref()
        .map(str::trim)
        .filter(|value| !value.is_empty())
        .map(str::to_string);

    scheduler
        .submit_init_agents_md(
            session_id.to_string(),
            workspace_path,
            request.remote_connection_id.clone(),
            request.remote_ssh_host.clone(),
            DialogSubmissionPolicy::for_source(DialogTriggerSource::DesktopUi),
        )
        .await
        .map_err(|e| format!("Failed to run /init: {e}"))?;

    Ok(StartDialogTurnResponse {
        success: true,
        message: "Init dialog turn started".to_string(),