systemprompt-cli 0.1.22

use anyhow::{Context, Result};
use std::sync::Arc;
use systemprompt_runtime::AppContext;

use super::restart;
use super::start;
use super::stop;
use super::{RestartTarget, ServicesCommands, StartTarget, StopTarget};
use crate::cli_settings::CliConfig;
use crate::shared::render_result;

pub async fn execute(command: ServicesCommands, config: &CliConfig) -> Result<()> {
    match command {
        ServicesCommands::Start {
            target,
            all,
            api,
            agents,
            mcp,
            foreground: _,
            skip_migrate,
            kill_port_process,
        } => execute_start(target, all, api, agents, mcp, skip_migrate, kill_port_process, config).await,

        ServicesCommands::Stop {
            target,
            all,
            api,
            agents,
            mcp,
            force,
        } => execute_stop(target, all, api, agents, mcp, force, config).await,

        ServicesCommands::Restart {
            target,
            failed,
            agents,
            mcp,
        } => execute_restart(target, failed, agents, mcp, config).await,

        ServicesCommands::Status {
            detailed,
            json,
            health,
        } => {
            let result = super::status::execute(detailed, json, health, config).await?;
            render_result(&result);
            Ok(())
        },

        ServicesCommands::Cleanup { yes, dry_run } => {
            let result = super::cleanup::execute(yes, dry_run, config).await?;
            render_result(&result);
            Ok(())
        },

        ServicesCommands::Serve {
            foreground,
            kill_port_process,
        } => super::serve::execute(foreground, kill_port_process, config).await,
    }
}

async fn execute_start(
    target: Option<StartTarget>,
    all: bool,
    api: bool,
    agents: bool,
    mcp: bool,
    skip_migrate: bool,
    kill_port_process: bool,
    config: &CliConfig,
) -> Result<()> {
    if let Some(individual) = target {
        let ctx = Arc::new(
            AppContext::new()
                .await
                .context("Failed to initialize application context")?,
        );
        return match individual {
            StartTarget::Agent { agent_id } => {
                start::execute_individual_agent(&ctx, &agent_id, config).await
            },
            StartTarget::Mcp { server_name } => {
                start::execute_individual_mcp(&ctx, &server_name, config).await
            },
        };
    }

    let flags = start::ServiceFlags {
        all,
        targets: start::ServiceTargetFlags { api, agents, mcp },
    };
    let service_target = start::ServiceTarget::from_flags(flags);
    let options = start::StartupOptions {
        skip_migrate,
        kill_port_process,
    };
    start::execute(service_target, options, config).await
}

async fn execute_stop(
    target: Option<StopTarget>,
    all: bool,
    api: bool,
    agents: bool,
    mcp: bool,
    force: bool,
    config: &CliConfig,
) -> Result<()> {
    if let Some(individual) = target {
        let ctx = Arc::new(
            AppContext::new()
                .await
                .context("Failed to initialize application context")?,
        );
        return match individual {
            StopTarget::Agent { agent_id, force } => {
                let result =
                    stop::execute_individual_agent(&ctx, &agent_id, force, config).await?;
                render_result(&result);
                Ok(())
            },
            StopTarget::Mcp { server_name, force } => {
                let result =
                    stop::execute_individual_mcp(&ctx, &server_name, force, config).await?;
                render_result(&result);
                Ok(())
            },
        };
    }

    let flags = start::ServiceFlags {
        all,
        targets: start::ServiceTargetFlags { api, agents, mcp },
    };
    let service_target = start::ServiceTarget::from_flags(flags);
    let result = stop::execute(service_target, force, config).await?;
    render_result(&result);
    Ok(())
}

async fn execute_restart(
    target: Option<RestartTarget>,
    failed: bool,
    agents: bool,
    mcp: bool,
    config: &CliConfig,
) -> Result<()> {
    let ctx = Arc::new(
        AppContext::new()
            .await
            .context("Failed to initialize application context")?,
    );

    let result = if failed {
        restart::execute_failed(&ctx, config).await?
    } else if agents {
        restart::execute_all_agents(&ctx, config).await?
    } else if mcp {
        restart::execute_all_mcp(&ctx, config).await?
    } else {
        match target {
            Some(RestartTarget::Api) => restart::execute_api(config).await?,
            Some(RestartTarget::Agent { agent_id }) => {
                restart::execute_agent(&ctx, &agent_id, config).await?
            },
            Some(RestartTarget::Mcp { server_name, build }) => {
                restart::execute_mcp(&ctx, &server_name, build, config).await?
            },
            None => {
                return Err(anyhow::anyhow!(
                    "Must specify target (api, agent, mcp) or use --failed/--agents/--mcp flag"
                ));
            },
        }
    };
    render_result(&result);
    Ok(())
}

pub fn load_service_configs(
    _ctx: &AppContext,
) -> Result<Vec<systemprompt_scheduler::ServiceConfig>> {
    use systemprompt_loader::ConfigLoader;
    use systemprompt_scheduler::{ServiceConfig, ServiceType};

    let services_config = ConfigLoader::load()?;
    let mut configs = Vec::new();

    for (name, agent) in &services_config.agents {
        configs.push(ServiceConfig {
            name: name.clone(),
            service_type: ServiceType::Agent,
            port: agent.port,
            enabled: agent.enabled,
        });
    }

    for (name, mcp) in &services_config.mcp_servers {
        configs.push(ServiceConfig {
            name: name.clone(),
            service_type: ServiceType::Mcp,
            port: mcp.port,
            enabled: mcp.enabled,
        });
    }

    Ok(configs)
}