/home/noah/src/ruchy/src/bin/handlers/mod.rs

Source
use anyhow::{Context, Result};

mod commands;
mod handlers_modules;
use ruchy::{Parser as RuchyParser, Transpiler};
use ruchy::frontend::ast::Expr;
use ruchy::runtime::Repl;
use ruchy::runtime::replay_converter::ConversionConfig;
// Replay functionality imports removed - not needed in handler, used directly in REPL
use std::fs;
use std::io::{self, Read};
use std::path::{Path, PathBuf};

/// Handle eval command - evaluate a one-liner expression with -e flag
/// 
/// # Arguments
/// * `expr` - The expression to evaluate
/// * `verbose` - Enable verbose output
/// * `format` - Output format ("json" or default text)
/// 
/// # Examples
/// ```
/// // This function is typically called by the CLI with parsed arguments
/// // handle_eval_command("2 + 2", false, "text");
/// ```
/// 
/// # Errors
/// Returns error if expression cannot be parsed or evaluated
pub fn handle_eval_command(expr: &str, verbose: bool, format: &str) -> Result<()> {
    if verbose {
        eprintln!("Parsing expression: {expr}");
    }

    let mut repl = Repl::new()?;
    match repl.eval(expr) {
        Ok(result) => {
            if verbose {
                eprintln!("Evaluation successful");
            }

            if format == "json" {
                // Manually construct JSON to ensure field order matches test expectations
                let result_str = result.replace('"', "\\\"");
                println!("{{\"success\":true,\"result\":\"{result_str}\"}}");
            } else {
                // Default text output - always show result for one-liner evaluation
                println!("{result}");
            }
            Ok(())
        }
        Err(e) => {
            if verbose {
                eprintln!("Evaluation failed: {e}");
            }

            match format {
                "json" => {
                    println!(
                        "{}",
                        serde_json::json!({
                            "success": false,
                            "error": e.to_string()
                        })
                    );
                }
                _ => {
                    eprintln!("Error: {e}");
                }
            }
            std::process::exit(1);
        }
    }
}

/// Handle file execution - run a Ruchy script file directly (not via subcommand)
/// 
/// # Arguments
/// * `file` - Path to the Ruchy file to execute
/// 
/// # Examples
/// ```
/// // This function is typically called by the CLI
/// // handle_file_execution(&Path::new("script.ruchy"));
/// ```
/// 
/// # Errors
/// Returns error if file cannot be read, parsed, or executed
pub fn handle_file_execution(file: &Path) -> Result<()> {
    let source = fs::read_to_string(file)
        .with_context(|| format!("Failed to read file: {}", file.display()))?;

    // Use REPL to evaluate the file
    let mut repl = Repl::new()?;
    match repl.eval(&source) {
        Ok(result) => {
            // Only print non-unit results
            if result != "Unit" && result != "()" {
                println!("{result}");
            }
            Ok(())
        }
        Err(e) => {
            eprintln!("Error: {e}");
            std::process::exit(1);
        }
    }
}

/// Handle stdin/piped input - evaluate input from standard input
/// 
/// # Arguments
/// * `input` - The input string to evaluate
/// 
/// # Examples
/// ```
/// // This function is typically called when input is piped to the CLI
/// // handle_stdin_input("2 + 2");
/// ```
/// 
/// # Errors
/// Returns error if input cannot be parsed or evaluated
pub fn handle_stdin_input(input: &str) -> Result<()> {
    let mut repl = Repl::new()?;
    match repl.eval(input) {
        Ok(result) => {
            println!("{result}");
            Ok(())
        }
        Err(e) => {
            eprintln!("Error: {e}");
            std::process::exit(1);
        }
    }
}

/// Handle parse command - show AST for a Ruchy file
pub fn handle_parse_command(file: &Path, verbose: bool) -> Result<()> {
    if verbose {
        eprintln!("Parsing file: {}", file.display());
    }
    
    let source = fs::read_to_string(file)
        .with_context(|| format!("Failed to read file: {}", file.display()))?;
    
    let mut parser = RuchyParser::new(&source);
    match parser.parse() {
        Ok(ast) => {
            println!("{ast:#?}");
            Ok(())
        }
        Err(e) => {
            eprintln!("Parse error: {e}");
            std::process::exit(1);
        }
    }
}

/// Handle transpile command - convert Ruchy to Rust
pub fn handle_transpile_command(
    file: &Path, 
    output: Option<&Path>, 
    minimal: bool,
    verbose: bool
) -> Result<()> {
    log_transpile_start(file, minimal, verbose);
    
    let source = read_source_file(file, verbose)?;
    let ast = parse_source(&source)?;
    let rust_code = transpile_ast(&ast, minimal)?;
    
    write_output(&rust_code, output, verbose)?;
    Ok(())
}

/// Log transpilation start (complexity: 3)
fn log_transpile_start(file: &Path, minimal: bool, verbose: bool) {
    if !verbose {
        return;
    }
    eprintln!("Transpiling file: {}", file.display());
    if minimal {
        eprintln!("Using minimal codegen for self-hosting");
    }
}

/// Read source from file or stdin (complexity: 5)
fn read_source_file(file: &Path, verbose: bool) -> Result<String> {
    if file.as_os_str() == "-" {
        if verbose {
            eprintln!("Reading from stdin...");
        }
        let mut input = String::new();
        io::stdin().read_to_string(&mut input)?;
        Ok(input)
    } else {
        fs::read_to_string(file)
            .with_context(|| format!("Failed to read file: {}", file.display()))
    }
}

/// Parse source code to AST (complexity: 2)
fn parse_source(source: &str) -> Result<Expr> {
    let mut parser = RuchyParser::new(source);
    parser.parse()
        .with_context(|| "Failed to parse input")
}

/// Transpile AST to Rust code (complexity: 4)
fn transpile_ast(ast: &Expr, minimal: bool) -> Result<String> {
    let mut transpiler = Transpiler::new();
    if minimal {
        transpiler.transpile_minimal(ast)
            .with_context(|| "Failed to transpile to Rust (minimal)")
    } else {
        transpiler.transpile_to_program(ast)
            .map(|tokens| tokens.to_string())
            .with_context(|| "Failed to transpile to Rust")
    }
}

/// Write output to file or stdout (complexity: 5)
fn write_output(rust_code: &str, output: Option<&Path>, verbose: bool) -> Result<()> {
    if let Some(output_path) = output {
        fs::write(output_path, rust_code)
            .with_context(|| format!("Failed to write output file: {}", output_path.display()))?;
        if verbose {
            eprintln!("Output written to: {}", output_path.display());
        }
    } else {
        print!("{rust_code}");
    }
    Ok(())
}

/// Handle run command - compile and execute a Ruchy file
pub fn handle_run_command(file: &Path, verbose: bool) -> Result<()> {
    log_run_start(file, verbose);
    
    // Parse and transpile
    let source = fs::read_to_string(file)
        .with_context(|| format!("Failed to read file: {}", file.display()))?;
    let ast = parse_source(&source)?;
    let rust_code = transpile_for_execution(&ast, file)?;
    
    // Compile and execute
    let (temp_source, binary_path) = prepare_compilation(&rust_code, verbose)?;
    compile_rust_code(temp_source.path(), &binary_path)?;
    execute_binary(&binary_path)?;
    
    Ok(())
}

/// Log run command start (complexity: 2)
fn log_run_start(file: &Path, verbose: bool) {
    if verbose {
        eprintln!("Running file: {}", file.display());
    }
}

/// Transpile AST for execution with context (complexity: 3)
fn transpile_for_execution(ast: &Expr, file: &Path) -> Result<String> {
    let transpiler = Transpiler::new();
    transpiler.transpile_to_program_with_context(ast, Some(file))
        .map(|tokens| tokens.to_string())
        .with_context(|| "Failed to transpile to Rust")
}

/// Prepare compilation artifacts (complexity: 4)
fn prepare_compilation(rust_code: &str, verbose: bool) -> Result<(tempfile::NamedTempFile, PathBuf)> {
    let temp_source = tempfile::NamedTempFile::new()
        .with_context(|| "Failed to create temporary file")?;
    fs::write(temp_source.path(), rust_code)
        .with_context(|| "Failed to write temporary file")?;
    
    if verbose {
        eprintln!("Temporary Rust file: {}", temp_source.path().display());
        eprintln!("Compiling and running...");
    }
    
    // Create unique binary path using process ID for temporary compilation output
    let binary_path = std::env::temp_dir().join(format!("ruchy_temp_bin_{}", std::process::id()));
    
    Ok((temp_source, binary_path))
}

/// Compile Rust code using rustc (complexity: 5)
fn compile_rust_code(source_path: &Path, binary_path: &Path) -> Result<()> {
    let output = std::process::Command::new("rustc")
        .arg("--edition=2021")
        .arg("--crate-name=ruchy_temp")
        .arg("-o")
        .arg(binary_path)
        .arg(source_path)
        .output()
        .with_context(|| "Failed to run rustc")?;
    
    if !output.status.success() {
        eprintln!("Compilation failed:");
        eprintln!("{}", String::from_utf8_lossy(&output.stderr));
        std::process::exit(1);
    }
    
    Ok(())
}

/// Execute compiled binary and handle output (complexity: 5)
fn execute_binary(binary_path: &Path) -> Result<()> {
    let run_output = std::process::Command::new(binary_path)
        .output()
        .with_context(|| "Failed to run compiled binary")?;
    
    print!("{}", String::from_utf8_lossy(&run_output.stdout));
    if !run_output.stderr.is_empty() {
        eprint!("{}", String::from_utf8_lossy(&run_output.stderr));
    }
    
    if !run_output.status.success() {
        std::process::exit(run_output.status.code().unwrap_or(1));
    }
    
    Ok(())
}

/// Handle interactive theorem prover (RUCHY-0820) - delegated to refactored module
pub fn handle_prove_command(
    file: Option<&std::path::Path>,
    backend: &str,
    ml_suggestions: bool,
    timeout: u64,
    script: Option<&std::path::Path>,
    export: Option<&std::path::Path>,
    check: bool,
    counterexample: bool,
    verbose: bool,
    format: &str,
) -> anyhow::Result<()> {
    // Delegate to refactored module with ≤10 complexity
    handlers_modules::prove::handle_prove_command(
        file,
        backend,
        ml_suggestions,
        timeout,
        script,
        export,
        check,
        counterexample,
        verbose,
        format,
    )
}

/// Print prover help - moved to separate function for clarity
fn print_prover_help() {
    println!("\nInteractive Prover Commands:");
    println!("  help          - Show this help message");
    println!("  quit/exit     - Exit the prover");
    println!("  goals         - Show current proof goals");
    println!("  tactics       - List available tactics");
    println!("  goal <stmt>   - Add a new proof goal");
    println!("  apply <tactic> - Apply a tactic to current goal");
    println!("\nTactics:");
    println!("  intro         - Introduce hypothesis from implication");
    println!("  split         - Split conjunction into subgoals");
    println!("  induction     - Proof by induction");
    println!("  contradiction - Proof by contradiction");
    println!("  reflexivity   - Prove equality by reflexivity");
    println!("  simplify      - Simplify expression");
    println!("  assumption    - Prove using an assumption");
    println!("\nExamples:");
    println!("  goal x > 0 -> x + 1 > 1");
    println!("  apply intro");
    println!("  apply simplify\n");
}

/// Handle REPL command - start the interactive Read-Eval-Print Loop
/// 
/// # Examples
/// ```
/// // This function is typically called when no command or when repl command is specified
/// // handle_repl_command();
/// ```
/// 
/// # Errors
/// Returns error if REPL fails to initialize or run
pub fn handle_repl_command(record_file: Option<PathBuf>) -> Result<()> {
    use colored::Colorize;
    
    let version_msg = format!("Welcome to Ruchy REPL v{}", env!("CARGO_PKG_VERSION"));
    println!("{}", version_msg.bright_cyan().bold());
    println!(
        "Type {} for commands, {} to exit\n",
        ":help".green(),
        ":quit".yellow()
    );

    let mut repl = Repl::new()?;
    
    if let Some(record_path) = record_file {
        repl.run_with_recording(&record_path)
    } else {
        repl.run()
    }
}

/// Handle compile command - compile Ruchy file to native binary
/// 
/// # Arguments
/// * `file` - Path to the Ruchy file to compile
/// * `output` - Output binary path
/// * `opt_level` - Optimization level (0, 1, 2, 3, s, z)
/// * `strip` - Strip debug symbols
/// * `static_link` - Use static linking
/// * `target` - Target triple for cross-compilation
/// 
/// # Examples
/// ```
/// // This function is typically called by the CLI compile command
/// // handle_compile_command(&Path::new("app.ruchy"), PathBuf::from("app"), "2".to_string(), true, false, None);
/// ```
/// 
/// # Errors
/// Returns error if compilation fails or rustc is not available
pub fn handle_compile_command(
    file: &Path,
    output: PathBuf,
    opt_level: String,
    strip: bool,
    static_link: bool,
    target: Option<String>,
) -> Result<()> {
    use ruchy::backend::{CompileOptions, compile_to_binary as backend_compile};
    use colored::Colorize;
    use std::fs;
    
    // Check if rustc is available
    if let Err(e) = ruchy::backend::compiler::check_rustc_available() {
        eprintln!("{} {}", "Error:".bright_red(), e);
        eprintln!("Please install Rust toolchain from https://rustup.rs/");
        std::process::exit(1);
    }
    
    println!("{} Compiling {}...", "→".bright_blue(), file.display());
    
    let options = CompileOptions {
        output,
        opt_level,
        strip,
        static_link,
        target,
        rustc_flags: Vec::new(),
    };
    
    match backend_compile(file, &options) {
        Ok(binary_path) => {
            println!(
                "{} Successfully compiled to: {}",
                "✓".bright_green(),
                binary_path.display()
            );
            
            // Make the binary executable on Unix
            #[cfg(unix)]
            {
                use std::os::unix::fs::PermissionsExt;
                let mut perms = fs::metadata(&binary_path)?.permissions();
                perms.set_mode(0o755);
                fs::set_permissions(&binary_path, perms)?;
            }
            
            println!(
                "{} Binary size: {} bytes",
                "ℹ".bright_blue(),
                fs::metadata(&binary_path)?.len()
            );
        }
        Err(e) => {
            eprintln!("{} Compilation failed: {}", "✗".bright_red(), e);
            std::process::exit(1);
        }
    }
    
    Ok(())
}

/// Handle check command - check syntax of a Ruchy file
/// 
/// # Arguments
/// * `file` - Path to the Ruchy file to check
/// * `watch` - Enable file watching mode
/// 
/// # Examples
/// ```
/// // This function is typically called by the CLI check command
/// // handle_check_command(&Path::new("script.ruchy"), false);
/// ```
/// 
/// # Errors
/// Returns error if file cannot be read or has syntax errors
pub fn handle_check_command(file: &Path, watch: bool) -> Result<()> {
    if watch {
        handle_watch_and_check(file)
    } else {
        handle_check_syntax(file)
    }
}

/// Check syntax of a single file
fn handle_check_syntax(file: &Path) -> Result<()> {
    use colored::Colorize;
    
    let source = fs::read_to_string(file)?;
    let mut parser = RuchyParser::new(&source);
    match parser.parse() {
        Ok(_) => {
            println!("{}", "✓ Syntax is valid".green());
            Ok(())
        }
        Err(e) => {
            eprintln!("{}", format!("✗ Syntax error: {e}").red());
            std::process::exit(1);
        }
    }
}

/// Watch a file and check syntax on changes
fn handle_watch_and_check(file: &Path) -> Result<()> {
    use colored::Colorize;
    use std::thread;
    use std::time::Duration;
    
    println!(
        "{} Watching {} for changes...",
        "👁".bright_cyan(),
        file.display()
    );
    println!("Press Ctrl+C to stop watching\n");

    // Initial check
    handle_check_syntax(file)?;

    // Simple file watching using polling
    let mut last_modified = fs::metadata(file)?.modified()?;

    loop {
        thread::sleep(Duration::from_millis(500));

        let Ok(metadata) = fs::metadata(file) else {
            continue; // File might be temporarily unavailable
        };

        let Ok(modified) = metadata.modified() else {
            continue;
        };

        if modified != last_modified {
            last_modified = modified;
            println!("\n{} File changed, checking...", "→".bright_cyan());
            let _ = handle_check_syntax(file); // Don't exit on error, keep watching
        }
    }
}

/// Handle test command - run tests with various options (delegated to refactored module)
/// 
/// # Arguments
/// * `path` - Optional path to test directory
/// * `watch` - Enable watch mode
/// * `verbose` - Enable verbose output
/// * `filter` - Optional test filter
/// * `coverage` - Enable coverage reporting
/// * `coverage_format` - Coverage report format
/// * `parallel` - Number of parallel test threads
/// * `threshold` - Coverage threshold
/// * `format` - Output format
/// 
/// # Examples
/// ```
/// // This function is typically called by the CLI test command
/// // handle_test_command(None, false, false, None, false, &"text".to_string(), 1, 80.0, &"text".to_string());
/// ```
/// 
/// # Errors
/// Returns error if tests fail to run or coverage threshold is not met
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<()> {
    // Delegate to refactored module with ≤10 complexity
    handlers_modules::test::handle_test_command(
        path,
        watch,
        verbose,
        filter,
        coverage,
        coverage_format,
        parallel,
        threshold,
        format,
    )
}

/// Handle the coverage command - generate coverage report for Ruchy code
///
/// # Arguments
/// * `path` - File or directory path to analyze
/// * `threshold` - Coverage threshold to check against  
/// * `format` - Output format (text, html, json)
/// * `verbose` - Enable verbose output
///
/// # Errors
/// Returns error if coverage analysis fails or threshold is not met
pub fn handle_coverage_command(
    path: &Path,
    threshold: f64,
    format: &str,
    verbose: bool,
) -> Result<()> {
    use ruchy::quality::ruchy_coverage::RuchyCoverageCollector;
    
    if verbose {
        println!("🔍 Analyzing coverage for: {}", path.display());
        println!("📊 Threshold: {:.1}%", threshold);
        println!("📋 Format: {}", format);
    }

    // Create coverage collector
    let mut collector = RuchyCoverageCollector::new();
    
    // Execute the file with coverage collection
    collector.execute_with_coverage(path)?;
    
    // Generate the coverage report based on format
    let report = match format {
        "html" => collector.generate_html_report(),
        "json" => collector.generate_json_report(),
        _ => collector.generate_text_report(), // Default to text
    };
    println!("{}", report);
    
    // Check threshold if specified
    if threshold > 0.0 {
        if collector.meets_threshold(threshold) {
            println!("\n✅ Coverage meets threshold of {:.1}%", threshold);
        } else {
            eprintln!("\n❌ Coverage below threshold of {:.1}%", threshold);
            std::process::exit(1);
        }
    }
    
    Ok(())
}

/// Watch and run tests on changes - delegated to refactored module
fn handle_watch_and_test(path: &Path, verbose: bool, filter: Option<&str>) -> Result<()> {
    handlers_modules::test::handle_test_command(
        Some(path.to_path_buf()),
        true, // watch mode
        verbose,
        filter,
        false, // coverage
        "text",
        1,
        0.0,
        "text",
    )
}

/// Run enhanced tests - delegated to refactored module
#[allow(clippy::unnecessary_wraps)]
fn handle_run_enhanced_tests(
    path: &Path,
    verbose: bool,
    filter: Option<&str>,
    coverage: bool,
    coverage_format: &str,
    parallel: usize,
    threshold: f64,
    format: &str,
) -> Result<()> {
    handlers_modules::test::handle_test_command(
        Some(path.to_path_buf()),
        false, // not watch mode
        verbose,
        filter,
        coverage,
        coverage_format,
        parallel,
        threshold,
        format,
    )
}

/// Run a single .ruchy test file - delegated to `test_helpers` module
fn run_ruchy_test_file(test_file: &Path, verbose: bool) -> Result<()> {
    handlers_modules::test_helpers::run_test_file(test_file, verbose)
}

/// Verify proofs extracted from AST - delegated to `prove_helpers` module
fn verify_proofs_from_ast(
    ast: &ruchy::frontend::ast::Expr, 
    file_path: &std::path::Path, 
    format: &str,
    counterexample: bool, 
    verbose: bool
) -> Result<()> {
    handlers_modules::prove_helpers::verify_proofs_from_ast(
        ast,
        file_path,
        format,
        counterexample,
        verbose,
    )
}
/// 
/// # Arguments
/// * `command` - The command to execute
/// 
/// # Examples
/// ```
/// // This function is typically called by the main dispatcher for complex commands
/// ```
/// 
/// # Errors
/// Returns error if command execution fails
#[allow(clippy::unnecessary_wraps)]
pub fn handle_complex_command(command: crate::Commands) -> Result<()> {
    match command {
        crate::Commands::Ast { 
            file, 
            json, 
            graph, 
            metrics, 
            symbols, 
            deps, 
            verbose, 
            output 
        } => {
            commands::handle_ast_command(
                &file,
                json,
                graph,
                metrics,
                symbols,
                deps,
                verbose,
                output.as_deref(),
            )
        }
        crate::Commands::Provability { 
            file, 
            verify, 
            contracts, 
            invariants, 
            termination, 
            bounds, 
            verbose, 
            output 
        } => {
            commands::handle_provability_command(
                &file,
                verify,
                contracts,
                invariants,
                termination,
                bounds,
                verbose,
                output.as_deref(),
            )
        }
        crate::Commands::Runtime { 
            file, 
            profile, 
            bigo, 
            bench, 
            compare, 
            memory, 
            verbose, 
            output 
        } => {
            commands::handle_runtime_command(
                &file,
                profile,
                bigo,
                bench,
                compare.as_deref(),
                memory,
                verbose,
                output.as_deref(),
            )
        }
        crate::Commands::Score {
            path,
            depth,
            fast,
            deep,
            watch,
            explain,
            baseline,
            min,
            config,
            format,
            verbose,
            output,
        } => {
            commands::handle_score_command(
                &path,
                &depth,
                fast,
                deep,
                watch,
                explain,
                baseline.as_deref(),
                min,
                config.as_deref(),
                &format,
                verbose,
                output.as_deref(),
            )
        }
        crate::Commands::QualityGate {
            path,
            config,
            depth: _,
            fail_fast,
            format,
            export,
            ci: _,
            verbose,
        } => {
            // Simplified quality gate handling
            commands::handle_quality_gate_command(
                &path,
                config.as_deref(),
                fail_fast,    // Use as strict
                !verbose,     // Use as quiet
                format == "json",
                verbose,
                None,         // No output field
                export.as_deref(),
            )
        }
        crate::Commands::Fmt {
            file,
            all,
            check,
            stdout,
            diff,
            config,
            line_width: _,
            indent: _,
            use_tabs: _,
        } => {
            // Simplified fmt handling
            commands::handle_fmt_command(
                &file,
                check,
                !check && !stdout,  // write if not check or stdout
                config.as_deref(),
                all,
                diff,
                stdout,
                false,  // verbose not available
            )
        }
        crate::Commands::Lint {
            file,
            all: _,
            fix,
            strict,
            verbose,
            format,
            rules,
            deny_warnings: _,
            max_complexity: _,
            config,
            init_config,
        } => {
            if init_config {
                // Create default lint config
                println!("Creating default lint configuration...");
                Ok(())
            } else if let Some(file_path) = file {
                commands::handle_lint_command(
                    &file_path,
                    fix,
                    strict,
                    rules.as_deref(),
                    format == "json",
                    verbose,
                    None,  // ignore not available
                    config.as_deref(),
                )
            } else {
                eprintln!("Error: Either provide a file or use --all flag");
                std::process::exit(1);
            }
        }
        crate::Commands::Prove {
            file,
            backend,
            ml_suggestions,
            timeout,
            script,
            export,
            check,
            counterexample,
            verbose,
            format,
        } => {
            handle_prove_command(
                file.as_deref(),
                &backend,
                ml_suggestions,
                timeout,
                script.as_deref(),
                export.as_deref(),
                check,
                counterexample,
                verbose,
                &format,
            )
        }
        crate::Commands::Coverage { path, threshold, format, verbose } => {
            handle_coverage_command(&path, threshold.unwrap_or(80.0), &format, verbose)
        }
        crate::Commands::ReplayToTests { input, output, property_tests, benchmarks, timeout } => {
            handle_replay_to_tests_command(&input, output.as_deref(), property_tests, benchmarks, timeout)
        }
        _ => {
            // Other commands not yet implemented
            eprintln!("Command not yet implemented");
            Ok(())
        }
    }
    
    /*
    // Original complex command handling - commented out until handlers implemented
    match command {
        crate::Commands::Ast { 
            file, 
            json, 
            graph, 
            metrics, 
            symbols, 
            deps, 
            verbose, 
            output 
        } => {
            // AST analysis implementation planned
            eprintln!("AST analysis not yet implemented");
            Ok(())
        }
        crate::Commands::Provability { 
            file, 
            verify, 
            contracts, 
            invariants, 
            termination, 
            bounds, 
            verbose, 
            output 
        } => {
            // Provability analysis implementation planned
            eprintln!("Provability analysis not yet implemented");
            Ok(())
        }
        crate::Commands::Runtime { 
            file, 
            profile, 
            bigo, 
            bench, 
            compare, 
            memory, 
            verbose, 
            output 
        } => {
            // Runtime analysis implementation planned
            eprintln!("Runtime analysis not yet implemented");
            Ok(())
        }
        crate::Commands::Score {
            path,
            depth,
            fast,
            deep,
            watch,
            explain,
            baseline,
            min,
            config,
            format,
            verbose,
            output,
        } => {
            let baseline_str = baseline.as_deref();
            let config_str = config.as_ref().and_then(|p| p.to_str());
            let output_str = output.as_ref().and_then(|p| p.to_str());
            // Quality score calculation implementation planned
            eprintln!("Quality score calculation not yet implemented");
            Ok(())
        }
        crate::Commands::QualityGate {
            path,
            config,
            depth,
            fail_fast,
            format,
            export,
            ci,
            verbose,
        } => {
            // Quality gates implementation planned
            eprintln!("Quality gates enforcement not yet implemented");
            Ok(())
        }
        crate::Commands::Fmt {
            file: _,
            all: _,
            check: _,
            stdout: _,
            diff: _,
            config: _,
            line_width: _,
            indent: _,
            use_tabs: _,
        } => {
            // Code formatting implementation planned
            eprintln!("Code formatting not yet implemented");
            Ok(())
        }
        crate::Commands::Doc {
            path,
            output,
            format,
            private,
            open,
            all,
            verbose,
        } => {
            // Documentation generation implementation planned
            eprintln!("Documentation generation not yet implemented");
            Ok(())
        }
        crate::Commands::Bench {
            file,
            iterations,
            warmup,
            format,
            output,
            verbose,
        } => {
            crate::benchmark_ruchy_code(
                &file,
                iterations,
                warmup,
                &format,
                output.as_deref(),
                verbose,
            )
        }
        crate::Commands::Lint {
            file,
            all: _,
            fix,
            strict,
            verbose,
            format,
            rules,
            deny_warnings: _,
            max_complexity: _,
            config,
            init_config,
        } => {
            if init_config {
                crate::generate_default_lint_config()
            } else {
                // Load custom rules if config provided
                let custom_rules = if let Some(config_path) = config {
                    crate::load_custom_lint_rules(&config_path)?
                } else {
                    // Custom lint rules implementation planned
                    Default::default()
                };

                if all {
                    crate::lint_ruchy_code(
                        &PathBuf::from("."),
                        all,
                        fix,
                        strict,
                        verbose,
                        &format,
                        rules.as_deref(),
                        deny_warnings,
                        max_complexity,
                        &custom_rules,
                    )
                } else if let Some(file) = file {
                    crate::lint_ruchy_code(
                        &file,
                        false,
                        fix,
                        strict,
                        verbose,
                        &format,
                        rules.as_deref(),
                        deny_warnings,
                        max_complexity,
                        &custom_rules,
                    )
                } else {
                    eprintln!("Error: Either provide a file or use --all flag");
                    std::process::exit(1);
                }
            }
        }
        crate::Commands::Add {
            package,
            version,
            dev,
            registry,
        } => {
            crate::add_package(&package, version.as_deref(), dev, &registry)
        }
        crate::Commands::Publish {
            registry,
            version,
            dry_run,
            allow_dirty,
        } => {
            crate::publish_package(&registry, version.as_deref(), dry_run, allow_dirty)
        }
        crate::Commands::Mcp {
            name,
            streaming,
            timeout,
            min_score,
            max_complexity,
            verbose,
            config,
        } => {
            let config_str = config.as_ref().and_then(|p| p.to_str());
            crate::start_mcp_server(&name, streaming, timeout, min_score, max_complexity, verbose, config_str)
        }
        crate::Commands::Optimize {
            file,
            hardware,
            depth,
            cache,
            branches,
            vectorization,
            abstractions,
            benchmark,
            format,
            output,
            verbose,
            threshold,
        } => {
            crate::optimize_file(
                &file,
                &hardware,
                &depth,
                cache,
                branches,
                vectorization,
                abstractions,
                benchmark,
                &format,
                output.as_deref(),
                verbose,
                threshold,
            )
        }
        crate::Commands::ActorObserve {
            config,
            refresh_interval,
            max_traces,
            max_actors,
            enable_deadlock_detection,
            deadlock_interval,
            start_mode,
            no_color,
            format,
            export,
            duration,
            verbose,
            filter_actor,
            filter_failed,
            filter_slow,
        } => {
            crate::start_actor_observatory(
                config.as_ref(),
                refresh_interval,
                max_traces,
                max_actors,
                enable_deadlock_detection,
                deadlock_interval,
                &start_mode,
                !no_color,
                &format,
                export.as_ref(),
                duration,
                verbose,
                filter_actor.as_ref(),
                filter_failed,
                filter_slow,
            )
        }
        crate::Commands::DataflowDebug {
            config,
            max_rows,
            auto_materialize,
            enable_profiling,
            timeout,
            track_memory,
            compute_diffs,
            sample_rate,
            refresh_interval,
            no_color,
            format,
            export,
            verbose,
            breakpoint,
            start_mode,
        } => {
            crate::start_dataflow_debugger(
                config.as_ref(),
                max_rows,
                auto_materialize,
                enable_profiling,
                timeout,
                track_memory,
                compute_diffs,
                sample_rate,
                refresh_interval,
                !no_color,
                &format,
                export.as_ref(),
                verbose,
                &breakpoint,
                &start_mode,
            )
        }
        crate::Commands::Wasm { 
            file,
            output,
            target,
            wit,
            deploy,
            deploy_target,
            portability,
            opt_level,
            debug,
            simd,
            threads,
            component_model,
            name,
            version,
            verbose,
        } => {
            crate::handle_wasm_command(
                &file,
                output.as_deref(),
                &target,
                wit,
                deploy,
                deploy_target.as_deref(),
                portability,
                &opt_level,
                debug,
                simd,
                threads,
                component_model,
                name.as_deref(),
                &version,
                verbose,
            )
        }
        _ => {
            // This should not be reached since handled commands are processed elsewhere
            eprintln!("Error: Command not implemented in complex handler");
            std::process::exit(1);
        }
    }
    */
}

/// Handle replay-to-tests command - convert .replay files to regression tests
/// 
/// # Arguments
/// * `input` - Input replay file or directory containing .replay files
/// * `output` - Optional output test file path
/// * `property_tests` - Whether to include property tests
/// * `benchmarks` - Whether to include benchmarks
/// * `timeout` - Test timeout in milliseconds
/// 
/// # Examples
/// ```
/// // Convert single replay file
/// handle_replay_to_tests_command(Path::new("demo.replay"), None, true, false, 5000);
/// 
/// // Convert directory of replay files
/// handle_replay_to_tests_command(Path::new("demos/"), Some(Path::new("tests/replays.rs")), true, true, 10000);
/// ```
/// 
/// # Errors
/// Returns error if replay files can't be read or test files can't be written

/// Setup conversion configuration for replay-to-test conversion (complexity: 4)
fn setup_conversion_config(property_tests: bool, benchmarks: bool, timeout: u64) -> ConversionConfig {
    ConversionConfig {
        test_module_prefix: "replay_generated".to_string(),
        include_property_tests: property_tests,
        include_benchmarks: benchmarks,
        timeout_ms: timeout,
    }
}

/// Determine output path, using default if none provided (complexity: 3)
fn determine_output_path(output: Option<&Path>) -> &Path {
    let default_output = Path::new("tests/generated_from_replays.rs");
    output.unwrap_or(default_output)
}

/// Validate that file has .replay extension (complexity: 3)
fn validate_replay_file(path: &Path) -> Result<()> {
    if path.extension().and_then(|s| s.to_str()) == Some("replay") {
        Ok(())
    } else {
        eprintln!("❌ Input file must have .replay extension");
        Err(anyhow::anyhow!("Invalid file extension"))
    }
}

/// Process a single .replay file (complexity: 8)
fn process_single_file(
    input: &Path, 
    converter: &ruchy::runtime::replay_converter::ReplayConverter,
    all_tests: &mut Vec<ruchy::runtime::replay_converter::GeneratedTest>,
    processed_files: &mut usize
) -> Result<()> {
    
    
    validate_replay_file(input)?;
    
    println!("📄 Processing replay file: {}", input.display());
    
    match converter.convert_file(input) {
        Ok(tests) => {
            println!("  ✅ Generated {} tests", tests.len());
            all_tests.extend(tests);
            *processed_files += 1;
            Ok(())
        }
        Err(e) => {
            eprintln!("  ❌ Failed to process {}: {}", input.display(), e);
            Err(e)
        }
    }
}

/// Process directory containing .replay files (complexity: 10)
fn process_directory(
    input: &Path,
    converter: &ruchy::runtime::replay_converter::ReplayConverter, 
    all_tests: &mut Vec<ruchy::runtime::replay_converter::GeneratedTest>,
    processed_files: &mut usize
) -> Result<()> {
    
    use std::fs;
    
    println!("📁 Processing replay directory: {}", input.display());
    
    // Find all .replay files in directory
    let replay_files: Vec<_> = fs::read_dir(input)?
        .filter_map(|entry| {
            let entry = entry.ok()?;
            let path = entry.path();
            if path.is_file() && path.extension()? == "replay" {
                Some(path)
            } else {
                None
            }
        })
        .collect();
    
    if replay_files.is_empty() {
        println!("⚠️  No .replay files found in directory");
        return Ok(());
    }
    
    println!("🔍 Found {} replay files", replay_files.len());
    
    for replay_file in replay_files {
        println!("📄 Processing: {}", replay_file.display());
        
        match converter.convert_file(&replay_file) {
            Ok(tests) => {
                println!("  ✅ Generated {} tests", tests.len());
                all_tests.extend(tests);
                *processed_files += 1;
            }
            Err(e) => {
                eprintln!("  ⚠️  Failed to process {}: {}", replay_file.display(), e);
                // Continue with other files instead of failing completely
            }
        }
    }
    
    Ok(())
}

/// Write test output to file, creating directories if needed (complexity: 4)
fn write_test_output(
    converter: &ruchy::runtime::replay_converter::ReplayConverter,
    all_tests: &[ruchy::runtime::replay_converter::GeneratedTest],
    output_path: &Path
) -> Result<()> {
    use std::fs;
    use anyhow::Context;
    
    // Create output directory if needed
    if let Some(parent) = output_path.parent() {
        fs::create_dir_all(parent)?;
    }
    
    println!("📝 Writing tests to: {}", output_path.display());
    
    converter.write_tests(all_tests, output_path)
        .context("Failed to write test file")?;
    
    Ok(())
}

/// Generate comprehensive summary report of conversion results (complexity: 8)
fn generate_summary_report(
    all_tests: &[ruchy::runtime::replay_converter::GeneratedTest],
    processed_files: usize
) {
    use colored::Colorize;
    use std::collections::{HashMap, HashSet};
    
    println!("\n{}", "🎉 Conversion Summary".bright_green().bold());
    println!("=====================================");
    println!("📊 Files processed: {}", processed_files);
    println!("✅ Tests generated: {}", all_tests.len());
    
    // Breakdown by test category
    let mut category_counts = HashMap::new();
    let mut coverage_areas = HashSet::new();
    
    for test in all_tests {
        *category_counts.entry(&test.category).or_insert(0) += 1;
        coverage_areas.extend(test.coverage_areas.iter().cloned());
    }
    
    println!("\n📋 Test Breakdown:");
    for (category, count) in category_counts {
        println!("   {:?}: {}", category, count);
    }
    
    println!("\n🎯 Coverage Areas: {} unique areas", coverage_areas.len());
    if !coverage_areas.is_empty() {
        let mut areas: Vec<_> = coverage_areas.into_iter().collect();
        areas.sort();
        for area in areas.iter().take(10) {  // Show first 10
            println!("   • {}", area);
        }
        if areas.len() > 10 {
            println!("   ... and {} more", areas.len() - 10);
        }
    }
    
    println!("\n💡 Next Steps:");
    println!("   1. Run tests: cargo test");
    println!("   2. Measure coverage: cargo test -- --test-threads=1");
    println!("   3. Validate replay determinism");
    
    println!("\n🚀 {}", "Replay-to-test conversion complete!".bright_green());
}

/// Process input path (file or directory) with replay files (complexity: 5)
fn process_input_path(
    input: &Path,
    converter: &ruchy::runtime::replay_converter::ReplayConverter,
    all_tests: &mut Vec<ruchy::runtime::replay_converter::GeneratedTest>,
    processed_files: &mut usize
) -> Result<()> {
    if input.is_file() {
        process_single_file(input, converter, all_tests, processed_files)
    } else if input.is_dir() {
        process_directory(input, converter, all_tests, processed_files)
    } else {
        eprintln!("❌ Input path must be a file or directory");
        Err(anyhow::anyhow!("Invalid input path"))
    }
}

/// Convert REPL replay files to regression tests (complexity: 7)
pub fn handle_replay_to_tests_command(
    input: &Path,
    output: Option<&Path>,
    property_tests: bool,
    benchmarks: bool,
    timeout: u64,
) -> Result<()> {
    use colored::Colorize;
    use ruchy::runtime::replay_converter::ReplayConverter;
    
    println!("{}", "🔄 Converting REPL replay files to regression tests".bright_cyan().bold());
    println!("Input: {}", input.display());
    
    let config = setup_conversion_config(property_tests, benchmarks, timeout);
    let converter = ReplayConverter::with_config(config);
    let mut all_tests = Vec::new();
    let mut processed_files = 0;
    
    let output_path = determine_output_path(output);
    
    process_input_path(input, &converter, &mut all_tests, &mut processed_files)?;
    
    if all_tests.is_empty() {
        println!("⚠️  No tests generated");
        return Ok(());
    }
    
    write_test_output(&converter, &all_tests, output_path)?;
    generate_summary_report(&all_tests, processed_files);
    
    Ok(())
}

Coverage Report

Created: 2025-09-08 21:26