aleph-cli 0.14.0

use crate::cli::{
    CcnAddArgs, CcnCommand, CcnListArgs, CcnRemoveArgs, CcnShowArgs, CcnUseArgs, ConfigCommand,
    NetworkAddArgs, NetworkCommand, NetworkEthereumArgs, NetworkRemoveArgs, NetworkSetArgs,
    NetworkShowArgs, NetworkUseArgs,
};
use crate::common::confirm_action;
use crate::config::store::{ConfigStore, EthereumPatch, NetworkEntry};
use aleph_sdk::credit::EthereumConfig;
use anyhow::{Context, Result};

impl NetworkEthereumArgs {
    /// Lower to an `EthereumPatch` that the store can apply.
    fn to_patch(&self) -> EthereumPatch {
        EthereumPatch {
            rpc_url: self.rpc_url.clone(),
            credit_contract: self.credit_contract,
            aleph_token: self.aleph_token,
            usdc_token: self.usdc_token,
            price_source: self.price_source.clone(),
            explorer_tx_base: self.explorer_tx_base.clone(),
        }
    }
}

pub async fn handle_config_command(
    command: ConfigCommand,
    json: bool,
    cli_network: Option<&str>,
) -> Result<()> {
    match command {
        ConfigCommand::Ccn { command } => handle_ccn_command(command, json, cli_network).await,
        ConfigCommand::Network { command } => {
            handle_network_command(command, json, cli_network).await
        }
    }
}

async fn handle_network_command(
    command: NetworkCommand,
    json: bool,
    cli_network: Option<&str>,
) -> Result<()> {
    let store = ConfigStore::open().context("failed to open config store")?;
    match command {
        NetworkCommand::Add(args) => handle_network_add(&store, args, json),
        NetworkCommand::List => handle_network_list(&store, json),
        NetworkCommand::Use(args) => handle_network_use(&store, args, json),
        NetworkCommand::Show(args) => handle_network_show(&store, args, json, cli_network),
        NetworkCommand::Remove(args) => handle_network_remove(&store, args, json),
        NetworkCommand::Set(args) => handle_network_set(&store, args, json, cli_network),
    }
}

fn handle_network_add(store: &ConfigStore, args: NetworkAddArgs, json: bool) -> Result<()> {
    store.add_network(&args.name)?;
    let patch = args.ethereum.to_patch();
    if !patch.is_empty() {
        // The patch fills on top of mainnet defaults, giving the new network
        // a complete ethereum block even if the user only overrode one field.
        store.update_network_ethereum(&args.name, &patch)?;
    }
    if let Some(url) = args.scheduler_url.as_deref() {
        store.set_network_scheduler_url(&args.name, url)?;
    }
    let entry = store.get_network(&args.name)?;
    if json {
        println!(
            "{}",
            serde_json::to_string_pretty(&serde_json::json!({
                "name": args.name,
                "ethereum": entry.ethereum,
                "scheduler_url": entry.scheduler_url,
            }))?
        );
    } else {
        eprintln!("Network '{}' added.", args.name);
        if let Some(eth) = &entry.ethereum {
            render_ethereum_block_human(eth);
        }
        render_scheduler_url_human(&entry.scheduler_url);
    }
    Ok(())
}

fn handle_network_set(
    store: &ConfigStore,
    args: NetworkSetArgs,
    json: bool,
    cli_network: Option<&str>,
) -> Result<()> {
    let name = resolve_target_network(store, args.network.as_deref(), cli_network)?;
    let patch = args.ethereum.to_patch();
    if patch.is_empty() && args.scheduler_url.is_none() {
        return Err(anyhow::anyhow!(
            "nothing to update — pass at least one of --scheduler-url, --rpc-url, --credit-contract, --aleph-token, --usdc-token, --price-source, --explorer-tx-base"
        ));
    }
    if !patch.is_empty() {
        store.update_network_ethereum(&name, &patch)?;
    }
    if let Some(url) = args.scheduler_url.as_deref() {
        store.set_network_scheduler_url(&name, url)?;
    }
    let entry = store.get_network(&name)?;
    if json {
        println!(
            "{}",
            serde_json::to_string_pretty(&serde_json::json!({
                "network": name,
                "ethereum": entry.ethereum,
                "scheduler_url": entry.scheduler_url,
            }))?
        );
    } else {
        eprintln!("Network '{name}' updated.");
        if let Some(eth) = &entry.ethereum {
            render_ethereum_block_human(eth);
        }
        render_scheduler_url_human(&entry.scheduler_url);
    }
    Ok(())
}

/// Resolve which network a `network set` call targets:
/// explicit `--network` > top-level `--network` > current default.
fn resolve_target_network(
    store: &ConfigStore,
    override_name: Option<&str>,
    cli_network: Option<&str>,
) -> Result<String> {
    let name = match override_name.or(cli_network) {
        Some(n) => n.to_string(),
        None => store.default_network_name()?.ok_or_else(|| {
            anyhow::anyhow!("no default network set; use: aleph config network use <NAME>")
        })?,
    };
    // Validate existence early so errors are consistent with other commands.
    store.get_network(&name)?;
    Ok(name)
}

fn render_scheduler_url_human(url: &str) {
    eprintln!("Scheduler:   {url}");
}

fn render_ethereum_block_human(eth: &EthereumConfig) {
    eprintln!("Ethereum:");
    eprintln!("  RPC URL:        {}", eth.rpc_url);
    eprintln!("  Credit:         {}", eth.credit_contract);
    eprintln!("  ALEPH token:    {}", eth.aleph_token);
    eprintln!("  USDC token:     {}", eth.usdc_token);
    eprintln!(
        "  Price source:   {}",
        format_price_source(&eth.price_source)
    );
    if let Some(base) = &eth.explorer_tx_base {
        eprintln!("  Explorer base:  {base}");
    }
}

fn format_price_source(p: &aleph_sdk::credit::PriceSource) -> String {
    use aleph_sdk::credit::PriceSource::*;
    match p {
        CoinGecko => "coingecko".to_string(),
        Fixed { usd } => format!("fixed:{usd}"),
        None => "none".to_string(),
    }
}

fn handle_network_list(store: &ConfigStore, json: bool) -> Result<()> {
    let networks = store.list_networks()?;
    let default = store.default_network_name()?;
    if json {
        let rows: Vec<_> = networks
            .iter()
            .map(|n| {
                serde_json::json!({
                    "name": n.name,
                    "default": default.as_deref() == Some(&n.name),
                    "ccn_count": n.ccns.len(),
                    "default_ccn": n.default_ccn,
                })
            })
            .collect();
        println!("{}", serde_json::to_string_pretty(&rows)?);
        return Ok(());
    }
    eprintln!("{:<2} {:<16} {:<6} DEFAULT CCN", "", "NAME", "CCNS");
    for n in &networks {
        let marker = if default.as_deref() == Some(&n.name) {
            "*"
        } else {
            " "
        };
        let default_ccn = n.default_ccn.as_deref().unwrap_or("-");
        eprintln!(
            "{:<2} {:<16} {:<6} {}",
            marker,
            n.name,
            n.ccns.len(),
            default_ccn
        );
    }
    Ok(())
}

fn handle_network_use(store: &ConfigStore, args: NetworkUseArgs, json: bool) -> Result<()> {
    store.set_default_network(&args.name)?;
    if json {
        println!(
            "{}",
            serde_json::to_string_pretty(&serde_json::json!({ "default_network": args.name }))?
        );
    } else {
        eprintln!("Default network set to '{}'.", args.name);
    }
    Ok(())
}

fn handle_network_show(
    store: &ConfigStore,
    args: NetworkShowArgs,
    json: bool,
    cli_network: Option<&str>,
) -> Result<()> {
    let default_network = store.default_network_name()?;
    let name = match args.name {
        Some(n) => n,
        None => cli_network
            .map(str::to_string)
            .or_else(|| default_network.clone())
            .ok_or_else(|| {
                anyhow::anyhow!("no default network set; use: aleph config network use <NAME>")
            })?,
    };
    let net = store.get_network(&name)?;
    let is_default = default_network.as_deref() == Some(name.as_str());
    if json {
        let output = serde_json::json!({
            "name": net.name,
            "default": is_default,
            "default_ccn": net.default_ccn,
            "ccns": net.ccns,
            "ethereum": net.ethereum,
            "scheduler_url": net.scheduler_url,
        });
        println!("{}", serde_json::to_string_pretty(&output)?);
    } else {
        eprintln!("Name:        {}", net.name);
        eprintln!("Default:     {}", if is_default { "yes" } else { "no" });
        eprintln!("Default CCN: {}", net.default_ccn.as_deref().unwrap_or("-"));
        eprintln!("CCNs:");
        if net.ccns.is_empty() {
            eprintln!("  (none)");
        } else {
            for c in &net.ccns {
                let marker = if net.default_ccn.as_deref() == Some(&c.name) {
                    "*"
                } else {
                    " "
                };
                eprintln!("  {} {:<16} {}", marker, c.name, c.url);
            }
        }
        render_scheduler_url_human(&net.scheduler_url);
        if let Some(eth) = &net.ethereum {
            render_ethereum_block_human(eth);
        }
    }
    Ok(())
}

fn handle_network_remove(store: &ConfigStore, args: NetworkRemoveArgs, json: bool) -> Result<()> {
    let prompt = format!(
        "Remove network '{}' and all of its CCN entries? This cannot be undone.",
        args.name
    );
    if !confirm_action(&prompt, args.yes).context("failed to read confirmation")? {
        eprintln!("Aborted.");
        return Ok(());
    }
    store.remove_network(&args.name)?;
    if json {
        println!(
            "{}",
            serde_json::to_string_pretty(&serde_json::json!({ "removed": args.name }))?
        );
    } else {
        eprintln!("Network '{}' removed.", args.name);
    }
    Ok(())
}

/// Resolve which network a `ccn` subcommand operates on and return its entry.
///
/// If `override_name` is `Some`, that network is loaded (errors with
/// `NetworkNotFound` if unknown). Otherwise the current `default_network`
/// is used — errors if no default is set.
fn resolve_ccn_scope(store: &ConfigStore, override_name: Option<&str>) -> Result<NetworkEntry> {
    let name = match override_name {
        Some(n) => n.to_string(),
        None => store.default_network_name()?.ok_or_else(|| {
            anyhow::anyhow!("no default network set; use: aleph config network use <NAME>")
        })?,
    };
    Ok(store.get_network(&name)?)
}

async fn handle_ccn_command(
    command: CcnCommand,
    json: bool,
    cli_network: Option<&str>,
) -> Result<()> {
    let store = ConfigStore::open().context("failed to open config store")?;
    match command {
        CcnCommand::Add(args) => handle_add(&store, args, json, cli_network),
        CcnCommand::Use(args) => handle_use(&store, args, json, cli_network),
        CcnCommand::List(args) => handle_list(&store, args, json, cli_network),
        CcnCommand::Show(args) => handle_show(&store, args, json, cli_network).await,
        CcnCommand::Remove(args) => handle_remove(&store, args, json, cli_network),
    }
}

fn handle_add(
    store: &ConfigStore,
    args: CcnAddArgs,
    json: bool,
    cli_network: Option<&str>,
) -> Result<()> {
    let network = resolve_ccn_scope(store, args.network.as_deref().or(cli_network))?.name;
    store.add_ccn(&network, &args.name, &args.url)?;
    if json {
        println!(
            "{}",
            serde_json::to_string_pretty(&serde_json::json!({
                "network": network,
                "name": args.name,
                "url": args.url,
            }))?
        );
    } else {
        eprintln!("CCN '{}' added to network '{}'.", args.name, network);
        eprintln!("  URL: {}", args.url);
    }
    Ok(())
}

fn handle_use(
    store: &ConfigStore,
    args: CcnUseArgs,
    json: bool,
    cli_network: Option<&str>,
) -> Result<()> {
    let network = resolve_ccn_scope(store, args.network.as_deref().or(cli_network))?.name;
    store.set_default_ccn(&network, &args.name)?;
    if json {
        println!(
            "{}",
            serde_json::to_string_pretty(&serde_json::json!({
                "network": network,
                "default_ccn": args.name,
            }))?
        );
    } else {
        eprintln!(
            "Default CCN for network '{}' set to '{}'.",
            network, args.name
        );
    }
    Ok(())
}

fn handle_list(
    store: &ConfigStore,
    args: CcnListArgs,
    json: bool,
    cli_network: Option<&str>,
) -> Result<()> {
    if args.all {
        let rows = store.list_all_ccns()?;
        if json {
            let items: Vec<_> = rows
                .iter()
                .map(|(net, c)| {
                    serde_json::json!({
                        "network": net,
                        "name": c.name,
                        "url": c.url,
                    })
                })
                .collect();
            println!("{}", serde_json::to_string_pretty(&items)?);
            return Ok(());
        }
        eprintln!("{:<16} {:<16} URL", "NETWORK", "NAME");
        for (net, c) in &rows {
            eprintln!("{:<16} {:<16} {}", net, c.name, c.url);
        }
        return Ok(());
    }

    let net = resolve_ccn_scope(store, args.network.as_deref().or(cli_network))?;

    if json {
        println!("{}", serde_json::to_string_pretty(&net.ccns)?);
        return Ok(());
    }

    eprintln!("Network: {}", net.name);
    eprintln!("{:<2} {:<16} URL", "", "NAME");
    for c in &net.ccns {
        let marker = if net.default_ccn.as_deref() == Some(&c.name) {
            "*"
        } else {
            " "
        };
        eprintln!("{:<2} {:<16} {}", marker, c.name, c.url);
    }
    Ok(())
}

async fn handle_show(
    store: &ConfigStore,
    args: CcnShowArgs,
    json: bool,
    cli_network: Option<&str>,
) -> Result<()> {
    let net = resolve_ccn_scope(store, args.network.as_deref().or(cli_network))?;
    let name = match args.name {
        Some(n) => n,
        None => net.default_ccn.clone().ok_or_else(|| {
            anyhow::anyhow!(
                "network '{network}' has no default CCN; use: aleph config ccn use <NAME> [--network {network}]",
                network = net.name,
            )
        })?,
    };
    let entry = net
        .ccns
        .iter()
        .find(|c| c.name == name)
        .cloned()
        .ok_or_else(|| crate::config::store::ConfigError::CcnNotFound {
            network: net.name.clone(),
            ccn: name.clone(),
        })?;
    let is_default = net.default_ccn.as_deref() == Some(name.as_str());
    let version = fetch_ccn_version(&entry.url).await;

    if json {
        let mut output = serde_json::json!({
            "network": net.name,
            "name": entry.name,
            "url": entry.url,
            "default": is_default,
        });
        if let Some(v) = &version {
            output["version"] = serde_json::json!(v);
        }
        println!("{}", serde_json::to_string_pretty(&output)?);
    } else {
        eprintln!("Network: {}", net.name);
        eprintln!("Name:    {}", entry.name);
        eprintln!("URL:     {}", entry.url);
        match &version {
            Some(v) => eprintln!("Version: {v}"),
            None => eprintln!("Version: (unreachable)"),
        }
        if is_default {
            eprintln!("Default: yes");
        }
    }
    Ok(())
}

fn handle_remove(
    store: &ConfigStore,
    args: CcnRemoveArgs,
    json: bool,
    cli_network: Option<&str>,
) -> Result<()> {
    let network = resolve_ccn_scope(store, args.network.as_deref().or(cli_network))?.name;
    let prompt = format!("Remove CCN '{}' from network '{network}'?", args.name);
    if !confirm_action(&prompt, args.yes).context("failed to read confirmation")? {
        eprintln!("Aborted.");
        return Ok(());
    }
    store.remove_ccn(&network, &args.name)?;
    if json {
        println!(
            "{}",
            serde_json::to_string_pretty(&serde_json::json!({
                "network": network,
                "removed": args.name,
            }))?
        );
    } else {
        eprintln!("CCN '{}' removed from network '{}'.", args.name, network);
    }
    Ok(())
}

/// Fetch the CCN version from GET /api/v0/version.
/// Returns None on any error (timeout, network, parse).
async fn fetch_ccn_version(url: &str) -> Option<String> {
    let version_url = format!("{}/api/v0/version", url.trim_end_matches('/'));
    let resp = reqwest::Client::new()
        .get(&version_url)
        .timeout(std::time::Duration::from_secs(5))
        .send()
        .await
        .ok()?;
    let body: serde_json::Value = resp.json().await.ok()?;
    body["version"].as_str().map(|s| s.to_string())
}