kimun 0.34.3

//! Knowledge maps: code ownership analysis via git blame.
//!
//! Identifies bus factor risk by analyzing who owns each file's code.
//! Risk levels: Critical (one person >80%), High (60-80%), Medium
//! (2-3 people >80% combined), Low (well-distributed). Generated
//! files (lock files, minified JS) are automatically excluded.

pub mod analyzer;
mod report;

use std::cmp::Reverse;
use std::error::Error;

use crate::git::GitRepo;
use crate::util::{is_generated, parse_since};
use crate::walk::{self, WalkConfig};

use crate::cli::OutputMode;
use crate::report_helpers;
use analyzer::{FileOwnership, aggregate_by_author, compute_bus_factor, compute_ownership};
use report::{
    print_bus_factor_json, print_bus_factor_report, print_bus_factor_short, print_bus_factor_terse,
    print_json, print_report, print_short, print_summary_json, print_summary_report,
    print_summary_short, print_summary_terse, print_terse,
};

/// Options for knowledge map analysis.
pub struct KnowledgeOptions<'a> {
    pub output: OutputMode,
    pub top: usize,
    pub sort_by: &'a str,
    pub since: Option<&'a str>,
    pub risk_only: bool,
    pub summary: bool,
    pub bus_factor: bool,
    /// Filter to files owned by this author (case-insensitive substring match).
    pub author: Option<&'a str>,
}

/// Sort file ownership results by the given sort key.
/// "diffusion" sorts by contributor count, "risk" by risk level then ownership,
/// and anything else (default "concentration") by highest ownership percentage first.
fn sort_results(results: &mut [FileOwnership], sort_by: &str) {
    match sort_by {
        "diffusion" => results.sort_by_key(|r| Reverse(r.contributors)),
        "risk" => results.sort_by(|a, b| {
            a.risk.sort_key().cmp(&b.risk.sort_key()).then_with(|| {
                b.ownership_pct
                    .partial_cmp(&a.ownership_pct)
                    .unwrap_or(std::cmp::Ordering::Equal)
            })
        }),
        _ => {
            // concentration: highest ownership % first
            results.sort_by(|a, b| {
                b.ownership_pct
                    .partial_cmp(&a.ownership_pct)
                    .unwrap_or(std::cmp::Ordering::Equal)
            });
        }
    }
}

/// Run knowledge map analysis: walk source files, blame each one,
/// compute ownership concentration and risk, then output results.
pub fn run(cfg: &WalkConfig<'_>, opts: &KnowledgeOptions<'_>) -> Result<(), Box<dyn Error>> {
    let git_repo = GitRepo::open(cfg.path)
        .map_err(|e| format!("not a git repository (or any parent): {e}"))?;

    let since_ts = opts.since.map(parse_since).transpose()?;

    // Collect recent authors (for knowledge loss detection)
    let recent_authors = if since_ts.is_some() {
        git_repo.recent_authors(since_ts)?
    } else {
        std::collections::HashSet::new()
    };

    let (walk_root, walk_prefix) = git_repo.walk_prefix(cfg.path)?;

    let mut results: Vec<FileOwnership> = Vec::new();
    // author name → total blame lines across all files (for bus factor)
    let mut author_lines: std::collections::HashMap<String, usize> =
        std::collections::HashMap::new();

    for (file_path, spec) in walk::source_files(&walk_root, cfg.exclude_tests(), cfg.filter) {
        if is_generated(&file_path) {
            continue;
        }

        let rel_path = GitRepo::to_git_path(&walk_root, &walk_prefix, &file_path);

        // Run blame
        let blames = match git_repo.blame_file(&rel_path) {
            Ok(b) => b,
            Err(e) => {
                eprintln!("warning: blame {}: {e}", rel_path.display());
                continue;
            }
        };

        // Accumulate raw blame lines for bus factor computation.
        for b in &blames {
            *author_lines.entry(b.author.clone()).or_insert(0) += b.lines;
        }

        let ownership = compute_ownership(rel_path, spec.name, &blames, &recent_authors);
        results.push(ownership);
    }

    // Filter by author if requested (case-insensitive substring match on name or email)
    if let Some(author_filter) = opts.author {
        let lower = author_filter.to_lowercase();
        results.retain(|f| {
            f.primary_owner.to_lowercase().contains(&lower)
                || f.primary_email.to_lowercase().contains(&lower)
        });
    }

    // Filter risk-only if requested
    if opts.risk_only {
        results.retain(|f| f.knowledge_loss);
    }

    sort_results(&mut results, opts.sort_by);

    if opts.bus_factor {
        let bf = compute_bus_factor(&author_lines, 80.0);
        return match opts.output {
            OutputMode::Json => print_bus_factor_json(&bf),
            OutputMode::Short => {
                print_bus_factor_short(&bf);
                Ok(())
            }
            OutputMode::Terse => {
                print_bus_factor_terse(&bf);
                Ok(())
            }
            OutputMode::Github | OutputMode::Codeclimate => {
                Err(crate::cli::ERR_CI_FORMAT_ONLY.into())
            }
            OutputMode::Table => {
                print_bus_factor_report(&bf);
                Ok(())
            }
        };
    }

    if opts.summary {
        let mut authors = aggregate_by_author(&results);
        // In summary mode sort_by maps: concentration→files owned, diffusion→lines, risk→worst risk
        match opts.sort_by {
            "diffusion" => authors.sort_by_key(|a| Reverse(a.total_lines)),
            "risk" => authors.sort_by_key(|a| a.worst_risk.sort_key()),
            _ => authors.sort_by_key(|a| Reverse(a.files_owned)),
        }
        let limit = opts.top.min(authors.len());
        let authors = &authors[..limit];
        match opts.output {
            OutputMode::Json => print_summary_json(authors),
            OutputMode::Short => {
                print_summary_short(authors);
                Ok(())
            }
            OutputMode::Terse => {
                print_summary_terse(authors);
                Ok(())
            }
            OutputMode::Github | OutputMode::Codeclimate => {
                Err(crate::cli::ERR_CI_FORMAT_ONLY.into())
            }
            OutputMode::Table => {
                print_summary_report(authors);
                Ok(())
            }
        }
    } else {
        report_helpers::output_results(
            &mut results,
            opts.top,
            opts.output,
            print_json,
            print_report,
            print_short,
            print_terse,
        )
    }
}

#[cfg(test)]
#[path = "mod_test.rs"]
mod tests;