Function run_external_client

src/apps/cli/src/acp_cli.rs:340–418

(
    client: ExternalAcpClient,
    prompt: String,
    workspace: Option<String>,
    timeout: u64,
    permission: CliAcpPermissionMode,
)

}

pub async fn run_external_client(
    client: ExternalAcpClient,
    prompt: String,
    workspace: Option<String>,
    timeout: u64,
    permission: CliAcpPermissionMode,
) -> Result<()> {
    if matches!(permission, CliAcpPermissionMode::Ask) {
        bail!(
            "`--permission ask` is not available for non-interactive `acp run`; use allow-once or reject-once."
        );
    }

    let prompt = prompt.trim().to_string();
    if prompt.is_empty() {
        bail!("Prompt cannot be empty");
    }

    let service = create_client_service().await?;
    let client_id = client.id();
    let base_config_json = update_client_config_json(
        load_client_config_json(&service).await?,
        client_id,
        Some(client.config()),
        true,
        None,
    )?;
    save_client_config_json(&service, &base_config_json).await?;

    let run_config_json = update_client_config_json(
        base_config_json.clone(),
        client_id,
        None,
        true,
        Some(permission.to_config_mode()),
    )?;
    if run_config_json != base_config_json {
        save_client_config_json(&service, &run_config_json).await?;
    }

    let workspace_path = match workspace {
        Some(path) => path,
        None => std::env::current_dir()
            .context("Failed to resolve current directory")?
            .to_string_lossy()
            .to_string(),
    };
    let session_id = format!("cli_acp_{}_{}", client_id, uuid::Uuid::new_v4());

    eprintln!(
        "Starting external ACP agent '{}' in {}",
        client_id, workspace_path
    );
    let result = service
        .prompt_agent(
            client_id,
            prompt,
            Some(workspace_path),