Function handle_exec_command

src/apps/cli/src/root_handlers.rs:26–73

(config: CliConfig, args: ExecCommandArgs)

}

pub async fn handle_exec_command(config: CliConfig, args: ExecCommandArgs) -> Result<()> {
    let workspace_path_resolved = std::env::current_dir().ok();

    if let Some(ref ws_path) = workspace_path_resolved {
        tracing::info!("Workspace path set: {:?}", ws_path);
    }

    let message = resolve_exec_message(args.message)?;
    let resume = match (args.resume, args.session) {
        (Some(_), Some(_)) => {
            anyhow::bail!("Use only one of --resume or --session");
        }
        (Some(value), None) | (None, Some(value)) => Some(value),
        (None, None) => None,
    };
    if args.session_id.is_some() && (args.continue_last || resume.is_some()) {
        anyhow::bail!("--session-id cannot be combined with --continue, --resume, or --session");
    }
    if args.fork_session && args.session_id.is_some() {
        anyhow::bail!("--fork-session cannot be combined with --session-id");
    }

    let skip_confirmation = !args.confirm;
    let (agentic_system, original_skip_confirmation) =
        crate::initialize_core_services(skip_confirmation).await?;

    let mut exec_mode = ExecMode::new(
        config,
        message,
        args.agent,
        &agentic_system,
        workspace_path_resolved,
        args.output_patch,
        args.output_format,
        ExecSessionOptions {
            resume,
            continue_last: args.continue_last,
            session_id: args.session_id,
            fork_session: args.fork_session,
        },
    );
    let run_result = exec_mode.run().await;

    crate::shutdown_mcp_servers().await;
    crate::restore_tool_confirmation(original_skip_confirmation).await;

    run_result
}

fn resolve_exec_message(message: Option<String>) -> Result<String> {
    let mut combined = message.unwrap_or_default();