shine-cli 1.6.0

use anyhow::{Result, bail};
use std::path::PathBuf;

use crate::commands::OverlayLinkCommand;
use crate::config::{self, Config};
use crate::{colors, presets};

pub async fn handle_preset_copy(target: &str, force: bool) -> Result<()> {
    use anyhow::Context as _;

    let current_dir = std::env::current_dir().context("reading current directory")?;
    println!(
        "Copying built-in preset {target} to {} ...",
        current_dir.display()
    );

    let report = copy_embedded_preset(target, &current_dir, force).await?;
    print_extract_report(&report);

    println!();
    println!(
        "Tip: delete files you do not plan to customize so they continue to follow built-in updates."
    );
    println!(
        "Tip: run `shine preset overlay link {}` to activate this directory.",
        current_dir.display()
    );

    Ok(())
}

async fn copy_embedded_preset(
    target: &str,
    target_dir: &std::path::Path,
    force: bool,
) -> Result<presets::ExtractReport> {
    crate::commands::parse_copy_target(target).map_err(anyhow::Error::msg)?;
    if presets::embedded_asset_paths(target).is_empty() {
        bail!("built-in preset not found: {target}");
    }
    presets::extract_embedded_prefix(target, target_dir, force).await
}

fn print_extract_report(report: &presets::ExtractReport) {
    let created = report.created.len();
    let overwritten = report.overwritten.len();
    let skipped = report.skipped.len();

    if created > 0 {
        println!("{}", colors::green(&format!("  {created} file(s) created")));
    }
    if overwritten > 0 {
        println!(
            "{}",
            colors::yellow(&format!("  {overwritten} file(s) updated (overwritten)"))
        );
    }
    if skipped > 0 {
        println!("  {skipped} file(s) skipped (already exist; use --force to overwrite)");
    }
}

pub async fn handle_preset_export(
    config: &Config,
    dir: Option<PathBuf>,
    force: bool,
) -> Result<()> {
    use anyhow::Context as _;

    let target = dir.unwrap_or_else(|| config.presets_dir().to_owned());
    tokio::fs::create_dir_all(&target)
        .await
        .with_context(|| format!("creating export directory: {}", target.display()))?;

    println!("Exporting built-in presets to {} ...", target.display());

    let report = presets::extract_all(&target, force).await?;

    let created = report.created.len();
    let overwritten = report.overwritten.len();
    let skipped = report.skipped.len();
    print_extract_report(&report);
    if created == 0 && overwritten == 0 && skipped == 0 {
        println!("  No files exported (empty embedded asset set).");
    }

    if !config.is_external_presets {
        println!();
        println!(
            "Tip: run `shine preset link {}` to activate this directory.",
            target.display()
        );
    }

    Ok(())
}

/// Which override a `handle_link`-style command is pointing at. The two link
/// commands share the same expand/create/stat/canonicalize prelude but differ
/// in which config field they touch and what they print afterward.
enum LinkKind {
    Presets,
    Overlay,
}

async fn handle_link(
    config: &Config,
    path: PathBuf,
    create: bool,
    kind: LinkKind,
    live: bool,
) -> Result<()> {
    use anyhow::Context as _;

    let raw = path.to_string_lossy();
    let expanded = config::full_expand(&raw).with_context(|| format!("expanding path: {raw}"))?;
    let expanded = PathBuf::from(expanded);

    if create {
        tokio::fs::create_dir_all(&expanded)
            .await
            .with_context(|| format!("creating directory: {}", expanded.display()))?;
    }

    let meta = tokio::fs::metadata(&expanded).await.with_context(|| {
        if create {
            format!("accessing directory: {}", expanded.display())
        } else {
            format!(
                "path does not exist: {} (use --create to create it)",
                expanded.display()
            )
        }
    })?;

    if !meta.is_dir() {
        bail!("path is not a directory: {}", expanded.display());
    }

    let absolute = tokio::fs::canonicalize(&expanded).await.unwrap_or(expanded);

    if matches!(kind, LinkKind::Overlay) {
        config::validate_env_override_file(&absolute.join("shine.env.toml")).await?;
    }

    let wanted_mode = if live {
        config::ExternalShellMode::Live
    } else {
        config::ExternalShellMode::Snapshot
    };
    let already_linked = match kind {
        LinkKind::Presets => {
            config
                .presets_dir_override
                .as_deref()
                .is_some_and(|p| p == absolute)
                && config.external_shell_mode == wanted_mode
        }
        LinkKind::Overlay => config
            .presets_overlay_dir_override
            .as_deref()
            .is_some_and(|p| p == absolute),
    };
    if already_linked {
        let message = match kind {
            LinkKind::Presets => format!("already linked: {}", absolute.display()),
            LinkKind::Overlay => format!("overlay already linked: {}", absolute.display()),
        };
        println!("{}", colors::dim(&message));
        return Ok(());
    }

    let updated = match kind {
        LinkKind::Presets => config
            .clone()
            .with_presets_dir_override(Some(absolute.clone()))
            .with_external_shell_mode(wanted_mode),
        LinkKind::Overlay => config
            .clone()
            // Linking a local path clears any shine-managed Git overlay so the
            // two overlay modes never coexist.
            .with_presets_overlay_git(None, None)
            .with_presets_overlay_dir_override(Some(absolute.clone())),
    };
    updated.save().await?;

    match kind {
        LinkKind::Presets => {
            if std::env::var("SHINE_CONFIG_DIR")
                .map(|v| !v.trim().is_empty())
                .unwrap_or(false)
                || std::env::var("SHINE_PRESETS")
                    .map(|v| !v.trim().is_empty())
                    .unwrap_or(false)
            {
                println!(
                    "{}",
                    colors::yellow(
                        "Warning: SHINE_CONFIG_DIR or SHINE_PRESETS is set and takes priority over \
                         the active config at runtime. Unset the env var for this setting to take effect."
                    )
                );
            }

            println!("{}", colors::external_presets_note(&absolute));
            println!(
                "{}",
                colors::dim(match wanted_mode {
                    config::ExternalShellMode::Snapshot => {
                        "Shell mode: snapshot (run `shine upgrade` to apply source changes)."
                    }
                    config::ExternalShellMode::Live => {
                        "Shell mode: live (content changes apply on the next invocation)."
                    }
                })
            );
            println!(
                "{}",
                colors::dim(
                    "Run `shine preset export` to populate the directory with built-in presets."
                )
            );
        }
        LinkKind::Overlay => {
            println!("{}", colors::presets_overlay_note(&absolute));
            println!(
                "{}",
                colors::dim("Overlay files override the active presets source by matching path.")
            );
        }
    }

    Ok(())
}

pub async fn handle_preset_link(
    config: &Config,
    path: PathBuf,
    create: bool,
    live: bool,
) -> Result<()> {
    handle_link(config, path, create, LinkKind::Presets, live).await
}

pub async fn handle_preset_unlink(config: &Config) -> Result<()> {
    if config.presets_dir_override.is_none() {
        println!(
            "{}",
            colors::dim("No external presets directory is configured.")
        );
        return Ok(());
    }

    let updated = config
        .clone()
        .with_presets_dir_override(None)
        .with_external_shell_mode(config::ExternalShellMode::Snapshot);
    updated.save().await?;

    println!(
        "{}",
        colors::green("External presets directory removed from the active config.")
    );
    println!(
        "{}",
        colors::dim("Built-in embedded presets will be used on the next run.")
    );

    Ok(())
}

pub async fn handle_overlay_link(config: &Config, cmd: OverlayLinkCommand) -> Result<()> {
    if let Some(url) = cmd.git {
        return handle_overlay_link_git(config, url, cmd.branch).await;
    }
    match cmd.path {
        Some(path) => handle_link(config, path, cmd.create, LinkKind::Overlay, false).await,
        None => bail!("provide a local PATH or --git <URL> for the overlay"),
    }
}

/// Point the overlay at a shine-managed Git source: record the URL (clearing any
/// manual overlay path) and clone/mirror it immediately so it's ready to use.
async fn handle_overlay_link_git(
    config: &Config,
    url: String,
    branch: Option<String>,
) -> Result<()> {
    let url = url.trim().to_string();
    if url.is_empty() {
        bail!("overlay Git URL must not be empty");
    }
    let branch = branch
        .map(|b| b.trim().to_string())
        .filter(|b| !b.is_empty());

    let updated = config.clone().with_presets_overlay_git(Some(url), branch);
    updated.save().await?;

    let (url, branch, dir) = updated
        .overlay_git_source()
        .expect("overlay Git source was just set");
    println!(
        "{}",
        colors::green(&format!("Overlay Git source set: {url}"))
    );
    if let Some(branch) = branch {
        println!("  {} {branch}", colors::dim("branch:"));
    }
    println!("  {} {}", colors::dim("managed dir:"), dir.display());

    // Clone (or mirror, if already present) now so the overlay is usable right
    // away instead of waiting for the next `shine preset pull`.
    crate::git_pull::sync_managed_overlay(url, branch, dir, false).await?;
    Ok(())
}

pub async fn handle_overlay_unlink(config: &Config) -> Result<()> {
    if config.presets_overlay_dir_override.is_none() && config.presets_overlay_git.is_none() {
        println!("{}", colors::dim("No presets overlay is configured."));
        return Ok(());
    }

    let managed_dir = config
        .overlay_git_source()
        .map(|(_, _, dir)| dir.to_path_buf());

    let updated = config
        .clone()
        .with_presets_overlay_git(None, None)
        .with_presets_overlay_dir_override(None);
    updated.save().await?;

    println!(
        "{}",
        colors::green("Presets overlay removed from the active config.")
    );
    println!(
        "{}",
        colors::dim("Built-in embedded presets will be used without overlay on the next run.")
    );
    if let Some(dir) = managed_dir.filter(|dir| dir.exists()) {
        println!(
            "{}",
            colors::dim(&format!(
                "The managed overlay checkout remains at {}. Remove it manually if unwanted.",
                dir.display()
            ))
        );
    }

    Ok(())
}

pub fn handle_overlay_info(config: &Config) -> Result<()> {
    if let Some((url, branch, dir)) = config.overlay_git_source() {
        println!("{}", colors::green(&format!("Overlay Git source: {url}")));
        if let Some(branch) = branch {
            println!("  {} {branch}", colors::dim("branch:"));
        }
        println!("  {} {}", colors::dim("managed dir:"), dir.display());
        if dir.exists() {
            println!("{}", colors::green("Cloned"));
        } else {
            println!(
                "{}",
                colors::dim("Not cloned yet — run `shine preset pull` to fetch it.")
            );
        }
        return Ok(());
    }

    if let Some(dir) = &config.presets_overlay_dir_override {
        println!("{}", colors::presets_overlay_note(dir));
        println!("{}", colors::green("Active"));
    } else {
        println!("{}", colors::dim("No presets overlay is configured."));
    }
    Ok(())
}

#[cfg(test)]
mod tests {
    use super::*;
    use crate::test_support::env_lock;
    use std::time::{SystemTime, UNIX_EPOCH};
    use tokio::fs;

    async fn make_temp_dir() -> PathBuf {
        crate::test_support::make_temp_dir("shine-preset-commands-test").await
    }

    fn config_in(dir: &std::path::Path) -> Config {
        crate::test_support::test_config(dir)
    }

    #[test]
    fn copy_target_requires_canonical_safe_category() {
        for valid in ["app/surge", "shell/proxy", "sys/macos"] {
            crate::commands::parse_copy_target(valid).unwrap();
        }
        for invalid in [
            "surge",
            "app",
            "app/",
            "/app/surge",
            "app/../surge",
            "app/.",
            "app/surge/extra",
            "other/surge",
            "app\\surge",
        ] {
            assert!(
                crate::commands::parse_copy_target(invalid).is_err(),
                "target should be rejected: {invalid}"
            );
        }
    }

    #[tokio::test]
    async fn copy_one_builtin_preset_preserves_prefix_and_collision_policy() {
        let dir = make_temp_dir().await;
        let first = copy_embedded_preset("app/clash-verge", &dir, false)
            .await
            .unwrap();
        assert!(!first.created.is_empty());
        assert!(dir.join("app/clash-verge/shine.toml").is_file());
        assert!(dir.join("app/clash-verge/merge.yaml").is_file());
        assert!(!dir.join("app/surge/shine.toml").exists());

        let marker_path = dir.join("app/clash-verge/merge.yaml");
        fs::write(&marker_path, "user customization").await.unwrap();
        let second = copy_embedded_preset("app/clash-verge", &dir, false)
            .await
            .unwrap();
        assert!(second.skipped.contains(&marker_path));
        assert_eq!(
            fs::read_to_string(&marker_path).await.unwrap(),
            "user customization"
        );

        let third = copy_embedded_preset("app/clash-verge", &dir, true)
            .await
            .unwrap();
        assert!(third.overwritten.contains(&marker_path));
        assert_ne!(
            fs::read_to_string(&marker_path).await.unwrap(),
            "user customization"
        );
        fs::remove_dir_all(dir).await.unwrap();
    }

    #[tokio::test]
    async fn copy_unknown_builtin_preset_creates_nothing() {
        let dir = make_temp_dir().await;
        let error = match copy_embedded_preset("app/not-a-real-preset", &dir, false).await {
            Ok(_) => panic!("unknown preset should fail"),
            Err(error) => error,
        };
        assert!(error.to_string().contains("built-in preset not found"));
        assert!(
            fs::read_dir(&dir)
                .await
                .unwrap()
                .next_entry()
                .await
                .unwrap()
                .is_none()
        );
        fs::remove_dir_all(dir).await.unwrap();
    }

    #[allow(clippy::await_holding_lock)]
    #[tokio::test(flavor = "current_thread")]
    async fn overlay_link_rejects_invalid_env_without_saving_link() {
        let _guard = env_lock();
        let suffix = SystemTime::now()
            .duration_since(UNIX_EPOCH)
            .unwrap()
            .as_nanos();
        let root = std::env::temp_dir().join(format!("shine-overlay-link-{suffix}"));
        let state_dir = root.join("state");
        let overlay_dir = root.join("overlay");
        tokio::fs::create_dir_all(&overlay_dir).await.unwrap();
        tokio::fs::write(
            overlay_dir.join("shine.env.toml"),
            "INVALID = \"unterminated\n",
        )
        .await
        .unwrap();

        // SAFETY: env_lock serializes process-global environment changes in tests.
        unsafe {
            std::env::set_var("SHINE_CONFIG_DIR", &state_dir);
            std::env::remove_var("SHINE_PRESETS");
        }
        let config = Config::load_or_init().await.unwrap();
        let error = handle_overlay_link(
            &config,
            OverlayLinkCommand {
                path: Some(overlay_dir.clone()),
                git: None,
                branch: None,
                create: false,
            },
        )
        .await
        .unwrap_err();
        assert!(error.to_string().contains("shine.env.toml"));

        let saved = tokio::fs::read_to_string(state_dir.join("config.toml"))
            .await
            .unwrap();
        assert!(!saved.contains("presets_overlay_dir"));

        // SAFETY: env_lock serializes process-global environment changes in tests.
        unsafe { std::env::remove_var("SHINE_CONFIG_DIR") };
        tokio::fs::remove_dir_all(root).await.unwrap();
    }

    #[tokio::test]
    async fn link_writes_presets_dir_to_config() {
        let dir = make_temp_dir().await;
        let presets = make_temp_dir().await;
        let config = config_in(&dir);

        handle_preset_link(&config, presets.clone(), false, false)
            .await
            .unwrap();

        let content = fs::read_to_string(dir.join("config.toml")).await.unwrap();
        assert!(
            content.contains(presets.to_str().unwrap()),
            "config.toml should contain the linked path"
        );

        fs::remove_dir_all(&dir).await.unwrap();
        fs::remove_dir_all(&presets).await.unwrap();
    }

    #[tokio::test]
    async fn live_link_persists_external_shell_mode() {
        let dir = make_temp_dir().await;
        let presets = make_temp_dir().await;
        let config = config_in(&dir);

        handle_preset_link(&config, presets.clone(), false, true)
            .await
            .unwrap();

        let content = fs::read_to_string(dir.join("config.toml")).await.unwrap();
        assert!(content.contains("external_shell_mode = \"live\""));
        fs::remove_dir_all(&dir).await.unwrap();
        fs::remove_dir_all(&presets).await.unwrap();
    }

    #[tokio::test]
    async fn link_creates_dir_when_create_flag_set() {
        let dir = make_temp_dir().await;
        let config = config_in(&dir);
        let new_dir = dir.join("new-presets");

        handle_preset_link(&config, new_dir.clone(), true, false)
            .await
            .unwrap();

        assert!(new_dir.exists(), "directory should have been created");
        fs::remove_dir_all(&dir).await.unwrap();
    }

    #[tokio::test]
    async fn link_fails_when_path_missing_and_no_create() {
        let dir = make_temp_dir().await;
        let config = config_in(&dir);
        let missing = dir.join("does-not-exist");

        let err = handle_preset_link(&config, missing, false, false).await;
        assert!(err.is_err());
        let msg = err.unwrap_err().to_string();
        assert!(
            msg.contains("--create") || msg.contains("does not exist"),
            "error should mention --create: {msg}"
        );

        fs::remove_dir_all(&dir).await.unwrap();
    }

    #[tokio::test]
    async fn link_fails_when_path_is_a_file() {
        let dir = make_temp_dir().await;
        let config = config_in(&dir);
        let file = dir.join("not-a-dir.txt");
        fs::write(&file, b"hello").await.unwrap();

        let err = handle_preset_link(&config, file, false, false).await;
        assert!(err.is_err());
        assert!(
            err.unwrap_err().to_string().contains("not a directory"),
            "error should mention 'not a directory'"
        );

        fs::remove_dir_all(&dir).await.unwrap();
    }

    #[tokio::test]
    async fn link_is_noop_when_already_linked_to_same_path() {
        let dir = make_temp_dir().await;
        let presets = make_temp_dir().await;
        let abs = tokio::fs::canonicalize(&presets)
            .await
            .unwrap_or(presets.clone());
        let config = config_in(&dir).with_presets_dir_override(Some(abs.clone()));

        // Should return Ok without error
        handle_preset_link(&config, presets.clone(), false, false)
            .await
            .unwrap();

        // Config file should not be written (config_in has no pre-existing file)
        assert!(!dir.join("config.toml").exists());

        fs::remove_dir_all(&dir).await.unwrap();
        fs::remove_dir_all(&presets).await.unwrap();
    }

    #[allow(clippy::await_holding_lock)]
    #[tokio::test(flavor = "current_thread")]
    async fn link_warns_when_env_var_overrides() {
        let _guard = env_lock();
        let dir = make_temp_dir().await;
        let presets = make_temp_dir().await;
        let config = config_in(&dir);

        // SAFETY: `_guard` holds `env_lock()`, serialising SHINE_PRESETS mutations across test threads.
        unsafe { std::env::set_var("SHINE_PRESETS", "/some/override") };
        // Should succeed even with env var set
        handle_preset_link(&config, presets.clone(), false, false)
            .await
            .unwrap();
        // SAFETY: `_guard` holds `env_lock()`, serialising SHINE_PRESETS mutations across test threads.
        unsafe { std::env::remove_var("SHINE_PRESETS") };

        fs::remove_dir_all(&dir).await.unwrap();
        fs::remove_dir_all(&presets).await.unwrap();
    }

    #[tokio::test]
    async fn unlink_removes_presets_dir_key() {
        let dir = make_temp_dir().await;
        let presets = make_temp_dir().await;
        let config = config_in(&dir).with_presets_dir_override(Some(presets.clone()));
        // Write initial config with presets_dir set
        config.save().await.unwrap();

        handle_preset_unlink(&config).await.unwrap();

        let content = fs::read_to_string(dir.join("config.toml")).await.unwrap();
        let parsed: toml::Table = toml::from_str(&content).unwrap();
        assert!(
            !parsed.contains_key("presets_dir"),
            "presets_dir key must be absent after unlink"
        );

        fs::remove_dir_all(&dir).await.unwrap();
        fs::remove_dir_all(&presets).await.unwrap();
    }

    #[tokio::test]
    async fn unlink_is_noop_when_no_override_set() {
        let dir = make_temp_dir().await;
        let config = config_in(&dir);

        // Should return Ok, no file written
        handle_preset_unlink(&config).await.unwrap();
        assert!(!dir.join("config.toml").exists());

        fs::remove_dir_all(&dir).await.unwrap();
    }
}