scud-cli 1.67.0

use anyhow::Result;
use colored::Colorize;
use dialoguer::{Confirm, Input, MultiSelect, Select};
use std::fs;
use std::path::PathBuf;

use crate::backpressure::BackpressureConfig;
use crate::commands::config as config_cmd;
use crate::commands::helpers::is_interactive;
use crate::config::{Config, LLMConfig};
use crate::storage::Storage;

/// Helper function to configure provider and model for a specific tier
fn configure_provider_and_model(tier: &str) -> Result<(String, String)> {
    let providers = vec![
        "Claude Code (recommended - no API key needed)",
        "Cursor Agent CLI (no API key needed)",
        "OpenAI Codex CLI (no API key needed)",
        "xAI (Grok)",
        "Anthropic API key (ANTHROPIC_API_KEY)",
        "Anthropic OAuth (Claude Code login - no API key needed)",
        "OpenAI (GPT API)",
        "OpenRouter",
    ];
    let provider_selection = Select::new()
        .with_prompt(format!("Select {} LLM provider", tier))
        .items(&providers)
        .default(if tier == "fast" { 3 } else { 0 }) // Default xAI for fast, Claude for smart
        .interact()?;

    let provider = match provider_selection {
        0 => "claude-cli",
        1 => "cursor",
        2 => "codex",
        3 => "xai",
        4 => "anthropic",
        5 => "anthropic-oauth",
        6 => "openai",
        7 => "openrouter",
        _ => "claude-cli",
    };

    // Build model options: suggested models + "Custom" option
    let suggested = Config::suggested_models_for_provider(provider);
    let mut model_options: Vec<String> = suggested.iter().map(|s| s.to_string()).collect();
    model_options.push("Custom (enter model name)".to_string());

    let default_model_index = if tier == "fast" && provider == "xai" {
        suggested
            .iter()
            .position(|m| *m == "xai/grok-code-fast-1")
            .unwrap_or(0)
    } else if tier == "smart" && provider == "claude-cli" {
        suggested.iter().position(|m| *m == "opus").unwrap_or(0)
    } else {
        0
    };

    let model_selection = Select::new()
        .with_prompt(format!(
            "Select {} model (or choose Custom to enter any model)",
            tier
        ))
        .items(&model_options)
        .default(default_model_index)
        .interact()?;

    let model = if model_selection == model_options.len() - 1 {
        // User selected "Custom"
        Input::<String>::new()
            .with_prompt("Enter model name")
            .interact_text()?
    } else {
        suggested[model_selection].to_string()
    };

    Ok((provider.to_string(), model))
}

/// Interactive backpressure configuration during init
fn configure_backpressure_interactive(storage: &Storage) -> Result<()> {
    println!();
    println!(
        "{}",
        "=== VALIDATION COMMANDS (BACKPRESSURE) ===".yellow().bold()
    );
    println!(
        "{}",
        "Backpressure runs validation commands between task waves".dimmed()
    );
    println!("{}", "to catch build/test failures early.".dimmed());
    println!();

    // Get auto-detected commands
    let auto_config = BackpressureConfig::load(Some(&storage.project_root().to_path_buf()))?;

    if !auto_config.commands.is_empty() {
        println!("{}", "Auto-detected commands:".blue());
        for cmd in &auto_config.commands {
            println!("  {} {}", "·".green(), cmd);
        }
        println!();
    }

    let options = vec![
        "Use auto-detect (recommended)",
        "Configure custom commands",
        "Skip (configure later with: scud config backpressure)",
    ];

    let selection = Select::new()
        .with_prompt("How would you like to configure validation?")
        .items(&options)
        .default(0)
        .interact()?;

    match selection {
        0 => {
            // Auto-detect - nothing to save, that's the default
            if auto_config.commands.is_empty() {
                println!(
                    "{}",
                    "  ⚠ No project type detected - add commands later with: scud config backpressure".yellow()
                );
            } else {
                println!("{}", "  ✓ Using auto-detected commands".green());
            }
        }
        1 => {
            // Custom configuration
            let commands = configure_backpressure_commands(&auto_config.commands)?;
            save_backpressure_config(storage, &commands)?;
            println!("{}", "  ✓ Custom backpressure commands saved".green());
        }
        2 => {
            // Skip
            println!(
                "{}",
                "  Skipped - configure later with: scud config backpressure".dimmed()
            );
        }
        _ => {}
    }

    Ok(())
}

/// Configure custom backpressure commands interactively
fn configure_backpressure_commands(auto_detected: &[String]) -> Result<Vec<String>> {
    println!();
    println!("{}", "Common validation commands:".blue());

    // Build a list of common commands based on what might be useful
    let mut suggestions: Vec<(&str, bool)> = vec![
        ("cargo build", false),
        ("cargo build --release", false),
        ("cargo test", false),
        ("cargo clippy -- -D warnings", false),
        ("cargo fmt --check", false),
        ("npm run build", false),
        ("npm test", false),
        ("npm run lint", false),
        ("npm run typecheck", false),
        ("go build ./...", false),
        ("go test ./...", false),
        ("pytest", false),
        ("python -m mypy .", false),
    ];

    // Mark auto-detected as selected by default
    for (cmd, selected) in &mut suggestions {
        if auto_detected.contains(&cmd.to_string()) {
            *selected = true;
        }
    }

    let items: Vec<&str> = suggestions.iter().map(|(cmd, _)| *cmd).collect();
    let defaults: Vec<bool> = suggestions.iter().map(|(_, selected)| *selected).collect();

    let selections = MultiSelect::new()
        .with_prompt("Select commands to run (space to toggle, enter to confirm)")
        .items(&items)
        .defaults(&defaults)
        .interact()?;

    let mut commands: Vec<String> = selections.iter().map(|&i| items[i].to_string()).collect();

    // Allow adding custom commands
    loop {
        let add_custom = Confirm::new()
            .with_prompt("Add a custom command?")
            .default(false)
            .interact()?;

        if !add_custom {
            break;
        }

        let custom: String = Input::new().with_prompt("Enter command").interact_text()?;

        if !custom.trim().is_empty() {
            commands.push(custom.trim().to_string());
            println!("  {} Added: {}", "✓".green(), custom.trim());
        }
    }

    if commands.is_empty() {
        println!(
            "{}",
            "  No commands selected - backpressure will be skipped".yellow()
        );
    } else {
        println!();
        println!("{}", "Selected commands:".blue());
        for (i, cmd) in commands.iter().enumerate() {
            println!("  {}. {}", i + 1, cmd.green());
        }
    }

    Ok(commands)
}

/// Save backpressure configuration to config file
fn save_backpressure_config(storage: &Storage, commands: &[String]) -> Result<()> {
    let config_path = storage.config_file();

    // Load existing config
    let content = fs::read_to_string(&config_path).unwrap_or_default();
    let mut config: toml::Value =
        toml::from_str(&content).unwrap_or(toml::Value::Table(toml::map::Map::new()));

    let table = config.as_table_mut().expect("Config must be a table");

    // Ensure swarm section exists
    if !table.contains_key("swarm") {
        table.insert(
            "swarm".to_string(),
            toml::Value::Table(toml::map::Map::new()),
        );
    }

    let swarm = table.get_mut("swarm").unwrap().as_table_mut().unwrap();

    // Create backpressure section
    let mut bp = toml::map::Map::new();
    let cmd_array: Vec<toml::Value> = commands
        .iter()
        .map(|s| toml::Value::String(s.clone()))
        .collect();
    bp.insert("commands".to_string(), toml::Value::Array(cmd_array));
    bp.insert("stop_on_failure".to_string(), toml::Value::Boolean(true));
    bp.insert("timeout_secs".to_string(), toml::Value::Integer(300));

    swarm.insert("backpressure".to_string(), toml::Value::Table(bp));

    // Save
    let output = toml::to_string_pretty(&config)?;
    fs::write(&config_path, output)?;

    Ok(())
}

pub fn run(project_root: Option<PathBuf>, provider_arg: Option<String>) -> Result<()> {
    let storage = Storage::new(project_root);

    if storage.is_initialized() {
        println!("{}", "✓ SCUD is already initialized".green());
        return Ok(());
    }

    println!("{}", "Initializing SCUD...".blue());
    println!();

    let (provider, model, smart_provider, smart_model, fast_provider, fast_model) = if let Some(
        provider_name,
    ) =
        provider_arg
    {
        // Non-interactive mode with command-line argument - use defaults for all tiers
        let provider = provider_name.to_lowercase();
        if !matches!(
            provider.as_str(),
            "xai"
                | "anthropic"
                | "anthropic-oauth"
                | "openai"
                | "openrouter"
                | "claude-cli"
                | "codex"
                | "cursor"
        ) {
            anyhow::bail!(
                "Invalid provider: {}. Valid options: claude-cli, cursor, codex, xai, anthropic, anthropic-oauth, openai, openrouter",
                provider
            );
        }
        let model = Config::default_model_for_provider(&provider).to_string();
        // Use defaults for smart/fast from Config (respects env vars)
        let defaults = Config::default();
        (
            provider,
            model,
            defaults.llm.smart_provider,
            defaults.llm.smart_model,
            defaults.llm.fast_provider,
            defaults.llm.fast_model,
        )
    } else if is_interactive() {
        println!(
            "{}",
            "SCUD supports separate models for different types of tasks:".blue()
        );
        println!("  • Fast models: Quick coding, generation tasks");
        println!("  • Smart models: Complex reasoning, analysis, validation");
        println!();

        // Configure FAST model/provider
        println!("{}", "=== FAST MODEL CONFIGURATION ===".yellow().bold());
        let (fast_provider, fast_model) = configure_provider_and_model("fast")?;

        // Configure SMART model/provider
        println!();
        println!("{}", "=== SMART MODEL CONFIGURATION ===".yellow().bold());
        let (smart_provider, smart_model) = configure_provider_and_model("smart")?;

        // Use fast provider/model as defaults for backward compatibility
        let provider = fast_provider.clone();
        let model = fast_model.clone();

        (
            provider,
            model,
            smart_provider,
            smart_model,
            fast_provider,
            fast_model,
        )
    } else {
        // Non-interactive without provider arg: use defaults from Config (respects env vars)
        let defaults = Config::default();
        (
            defaults.llm.provider,
            defaults.llm.model,
            defaults.llm.smart_provider,
            defaults.llm.smart_model,
            defaults.llm.fast_provider,
            defaults.llm.fast_model,
        )
    };

    let config = Config {
        llm: LLMConfig {
            provider,
            model,
            smart_provider,
            smart_model,
            fast_provider,
            fast_model,
            max_tokens: 16000,
        },
        swarm: crate::config::SwarmConfig::default(),
    };

    storage.initialize_with_config(&config)?;

    // Interactive backpressure configuration
    if is_interactive() {
        configure_backpressure_interactive(&storage)?;
    }

    println!("\n{}", "SCUD initialized successfully!".green().bold());

    // Auto-install all agents and commands
    println!("\n{}", "Installing SCUD agents and commands...".blue());
    if let Err(e) = config_cmd::agents_add(Some(storage.project_root().to_path_buf()), None, true) {
        println!("{}", format!("  Could not install agents: {}", e).yellow());
        println!("  You can install them later with: scud config agents add --all");
    }

    // Install spawn agents (harness/model routing definitions)
    println!("\n{}", "Installing spawn agent definitions...".blue());
    if let Err(e) = config_cmd::spawn_agents_add(
        Some(storage.project_root().to_path_buf()),
        None,
        true,
        false,
    ) {
        println!(
            "{}",
            format!("  Could not install spawn agents: {}", e).yellow()
        );
        println!("  You can install them later with: scud config spawn-agents add --all");
    } else {
        // Update spawn agents to match the configured providers/models
        if let Err(e) =
            config_cmd::spawn_agents_update_from_config(Some(storage.project_root().to_path_buf()))
        {
            println!(
                "{}",
                format!("  Could not update spawn agents: {}", e).yellow()
            );
        }
    }

    // Update CLAUDE.md with SCUD instructions
    if let Err(e) = update_claude_md(&storage) {
        println!(
            "{}",
            format!("  Could not update CLAUDE.md: {}", e).yellow()
        );
    }

    println!("\n{}", "Configuration:".blue());
    println!(
        "  Default Provider: {} ({})",
        config.llm.provider.yellow(),
        config.llm.model.yellow()
    );
    println!(
        "  Fast Provider: {} ({})",
        config.llm.fast_provider.yellow(),
        config.llm.fast_model.yellow()
    );
    println!(
        "  Smart Provider: {} ({})",
        config.llm.smart_provider.yellow(),
        config.llm.smart_model.yellow()
    );
    if config.requires_api_key() {
        println!("\n{}", "Environment variables required:".blue());
        let mut env_vars = std::collections::HashSet::new();
        env_vars.insert(config.api_key_env_var());
        if config.llm.fast_provider != config.llm.provider {
            env_vars.insert(Config::api_key_env_var_for_provider(
                &config.llm.fast_provider,
            ));
        }
        if config.llm.smart_provider != config.llm.provider
            && config.llm.smart_provider != config.llm.fast_provider
        {
            env_vars.insert(Config::api_key_env_var_for_provider(
                &config.llm.smart_provider,
            ));
        }
        for env_var in env_vars {
            if env_var != "NONE" {
                println!("  export {}=your-api-key", env_var.yellow());
            }
        }
    } else {
        println!("\n{}", "No API keys required (using CLI tools)".green());
    }
    println!("\n{}", "Next steps:".blue());
    println!("  1. Set your API key environment variable");
    println!("  2. Run: scud tags");
    println!("  3. Create or import tasks, then use: /scud:next\n");

    Ok(())
}

/// Update CLAUDE.md with SCUD instructions
fn update_claude_md(storage: &Storage) -> Result<()> {
    let claude_md_path = storage.project_root().join("CLAUDE.md");

    let scud_section = r#"
## SCUD Task Management

This project uses SCUD for AI-driven task management.

### Quick Start
- `scud tags` - List available phases
- `scud next` - Find next available task
- `scud set-status <id> in-progress` - Claim a task
- `scud view` - Open interactive task viewer

### Slash Commands
Use `/scud:` commands in Claude Code for task operations.
"#;

    let marker = "## SCUD Task Management";

    if claude_md_path.exists() {
        let content = fs::read_to_string(&claude_md_path)?;
        if content.contains(marker) {
            return Ok(()); // Already has SCUD section
        }
        // Append to existing file
        let new_content = format!("{}\n{}", content.trim_end(), scud_section);
        fs::write(&claude_md_path, new_content)?;
    } else {
        // Create new file
        fs::write(&claude_md_path, scud_section.trim_start())?;
    }

    println!("  {} Updated CLAUDE.md with SCUD instructions", "✓".green());
    Ok(())
}