use tracing::{error, info, warn, instrument, debug};
use anyhow::Result;
use apisix_admin_client::{ctrl_garbage_collect, ctrl_health_check, ctrl_schema};
use apisix_admin_client::config::ApisixConfigBuilder;

#[tokio::main]
#[instrument]
async fn main() -> Result<()> {
    tracing_subscriber::fmt()
        .with_env_filter(tracing_subscriber::EnvFilter::from_default_env())
        .init();

    ctrl_ucs().await?;

    Ok(())
}

#[instrument]
async fn ctrl_ucs() -> Result<()> {
    info!("===Example::Apisix Controller Client ===");

    // Get default Config (from environment variables)
    // let cfg = get_config_from_env().await;
    // or use builder pattern to construct the config
    let cfg = ApisixConfigBuilder::new().with_control_url("http://localhost:9090").build().expect("Error building config");
    debug!("Apisix Config: {:?}", cfg);

    // Check Apisix schema - not diplayed
    match ctrl_schema(&cfg).await {
        Ok(_) => info!("OK::Schema"),
        Err(e) => error!("Error checking schema: {:?}", e)
    }

    // Check if Control API is up and running
    match ctrl_health_check(&cfg).await {
        Ok(hc) => {
            debug!("Health Check: {:?}", hc);
            info!("OK::Control API is up and running")
        },
        Err(e) => error!("Error checking Control API: {:?}", e)
    }

    // Trigger garbage collection
    match ctrl_garbage_collect(&cfg).await {
        Ok(_) => info!("OK::Garbage collection triggered"),
        Err(e) => error!("Error triggering garbage collection: {:?}", e)
    }

    info!("===Example::Apisix Controller Client END===");
    Ok(())
}