ninja-core 1.14.1

use anyhow::Result;
use log::{self, error, info};
use serde::{Deserialize, Serialize};
use std::{collections::HashMap, path::Path};
use tokio::fs;
use url::Url;

use crate::common::registry::{ArmoryItem, fetch_registry, is_absolute_url};

#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct ShurikenReference {
    pub registry: String,
    pub shuriken: String,
}

impl ShurikenReference {
    /// Parse a "registry:shuriken" format string
    pub fn parse(input: &str) -> Result<Self, anyhow::Error> {
        let parts: Vec<&str> = input.splitn(2, ':').collect();
        if parts.len() != 2 {
            return Err(anyhow::anyhow!(
                "Invalid shuriken reference format. Expected 'registry:shuriken', got '{}'",
                input
            ));
        }

        Ok(ShurikenReference {
            registry: parts[0].to_string(),
            shuriken: parts[1].to_string(),
        })
    }
}

#[derive(Clone, Debug, Serialize, Deserialize)]
pub struct NinjaConfig {
    pub registries: HashMap<String, String>,
    pub check_updates: bool,
    pub dev_mode: bool,
}

impl NinjaConfig {
    pub fn new() -> Self {
        Self {
            registries: HashMap::from([(
                "ninja".to_string(),
                "https://raw.githubusercontent.com/tunafysh/ninja-packages/main/registry.yml"
                    .to_string(),
            )]),
            check_updates: true,
            dev_mode: false,
        }
    }

    pub async fn generate_default_config(&self, root_dir: &Path) -> Result<()> {
        let config_path = root_dir.join("config.toml");
        let serialized = toml::ser::to_string_pretty(&self)?;

        fs::write(config_path, serialized).await?;

        Ok(())
    }

    pub fn add_registry(&mut self, name: String, url: String) {
        self.registries.insert(name, url);
    }

    pub fn set_check_updates(&mut self, check: bool) {
        self.check_updates = check;
    }

    pub fn set_dev_mode(&mut self, dev_mode: bool) {
        self.dev_mode = dev_mode;
    }

    pub fn remove_registry(&mut self, registry: &str) {
        self.registries.remove(registry);
    }
}

impl Default for NinjaConfig {
    fn default() -> Self {
        Self::new()
    }
}

pub async fn fetch_registries(
    config: &NinjaConfig,
) -> HashMap<String, crate::common::registry::Registry> {
    let mut registries = HashMap::new();

    for (name, url) in &config.registries {
        info!("Fetching registry '{}' from {}", name, url);
        match crate::common::registry::fetch_registry(url).await {
            Ok(reg) => {
                info!(
                    "Successfully fetched registry '{}' with {} items",
                    name,
                    reg.shurikens.len()
                );
                registries.insert(name.clone(), reg);
            }
            Err(e) => error!("Failed to fetch registry '{}': {}", name, e),
        }
    }

    registries
}

pub fn resolve_shuriken_url(
    registry_url: &str,
    shuriken_url: &str,
) -> Result<String, anyhow::Error> {
    if is_absolute_url(shuriken_url) {
        return Ok(shuriken_url.to_string());
    }

    let base = Url::parse(registry_url)?;
    let resolved = base.join(shuriken_url)?;

    // Inject OS and ARCH in placeholders if present
    let os = std::env::consts::OS;
    let arch = std::env::consts::ARCH;
    let resolved_str = resolved
        .as_str()
        .replace("{{os}}", os)
        .replace("{{arch}}", arch);

    Ok(resolved_str)
}

/// Find a shuriken in the fetched registries by its reference (e.g., "official:my-shuriken")
pub async fn find_shuriken_in_registries(
    registries: &HashMap<String, String>,
    reference: &ShurikenReference,
) -> Result<(ArmoryItem, String), anyhow::Error> {
    let registry_url = registries.get(&reference.registry).ok_or_else(|| {
        anyhow::anyhow!(
            "Registry {} does not exist in the config.",
            &reference.registry
        )
    })?;

    let registry = fetch_registry(registry_url).await?;

    let shuriken = registry
        .shurikens
        .iter()
        .find(|s| match s {
            ArmoryItem::Shuriken { name, .. } => name == &reference.shuriken,
            ArmoryItem::Bundle { name, .. } => name == &reference.shuriken,
        })
        .ok_or_else(|| {
            anyhow::anyhow!(
                "Shuriken '{}' not found in registry '{}'",
                reference.shuriken,
                reference.registry
            )
        })?;

    Ok((shuriken.clone(), reference.registry.clone()))
}

/// Get information about a shuriken from registries as JSON
pub async fn get_shuriken_info(
    registries: &HashMap<String, String>,
    reference: &ShurikenReference,
) -> Result<serde_json::Value, anyhow::Error> {
    let (shuriken, registry_name) = find_shuriken_in_registries(registries, reference).await?;

    let info = match shuriken {
        ArmoryItem::Shuriken {
            name,
            version,
            description,
            author,
            license,
            platforms,
            url,
        } => {
            serde_json::json!({
                "type": "shuriken",
                "name": name,
                "version": version,
                "registry": registry_name,
                "author": author,
                "license": license,
                "description": description,
                "platforms": platforms,
                "url": url
            })
        }
        ArmoryItem::Bundle {
            name,
            version,
            description,
            author,
            license,
            shurikens,
        } => {
            serde_json::json!({
                "type": "bundle",
                "name": name,
                "version": version,
                "registry": registry_name,
                "author": author,
                "license": license,
                "description": description,
                "contains": shurikens
            })
        }
    };

    Ok(info)
}

/// Resolve the download URL for a shuriken from registries
pub async fn resolve_download_url(
    registries: &HashMap<String, String>,
    reference: &ShurikenReference,
) -> Result<String, anyhow::Error> {
    if !registries.contains_key(&reference.registry) {
        return Err(anyhow::anyhow!(
            "Registry {} not found in config.",
            &reference.registry
        ));
    }

    let registry = fetch_registry(&reference.registry).await?;

    let shuriken = registry
        .shurikens
        .iter()
        .find(|s| match s {
            ArmoryItem::Shuriken { name, .. } => name == &reference.shuriken,
            ArmoryItem::Bundle { name, .. } => name == &reference.shuriken,
        })
        .ok_or_else(|| {
            anyhow::anyhow!(
                "Shuriken '{}' not found in registry '{}'",
                reference.shuriken,
                reference.registry
            )
        })?
        .to_owned()
        .resolve();

    let shuriken_url = match shuriken {
        ArmoryItem::Shuriken { url, .. } => url,
        _ => return Err(anyhow::anyhow!("Bundles do not have direct download URLs")),
    };

    resolve_shuriken_url(&reference.registry, &shuriken_url)
}