ruchy 5.0.0-beta.2

//! Refactored test command handler
//! Complexity reduced from ~200 lines to ≤10 per function
use super::test_helpers::{
    discover_test_files, execute_tests, generate_coverage_report, generate_json_output,
    print_test_summary, TestResult,
};
use anyhow::Result;
use std::path::{Path, PathBuf};
use std::time::Instant;
/// Handle test command - refactored with ≤10 complexity
pub fn handle_test_command(
    path: Option<PathBuf>,
    watch: bool,
    verbose: bool,
    filter: Option<&str>,
    coverage: bool,
    coverage_format: &str,
    parallel: usize,
    threshold: f64,
    format: &str,
) -> Result<()> {
    let test_path = path.unwrap_or_else(|| PathBuf::from("."));
    if watch {
        handle_watch_mode(&test_path, verbose, filter)
    } else {
        run_tests(
            &test_path,
            verbose,
            filter,
            coverage,
            coverage_format,
            parallel,
            threshold,
            format,
        )
    }
}
/// Run tests once
fn run_tests(
    path: &Path,
    verbose: bool,
    filter: Option<&str>,
    coverage: bool,
    coverage_format: &str,
    _parallel: usize, // Unused for now
    threshold: f64,
    format: &str,
) -> Result<()> {
    // Discover test files
    let test_files = discover_test_files(path, filter, verbose)?;
    if test_files.is_empty() {
        anyhow::bail!("No .ruchy test files found in {}", path.display());
    }
    println!("🧪 Running {} .ruchy test files...\n", test_files.len());
    // Execute tests
    let total_start = Instant::now();
    let test_results = execute_tests(&test_files, verbose);
    let total_duration = total_start.elapsed();
    // Print summary
    print_test_summary(&test_results, total_duration, verbose);
    // Handle output format
    if format == "json" {
        let json = generate_json_output(&test_results, total_duration)?;
        println!("\n{}", json);
    }
    // Handle coverage if requested
    if coverage {
        generate_coverage_report(&test_files, &test_results, coverage_format, threshold)?;
    }
    // Check for failures
    check_test_failures(&test_results)?;
    println!("\n✅ All tests passed!");
    Ok(())
}
/// Print the watch-mode banner and perform the initial test run.
///
/// Split out of [`handle_watch_mode`] (PMAT-104) so the non-looping part of
/// watch mode can be tested; the loop itself never returns by design.
pub(crate) fn start_watch_mode(path: &Path, verbose: bool, filter: Option<&str>) {
    use colored::Colorize;
    println!(
        "{} Watching {} for test changes...",
        "👁".bright_cyan(),
        path.display()
    );
    println!("Press Ctrl+C to stop watching\n");
    // Initial test run
    let _ = run_tests(path, verbose, filter, false, "text", 1, 0.0, "text");
}

/// Run a single watch-mode poll: re-run the tests if anything changed since
/// `last_modified`, updating it in place.
///
/// Returns `true` when a change was detected and the tests were re-run. This is
/// the body of the watch loop, extracted (PMAT-104) so it can be tested without
/// entering the loop.
pub(crate) fn run_watch_iteration(
    path: &Path,
    verbose: bool,
    filter: Option<&str>,
    last_modified: &mut std::time::SystemTime,
) -> bool {
    use colored::Colorize;
    let current_modified = get_latest_modification(path);
    if current_modified <= *last_modified {
        return false;
    }
    *last_modified = current_modified;
    println!("\n{} Files changed, running tests...", "→".bright_cyan());
    let _ = run_tests(path, verbose, filter, false, "text", 1, 0.0, "text");
    true
}

/// Handle watch mode
fn handle_watch_mode(path: &Path, verbose: bool, filter: Option<&str>) -> Result<()> {
    use std::thread;
    use std::time::Duration;
    start_watch_mode(path, verbose, filter);
    // Watch for changes
    let mut last_modified = get_latest_modification(path);
    loop {
        thread::sleep(Duration::from_millis(1000));
        run_watch_iteration(path, verbose, filter, &mut last_modified);
    }
}
/// Modification time of a directory entry if it is a `.ruchy` file, else `None`.
fn ruchy_file_mtime(entry: &std::fs::DirEntry) -> Option<std::time::SystemTime> {
    let path = entry.path().canonicalize().ok()?;
    if path.extension().and_then(|ext| ext.to_str()) != Some("ruchy") {
        return None;
    }
    std::fs::metadata(&path).ok()?.modified().ok()
}

/// Get latest modification time in directory
fn get_latest_modification(path: &Path) -> std::time::SystemTime {
    let mut latest = std::time::SystemTime::now();
    if let Ok(entries) = std::fs::read_dir(path) {
        for modified in entries.flatten().filter_map(|e| ruchy_file_mtime(&e)) {
            if modified > latest {
                latest = modified;
            }
        }
    }
    latest
}
/// Check if any tests failed and return error if necessary
fn check_test_failures(test_results: &[TestResult]) -> Result<()> {
    let failed = test_results.iter().filter(|r| !r.success).count();
    if failed > 0 {
        Err(anyhow::anyhow!(
            "Test failures detected: {} tests failed",
            failed
        ))
    } else {
        Ok(())
    }
}

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

    // Helper function to create a test directory with .ruchy files
    fn create_test_directory_with_files() -> Result<TempDir> {
        let temp_dir = TempDir::new()?;

        // Create a passing test file
        let test_file1 = temp_dir.path().join("passing_test.ruchy");
        fs::write(&test_file1, "println(\"Hello Test\")")?;

        // Create another passing test file
        let test_file2 = temp_dir.path().join("another_test.ruchy");
        fs::write(&test_file2, "let x = 42; println(x)")?;

        // Create a non-ruchy file (should be ignored)
        let readme_file = temp_dir.path().join("README.txt");
        fs::write(&readme_file, "This is documentation")?;

        Ok(temp_dir)
    }

    // Helper function to create TestResult instances
    fn create_test_result(
        file: &str,
        success: bool,
        duration_ms: u64,
        error: Option<&str>,
    ) -> TestResult {
        TestResult {
            file: PathBuf::from(file),
            success,
            duration: Duration::from_millis(duration_ms),
            error: error.map(std::string::ToString::to_string),
        }
    }

    // ========== Test Command Handler Tests ==========
    #[test]
    fn test_handle_test_command_default_path() {
        let _cwd = crate::handlers::test_support::cwd_lock();
        let temp_dir =
            create_test_directory_with_files().expect("Failed to create test directory with files");

        // Change to the temp directory for the test
        let original_dir = std::env::current_dir().expect("Failed to get current directory");
        std::env::set_current_dir(temp_dir.path())
            .expect("Failed to set current directory to temp path");

        let result = handle_test_command(
            None,   // Use default path (current directory)
            false,  // No watch mode
            false,  // Not verbose
            None,   // No filter
            false,  // No coverage
            "text", // Coverage format
            1,      // Parallel threads
            0.0,    // No threshold
            "text", // Output format
        );

        // Restore original directory
        std::env::set_current_dir(original_dir).expect("Failed to restore original directory");

        // Test should complete without panicking
        assert!(result.is_ok() || result.is_err());
    }

    #[test]
    fn test_handle_test_command_with_path() {
        let temp_dir =
            create_test_directory_with_files().expect("Failed to create test directory with files");

        let result = handle_test_command(
            Some(temp_dir.path().to_path_buf()),
            false,  // No watch mode
            true,   // Verbose
            None,   // No filter
            false,  // No coverage
            "text", // Coverage format
            1,      // Parallel threads
            0.0,    // No threshold
            "text", // Output format
        );

        // Test should complete without panicking
        assert!(result.is_ok() || result.is_err());
    }

    #[test]
    fn test_handle_test_command_with_filter() {
        let temp_dir =
            create_test_directory_with_files().expect("Failed to create test directory with files");

        let result = handle_test_command(
            Some(temp_dir.path().to_path_buf()),
            false,           // No watch mode
            false,           // Not verbose
            Some("passing"), // Filter for "passing" in filename
            false,           // No coverage
            "text",          // Coverage format
            1,               // Parallel threads
            0.0,             // No threshold
            "text",          // Output format
        );

        // Test should complete without panicking
        assert!(result.is_ok() || result.is_err());
    }

    #[test]
    fn test_handle_test_command_with_coverage() {
        let temp_dir =
            create_test_directory_with_files().expect("Failed to create test directory with files");

        let result = handle_test_command(
            Some(temp_dir.path().to_path_buf()),
            false,  // No watch mode
            false,  // Not verbose
            None,   // No filter
            true,   // Enable coverage
            "html", // HTML coverage format
            1,      // Parallel threads
            80.0,   // Coverage threshold
            "text", // Output format
        );

        // Test should complete without panicking
        assert!(result.is_ok() || result.is_err());
    }

    #[test]
    fn test_handle_test_command_json_output() {
        let temp_dir =
            create_test_directory_with_files().expect("Failed to create test directory with files");

        let result = handle_test_command(
            Some(temp_dir.path().to_path_buf()),
            false,  // No watch mode
            false,  // Not verbose
            None,   // No filter
            false,  // No coverage
            "text", // Coverage format
            1,      // Parallel threads
            0.0,    // No threshold
            "json", // JSON output format
        );

        // Test should complete without panicking
        assert!(result.is_ok() || result.is_err());
    }

    // ========== Run Tests Function Tests ==========
    #[test]
    fn test_run_tests_empty_directory() {
        let temp_dir = TempDir::new().expect("Failed to create temporary test directory");
        // Create empty directory with no .ruchy files

        let result = run_tests(
            temp_dir.path(),
            false,  // Not verbose
            None,   // No filter
            false,  // No coverage
            "text", // Coverage format
            1,      // Parallel threads
            0.0,    // No threshold
            "text", // Output format
        );

        // Empty directory correctly errors with "No .ruchy test files found"
        assert!(result.is_err());
    }

    #[test]
    fn test_run_tests_with_files() {
        let temp_dir =
            create_test_directory_with_files().expect("Failed to create test directory with files");

        let result = run_tests(
            temp_dir.path(),
            true,   // Verbose
            None,   // No filter
            false,  // No coverage
            "text", // Coverage format
            1,      // Parallel threads
            0.0,    // No threshold
            "text", // Output format
        );

        // Test should complete without panicking
        assert!(result.is_ok() || result.is_err());
    }

    #[test]
    fn test_run_tests_with_filter() {
        let temp_dir =
            create_test_directory_with_files().expect("Failed to create test directory with files");

        let result = run_tests(
            temp_dir.path(),
            false,           // Not verbose
            Some("another"), // Filter for "another" in filename
            false,           // No coverage
            "text",          // Coverage format
            1,               // Parallel threads
            0.0,             // No threshold
            "text",          // Output format
        );

        // Test should complete without panicking
        assert!(result.is_ok() || result.is_err());
    }

    #[test]
    fn test_run_tests_json_format() {
        let temp_dir =
            create_test_directory_with_files().expect("Failed to create test directory with files");

        let result = run_tests(
            temp_dir.path(),
            false,  // Not verbose
            None,   // No filter
            false,  // No coverage
            "text", // Coverage format
            1,      // Parallel threads
            0.0,    // No threshold
            "json", // JSON output format
        );

        // Test should complete without panicking
        assert!(result.is_ok() || result.is_err());
    }

    #[test]
    fn test_run_tests_with_coverage() {
        let temp_dir =
            create_test_directory_with_files().expect("Failed to create test directory with files");

        let result = run_tests(
            temp_dir.path(),
            false,  // Not verbose
            None,   // No filter
            true,   // Enable coverage
            "html", // HTML coverage format
            1,      // Parallel threads
            75.0,   // Coverage threshold
            "text", // Output format
        );

        // Test should complete without panicking
        assert!(result.is_ok() || result.is_err());
    }

    // ========== File Modification Tests ==========
    #[test]
    fn test_get_latest_modification_empty_directory() {
        let temp_dir = TempDir::new().expect("Failed to create temporary test directory");
        // Empty directory with no .ruchy files

        let modification_time = get_latest_modification(temp_dir.path());
        // Should return some time (likely current time)
        assert!(modification_time <= std::time::SystemTime::now());
    }

    #[test]
    fn test_get_latest_modification_with_ruchy_files() {
        let temp_dir =
            create_test_directory_with_files().expect("Failed to create test directory with files");

        let modification_time = get_latest_modification(temp_dir.path());
        // Should return a valid time
        assert!(modification_time <= std::time::SystemTime::now());
    }

    #[test]
    fn test_get_latest_modification_with_mixed_files() {
        let temp_dir = TempDir::new().expect("Failed to create temporary test directory");

        // Create a .ruchy file
        let ruchy_file = temp_dir.path().join("test.ruchy");
        fs::write(&ruchy_file, "println(\"test\")")
            .unwrap_or_else(|_| panic!("Failed to write test file: {}", ruchy_file.display()));

        // Create a non-ruchy file (should be ignored)
        let other_file = temp_dir.path().join("other.txt");
        fs::write(&other_file, "not ruchy")
            .unwrap_or_else(|_| panic!("Failed to write test file: {}", other_file.display()));

        let modification_time = get_latest_modification(temp_dir.path());
        // Should return a valid time
        assert!(modification_time <= std::time::SystemTime::now());
    }

    #[test]
    fn test_get_latest_modification_nonexistent_directory() {
        let nonexistent_path = Path::new("/nonexistent/directory");

        let modification_time = get_latest_modification(nonexistent_path);
        // Should handle gracefully and return some time
        assert!(modification_time <= std::time::SystemTime::now());
    }

    // ========== Test Failure Checking Tests ==========
    #[test]
    fn test_check_test_failures_all_passing() {
        let test_results = vec![
            create_test_result("test1.ruchy", true, 100, None),
            create_test_result("test2.ruchy", true, 150, None),
            create_test_result("test3.ruchy", true, 200, None),
        ];

        // Should return Ok for all passing tests
        assert!(check_test_failures(&test_results).is_ok());
    }

    #[test]
    fn test_check_test_failures_with_failures() {
        let test_results = vec![
            create_test_result("test1.ruchy", true, 100, None),
            create_test_result("test2.ruchy", false, 50, Some("Parse error")),
            create_test_result("test3.ruchy", true, 200, None),
        ];

        // Should return Err when there are failures
        let result = check_test_failures(&test_results);
        assert!(result.is_err());
        assert!(result.unwrap_err().to_string().contains("1 tests failed"));
    }

    #[test]
    fn test_check_test_failures_all_failing() {
        let test_results = vec![
            create_test_result("test1.ruchy", false, 50, Some("Error 1")),
            create_test_result("test2.ruchy", false, 60, Some("Error 2")),
            create_test_result("test3.ruchy", false, 70, Some("Error 3")),
        ];

        // Should return Err when all tests fail
        let result = check_test_failures(&test_results);
        assert!(result.is_err());
        assert!(result.unwrap_err().to_string().contains("3 tests failed"));
    }

    #[test]
    fn test_check_test_failures_empty_results() {
        let test_results: Vec<TestResult> = vec![];

        // Should return Ok for empty results (no failures)
        assert!(check_test_failures(&test_results).is_ok());
    }

    // ========== Integration Tests ==========
    #[test]
    fn test_integration_complete_workflow() {
        let temp_dir =
            create_test_directory_with_files().expect("Failed to create test directory with files");

        // Test the complete workflow without watch mode
        let result = handle_test_command(
            Some(temp_dir.path().to_path_buf()),
            false,  // No watch mode
            true,   // Verbose
            None,   // No filter
            false,  // No coverage (to keep test simple)
            "text", // Coverage format
            1,      // Single thread
            0.0,    // No threshold
            "text", // Text output
        );

        // Should complete the full workflow
        assert!(result.is_ok() || result.is_err());
    }

    #[test]
    fn test_integration_with_all_options() {
        let temp_dir =
            create_test_directory_with_files().expect("Failed to create test directory with files");

        // Test with maximum options enabled
        let result = handle_test_command(
            Some(temp_dir.path().to_path_buf()),
            false,        // No watch mode (to keep test finite)
            true,         // Verbose
            Some("test"), // Filter
            true,         // Enable coverage
            "json",       // JSON coverage format
            2,            // Multiple threads
            50.0,         // Coverage threshold
            "json",       // JSON output
        );

        // Should handle all options gracefully
        assert!(result.is_ok() || result.is_err());
    }

    // ========== Error Handling Tests ==========
    #[test]
    fn test_error_handling_invalid_path() {
        let invalid_path = PathBuf::from("/absolutely/nonexistent/path/that/should/not/exist");

        let result = handle_test_command(
            Some(invalid_path),
            false,  // No watch mode
            false,  // Not verbose
            None,   // No filter
            false,  // No coverage
            "text", // Coverage format
            1,      // Single thread
            0.0,    // No threshold
            "text", // Text output
        );

        // Should handle invalid path gracefully (likely return an error)
        assert!(result.is_err() || result.is_ok());
    }

    #[test]
    fn test_parameter_validation() {
        let temp_dir =
            create_test_directory_with_files().expect("Failed to create test directory with files");

        // Test with various parameter combinations
        let test_cases = vec![
            (0, 0.0, "text"),    // Minimum values
            (1, 50.0, "json"),   // Medium values
            (10, 100.0, "html"), // Maximum values
        ];

        for (parallel, threshold, format) in test_cases {
            let result = handle_test_command(
                Some(temp_dir.path().to_path_buf()),
                false,  // No watch mode
                false,  // Not verbose
                None,   // No filter
                false,  // No coverage
                "text", // Coverage format
                parallel,
                threshold,
                format,
            );

            // All parameter combinations should be handled
            assert!(result.is_ok() || result.is_err());
        }
    }
}