pasta_check 0.3.1

use crate::ReleaseArgs;
use crate::copy::{copy_dir_recursive, prepare_release_dir};
use crate::nar::create_nar;
use crate::update_files::generate_update_files;
use std::io;

/// release サブコマンドを実行
pub(crate) fn execute_release(args: &ReleaseArgs) -> io::Result<()> {
    // Step 1: リリースフォルダー初期化
    println!("[1/5] Preparing release folder...");
    prepare_release_dir(&args.release)?;

    // Step 2: target → release コピー
    println!("[2/5] Copying target files...");
    let count = copy_dir_recursive(&args.target, &args.release)?;
    println!("  Copied {count} files from {}", args.target.display());

    // Step 3: --copy 上書きコピー
    if !args.copy_dirs.is_empty() {
        println!("[3/5] Applying overlay copies...");
        for copy_dir in &args.copy_dirs {
            let c = copy_dir_recursive(copy_dir, &args.release)?;
            println!("  Copied {c} files from {}", copy_dir.display());
        }
    } else {
        println!("[3/5] Applying overlay copies... (none specified)");
    }

    // Step 4: 更新ファイル生成
    println!("[4/5] Generating update files...");
    let entries = generate_update_files(&args.release)?;
    println!("  Generated updates.txt ({entries} entries)");

    // Step 5: NAR 作成
    println!("[5/5] Creating NAR archive...");
    let nar_size = create_nar(&args.release, &args.nar)?;
    let nar_size_kb = nar_size as f64 / 1024.0;
    println!("  Created {} ({nar_size_kb:.1} KB)", args.nar.display());

    println!();
    println!("Release complete!");

    Ok(())
}

#[cfg(test)]
mod tests {
    use super::*;
    use std::fs;
    use tempfile::TempDir;

    #[test]
    fn test_execute_release_full_pipeline() {
        let temp = TempDir::new().unwrap();

        // target フォルダーを準備
        let target = temp.path().join("target_ghost");
        fs::create_dir_all(target.join("ghost/master")).unwrap();
        fs::write(target.join("ghost/master/descript.txt"), "desc").unwrap();
        fs::write(target.join("install.txt"), "install").unwrap();

        let release = temp.path().join("release_out");
        let nar = temp.path().join("out.nar");

        let args = ReleaseArgs {
            target: target.clone(),
            release: release.clone(),
            nar: nar.clone(),
            copy_dirs: vec![],
        };

        execute_release(&args).unwrap();

        // リリースフォルダーに更新ファイルが生成されている
        assert!(!release.join("updates2.dau").exists());
        assert!(release.join("updates.txt").exists());
        // NAR が作成されている
        assert!(nar.exists());
        assert!(nar.metadata().unwrap().len() > 0);
        // target フォルダーは変更されていない
        assert!(!target.join("updates2.dau").exists());
        assert_eq!(
            fs::read_to_string(target.join("install.txt")).unwrap(),
            "install"
        );
    }

    /// 複数 --copy 指定時は後勝ち（後のオーバーレイが前のオーバーレイを上書きする）
    #[test]
    fn test_execute_release_overlay_precedence_last_wins() {
        let temp = TempDir::new().unwrap();

        let target = temp.path().join("target_ghost");
        fs::create_dir_all(&target).unwrap();
        fs::write(target.join("a.txt"), "original").unwrap();

        let overlay1 = temp.path().join("overlay1");
        fs::create_dir_all(&overlay1).unwrap();
        fs::write(overlay1.join("a.txt"), "first").unwrap();
        fs::write(overlay1.join("only1.txt"), "one").unwrap();

        let overlay2 = temp.path().join("overlay2");
        fs::create_dir_all(&overlay2).unwrap();
        fs::write(overlay2.join("a.txt"), "second").unwrap();

        let release = temp.path().join("release_out");
        let args = ReleaseArgs {
            target,
            release: release.clone(),
            nar: temp.path().join("out.nar"),
            copy_dirs: vec![overlay1, overlay2],
        };

        execute_release(&args).unwrap();

        assert_eq!(fs::read_to_string(release.join("a.txt")).unwrap(), "second");
        // 上書きされなかったオーバーレイ 1 固有のファイルは残る
        assert_eq!(
            fs::read_to_string(release.join("only1.txt")).unwrap(),
            "one"
        );
    }

    /// 既存の release フォルダーは初期化され、stale ファイルが残らない
    #[test]
    fn test_execute_release_cleans_stale_release_dir() {
        let temp = TempDir::new().unwrap();

        let target = temp.path().join("target_ghost");
        fs::create_dir_all(&target).unwrap();
        fs::write(target.join("a.txt"), "fresh").unwrap();

        let release = temp.path().join("release_out");
        fs::create_dir_all(&release).unwrap();
        fs::write(release.join("stale.txt"), "stale").unwrap();

        let args = ReleaseArgs {
            target,
            release: release.clone(),
            nar: temp.path().join("out.nar"),
            copy_dirs: vec![],
        };

        execute_release(&args).unwrap();

        assert!(!release.join("stale.txt").exists());
        assert_eq!(fs::read_to_string(release.join("a.txt")).unwrap(), "fresh");
    }

    /// NAR には生成済みの updates.txt が封入される
    /// （updates.txt 生成 → NAR 作成の実行順序契約。順序が逆転すると fail する）
    #[test]
    fn test_execute_release_nar_contains_updates_txt() {
        let temp = TempDir::new().unwrap();

        let target = temp.path().join("target_ghost");
        fs::create_dir_all(target.join("ghost/master")).unwrap();
        fs::write(target.join("ghost/master/descript.txt"), "desc").unwrap();

        let nar = temp.path().join("out.nar");
        let args = ReleaseArgs {
            target,
            release: temp.path().join("release_out"),
            nar: nar.clone(),
            copy_dirs: vec![],
        };

        execute_release(&args).unwrap();

        let file = fs::File::open(&nar).unwrap();
        let mut archive = zip::ZipArchive::new(file).unwrap();
        assert!(archive.by_name("updates.txt").is_ok());
        assert!(archive.by_name("ghost/master/updates.txt").is_ok());
    }

    /// target が存在しない場合はエラーが伝播する
    #[test]
    fn test_execute_release_missing_target_errors() {
        let temp = TempDir::new().unwrap();
        let args = ReleaseArgs {
            target: temp.path().join("no_such_target"),
            release: temp.path().join("release_out"),
            nar: temp.path().join("out.nar"),
            copy_dirs: vec![],
        };
        assert!(execute_release(&args).is_err());
    }

    #[test]
    fn test_execute_release_with_copy() {
        let temp = TempDir::new().unwrap();

        let target = temp.path().join("target_ghost");
        fs::create_dir_all(&target).unwrap();
        fs::write(target.join("a.txt"), "original").unwrap();

        let overlay = temp.path().join("overlay");
        fs::create_dir_all(&overlay).unwrap();
        fs::write(overlay.join("a.txt"), "overwritten").unwrap();
        fs::write(overlay.join("b.txt"), "new file").unwrap();

        let release = temp.path().join("release_out");
        let nar = temp.path().join("out.nar");

        let args = ReleaseArgs {
            target: target.clone(),
            release: release.clone(),
            nar,
            copy_dirs: vec![overlay],
        };

        execute_release(&args).unwrap();

        assert_eq!(
            fs::read_to_string(release.join("a.txt")).unwrap(),
            "overwritten"
        );
        assert_eq!(
            fs::read_to_string(release.join("b.txt")).unwrap(),
            "new file"
        );
        // target は変更されていない
        assert_eq!(
            fs::read_to_string(target.join("a.txt")).unwrap(),
            "original"
        );
    }
}