rectilinear 0.7.0

use anyhow::Result;
use colored::Colorize;
use std::io::{self, Write};

use crate::config::Config;

pub fn handle_set(key: &str, value: &str) -> Result<()> {
    let mut config = Config::load()?;

    match key {
        "linear-api-key" => config.linear.api_key = Some(value.to_string()),
        "default-team" => config.linear.default_team = Some(value.to_string()),
        "embedding.backend" => {
            config.embedding.backend = match value {
                "local" => crate::config::EmbeddingBackend::Local,
                "api" => crate::config::EmbeddingBackend::Api,
                _ => anyhow::bail!("Invalid backend: {}. Use 'local' or 'api'", value),
            };
        }
        "anthropic-api-key" => config.anthropic.api_key = Some(value.to_string()),
        "embedding.gemini-api-key" => config.embedding.gemini_api_key = Some(value.to_string()),
        "search.default-limit" => {
            config.search.default_limit = value
                .parse()
                .map_err(|_| anyhow::anyhow!("Invalid number"))?;
        }
        "search.duplicate-threshold" => {
            config.search.duplicate_threshold = value
                .parse()
                .map_err(|_| anyhow::anyhow!("Invalid number"))?;
        }
        "triage.mode" => {
            config.triage.mode = match value {
                "native" => crate::config::TriageMode::Native,
                "claude-code" => crate::config::TriageMode::ClaudeCode,
                "codex" => crate::config::TriageMode::Codex,
                _ => anyhow::bail!(
                    "Invalid triage mode: {}. Use 'native', 'claude-code', or 'codex'",
                    value
                ),
            };
        }
        _ => anyhow::bail!("Unknown config key: {}", key),
    }

    config.save()?;
    println!("{} {} = {}", "Set".green(), key, value);
    Ok(())
}

pub fn handle_get(key: &str) -> Result<()> {
    let config = Config::load()?;

    let value = match key {
        "linear-api-key" => config.linear.api_key.map(|k| {
            if k.len() > 8 {
                format!("{}...{}", &k[..4], &k[k.len() - 4..])
            } else {
                "****".to_string()
            }
        }),
        "default-team" => config.linear.default_team,
        "embedding.backend" => Some(format!("{:?}", config.embedding.backend).to_lowercase()),
        "anthropic-api-key" => config.anthropic.api_key.map(|k| {
            if k.len() > 8 {
                format!("{}...{}", &k[..4], &k[k.len() - 4..])
            } else {
                "****".to_string()
            }
        }),
        "embedding.gemini-api-key" => config.embedding.gemini_api_key.map(|k| {
            if k.len() > 8 {
                format!("{}...{}", &k[..4], &k[k.len() - 4..])
            } else {
                "****".to_string()
            }
        }),
        "search.default-limit" => Some(config.search.default_limit.to_string()),
        "search.duplicate-threshold" => Some(config.search.duplicate_threshold.to_string()),
        "triage.mode" => Some(config.triage.mode.to_string()),
        _ => anyhow::bail!("Unknown config key: {}", key),
    };

    match value {
        Some(v) => println!("{}", v),
        None => println!("{}", "(not set)".dimmed()),
    }
    Ok(())
}

pub fn handle_show() -> Result<()> {
    let config = Config::load()?;
    let path = Config::config_path()?;

    println!("{} {}", "Config file:".bold(), path.display());
    println!("{} {}", "Database:".bold(), Config::db_path()?.display());
    println!();

    // Display workspaces if any are configured
    let workspace_names = config.workspace_names();
    if !workspace_names.is_empty() {
        let active = config.resolve_active_workspace().ok();
        println!("{}", "[workspaces]".bold());
        for name in &workspace_names {
            let ws = config.workspace_config(name).ok();
            let is_active = active.as_deref() == Some(name.as_str());
            let marker = if is_active {
                " *".green().bold().to_string()
            } else {
                String::new()
            };
            println!("  {}{}", name.bold(), marker);
            if let Some(ws) = ws {
                println!(
                    "    api-key: {}",
                    ws.api_key
                        .as_ref()
                        .map(|k| mask_key(k))
                        .unwrap_or_else(|| "(not set)".dimmed().to_string())
                );
                println!(
                    "    default-team: {}",
                    ws.default_team
                        .as_deref()
                        .unwrap_or(&"(not set)".dimmed().to_string())
                );
            }
        }
        if let Some(ref dw) = config.default_workspace {
            println!("  default-workspace: {}", dw);
        }
        println!();
    }

    // Show legacy [linear] section if it has values and no workspaces are configured
    if config.workspaces.is_empty() {
        println!("{}", "[linear]".bold());
        println!(
            "  api-key: {}",
            config
                .linear
                .api_key
                .as_ref()
                .map(|k| mask_key(k))
                .unwrap_or_else(|| "(not set)".dimmed().to_string())
        );
        println!(
            "  default-team: {}",
            config
                .linear
                .default_team
                .as_deref()
                .unwrap_or(&"(not set)".dimmed().to_string())
        );
        println!();
    }

    println!("{}", "[anthropic]".bold());
    println!(
        "  api-key: {}",
        config
            .anthropic
            .api_key
            .as_ref()
            .map(|k| mask_key(k))
            .unwrap_or_else(|| "(not set)".dimmed().to_string())
    );

    println!();
    println!("{}", "[embedding]".bold());
    println!(
        "  backend: {}",
        format!("{:?}", config.embedding.backend).to_lowercase()
    );
    println!(
        "  gemini-api-key: {}",
        config
            .embedding
            .gemini_api_key
            .as_ref()
            .map(|k| mask_key(k))
            .unwrap_or_else(|| "(not set)".dimmed().to_string())
    );

    println!();
    println!("{}", "[search]".bold());
    println!("  default-limit: {}", config.search.default_limit);
    println!(
        "  duplicate-threshold: {}",
        config.search.duplicate_threshold
    );

    println!();
    println!("{}", "[triage]".bold());
    println!("  mode: {}", config.triage.mode);

    Ok(())
}

fn mask_key(k: &str) -> String {
    if k.len() > 8 {
        format!("{}...{}", &k[..4], &k[k.len() - 4..])
    } else {
        "****".to_string()
    }
}

pub fn handle_add_workspace() -> Result<()> {
    let mut config = Config::load()?;

    println!("{}", "Add a new workspace".bold());
    println!();

    // 1. Prompt for workspace name
    let name = loop {
        let name = prompt_string("  Workspace name", None)?;
        match name {
            Some(n) if !n.is_empty() => {
                if config.workspaces.contains_key(&n) {
                    println!("  {} Workspace '{}' already exists.", "Error:".red(), n);
                    continue;
                }
                break n;
            }
            _ => {
                println!("  {} Workspace name is required.", "Error:".red());
                continue;
            }
        }
    };

    // 2. Prompt for API key
    let api_key = loop {
        let key = prompt_secret("  Linear API key", None)?;
        match key {
            Some(k) if !k.is_empty() => break k,
            _ => {
                println!("  {} API key is required.", "Error:".red());
                continue;
            }
        }
    };

    // 3. Prompt for default team (optional)
    let default_team = prompt_string("  Default team (optional)", None)?.filter(|t| !t.is_empty());

    // 4. Ask if should be default workspace
    let set_default = prompt_string("  Set as default workspace? (y/N)", Some("N"))?
        .map(|v| v.to_lowercase().starts_with('y'))
        .unwrap_or(false);

    // 5. If legacy [linear] exists and no workspaces yet, migrate it
    if config.workspaces.is_empty() && config.linear.api_key.is_some() {
        println!();
        println!(
            "  {} Migrating existing [linear] config to workspace 'default'.",
            "Note:".cyan()
        );
        config.workspaces.insert(
            "default".to_string(),
            crate::config::WorkspaceConfig {
                api_key: config.linear.api_key.clone(),
                default_team: config.linear.default_team.clone(),
            },
        );
    }

    // 6. Save the new workspace
    config.workspaces.insert(
        name.clone(),
        crate::config::WorkspaceConfig {
            api_key: Some(api_key),
            default_team,
        },
    );

    if set_default {
        config.default_workspace = Some(name.clone());
    }

    config.save()?;

    println!();
    println!("{} Workspace '{}' added.", "Done!".green().bold(), name);
    if set_default {
        println!("  Set as default workspace.");
    }
    println!(
        "  Run {} to sync issues.",
        format!("rectilinear sync --workspace {}", name).cyan()
    );

    Ok(())
}

pub fn handle_remove_workspace(name: &str, db: &crate::db::Database) -> Result<()> {
    let mut config = Config::load()?;

    // 1. Validate workspace exists
    if !config.workspaces.contains_key(name) {
        anyhow::bail!("Workspace '{}' not found in config.", name);
    }

    // 2. Check if it's the active workspace
    let is_active = config.resolve_active_workspace().ok().as_deref() == Some(name);

    if is_active {
        println!(
            "  {} '{}' is the currently active workspace.",
            "Warning:".yellow().bold(),
            name
        );
    }

    // 3. Show what will be deleted and confirm
    let issue_count = db.count_issues(None::<&str>, name).unwrap_or(0);
    println!(
        "  This will remove {} synced issues and all associated data.",
        issue_count.to_string().bold()
    );
    let confirm = prompt_string("  Are you sure? (y/N)", Some("N"))?
        .map(|v| v.to_lowercase().starts_with('y'))
        .unwrap_or(false);
    if !confirm {
        println!("  Cancelled.");
        return Ok(());
    }

    // 4. Purge database data
    let deleted = db.delete_workspace(name)?;
    println!("  Deleted {} issues from database.", deleted);

    // 5. Remove from config
    config.workspaces.remove(name);

    if config.default_workspace.as_deref() == Some(name) {
        config.default_workspace = None;
    }

    config.save()?;

    println!("{} Workspace '{}' removed.", "Done!".green().bold(), name);

    Ok(())
}

pub fn handle_interactive() -> Result<()> {
    let mut config = Config::load()?;
    let path = Config::config_path()?;

    println!(
        "{} {}",
        "Rectilinear configuration".bold(),
        format!("({})", path.display()).dimmed()
    );
    println!(
        "{}",
        "Press Enter to keep current value, or type a new value.".dimmed()
    );
    println!();

    // --- Linear ---
    println!("{}", "[linear]".bold().cyan());

    if let Some(new) = prompt_secret("  api-key", config.linear.api_key.as_deref())? {
        config.linear.api_key = Some(new);
    }

    if let Some(new) = prompt_string("  default-team", config.linear.default_team.as_deref())? {
        config.linear.default_team = if new.is_empty() { None } else { Some(new) };
    }

    println!();

    // --- Anthropic ---
    println!("{}", "[anthropic]".bold().cyan());

    if let Some(new) = prompt_secret("  api-key", config.anthropic.api_key.as_deref())? {
        config.anthropic.api_key = Some(new);
    }

    println!();

    // --- Embedding ---
    println!("{}", "[embedding]".bold().cyan());

    if let Some(new) = prompt_choice(
        "  backend",
        &format!("{:?}", config.embedding.backend).to_lowercase(),
        &["local", "api"],
    )? {
        config.embedding.backend = match new.as_str() {
            "api" => crate::config::EmbeddingBackend::Api,
            _ => crate::config::EmbeddingBackend::Local,
        };
    }

    if let Some(new) = prompt_secret(
        "  gemini-api-key",
        config.embedding.gemini_api_key.as_deref(),
    )? {
        config.embedding.gemini_api_key = Some(new);
    }

    println!();

    // --- Triage ---
    println!("{}", "[triage]".bold().cyan());

    if let Some(new) = prompt_choice(
        "  mode",
        &config.triage.mode.to_string(),
        &["native", "claude-code", "codex"],
    )? {
        config.triage.mode = match new.as_str() {
            "claude-code" => crate::config::TriageMode::ClaudeCode,
            "codex" => crate::config::TriageMode::Codex,
            _ => crate::config::TriageMode::Native,
        };
    }

    println!();

    config.save()?;
    println!("{} Configuration saved.", "Done!".green().bold());
    Ok(())
}

/// Prompt for a regular string value. Returns Some(new_value) if changed, None if kept.
fn prompt_string(label: &str, current: Option<&str>) -> Result<Option<String>> {
    let display = current.unwrap_or("(not set)");
    print!("{}: {} > ", label, display.dimmed());
    io::stdout().flush()?;

    let mut input = String::new();
    io::stdin().read_line(&mut input)?;
    let trimmed = input.trim();

    if trimmed.is_empty() {
        Ok(None)
    } else {
        Ok(Some(trimmed.to_string()))
    }
}

/// Prompt for a secret (API key). Shows masked current value.
fn prompt_secret(label: &str, current: Option<&str>) -> Result<Option<String>> {
    let display = match current {
        Some(k) if k.len() > 8 => format!("{}...{}", &k[..4], &k[k.len() - 4..]),
        Some(_) => "****".to_string(),
        None => "(not set)".to_string(),
    };
    print!("{}: {} > ", label, display.dimmed());
    io::stdout().flush()?;

    let mut input = String::new();
    io::stdin().read_line(&mut input)?;
    let trimmed = input.trim();

    if trimmed.is_empty() {
        Ok(None)
    } else {
        Ok(Some(trimmed.to_string()))
    }
}

/// Prompt for a choice from a fixed set of options. Tab cycles through options.
fn prompt_choice(label: &str, current: &str, options: &[&str]) -> Result<Option<String>> {
    use crossterm::event::{self, Event, KeyCode, KeyEventKind};
    use crossterm::terminal;

    let current_idx = options.iter().position(|o| *o == current).unwrap_or(0);
    let mut selected_idx = current_idx;
    let mut typed = String::new();
    let mut using_tab = false;

    let render = |selected: usize, typed: &str, using_tab: bool| {
        let options_str = options
            .iter()
            .enumerate()
            .map(|(i, o)| {
                if (using_tab && i == selected) || (!using_tab && i == current_idx) {
                    format!("[{}]", o).bold().to_string()
                } else {
                    o.to_string()
                }
            })
            .collect::<Vec<_>>()
            .join("/");

        let input_display = if using_tab {
            options[selected].to_string()
        } else {
            typed.to_string()
        };

        print!("\r\x1b[K{}: {} > {}", label, options_str, input_display);
        io::stdout().flush().ok();
    };

    terminal::enable_raw_mode()?;
    render(selected_idx, &typed, using_tab);

    let result = loop {
        if let Event::Key(key) = event::read()? {
            if key.kind != KeyEventKind::Press {
                continue;
            }
            match key.code {
                KeyCode::Tab | KeyCode::BackTab => {
                    if !using_tab {
                        using_tab = true;
                        typed.clear();
                    }
                    if key.code == KeyCode::BackTab {
                        selected_idx = if selected_idx == 0 {
                            options.len() - 1
                        } else {
                            selected_idx - 1
                        };
                    } else {
                        selected_idx = (selected_idx + 1) % options.len();
                    }
                    render(selected_idx, &typed, using_tab);
                }
                KeyCode::Enter => {
                    // Disable raw mode before printing so \n includes \r
                    terminal::disable_raw_mode()?;
                    println!();
                    if using_tab {
                        if selected_idx == current_idx {
                            break None;
                        } else {
                            break Some(options[selected_idx].to_string());
                        }
                    } else if typed.is_empty() {
                        break None;
                    } else if options.contains(&typed.as_str()) {
                        break Some(typed);
                    } else {
                        eprintln!(
                            "  {} Invalid choice '{}', keeping '{}'",
                            "Warning:".yellow(),
                            typed,
                            current
                        );
                        break None;
                    }
                }
                KeyCode::Char(c) => {
                    if using_tab {
                        using_tab = false;
                        selected_idx = current_idx;
                    }
                    typed.push(c);
                    render(selected_idx, &typed, using_tab);
                }
                KeyCode::Backspace => {
                    if using_tab {
                        using_tab = false;
                        selected_idx = current_idx;
                    }
                    typed.pop();
                    render(selected_idx, &typed, using_tab);
                }
                KeyCode::Esc => {
                    terminal::disable_raw_mode()?;
                    println!();
                    break None;
                }
                _ => {}
            }
        }
    };

    // Ensure raw mode is off (no-op if already disabled above)
    let _ = terminal::disable_raw_mode();
    Ok(result)
}