rustqual 0.5.5

use std::collections::HashMap;

use syn::spanned::Spanned;
use syn::visit::Visit;

use crate::config::sections::DuplicatesConfig;

/// Maximum entries per hash group before skipping pairwise comparison.
const MAX_WINDOW_GROUP_SIZE: usize = 50;

// ── Result types ────────────────────────────────────────────────

/// A group of matching code fragments across different functions.
#[derive(Debug, Clone)]
pub struct FragmentGroup {
    pub entries: Vec<FragmentEntry>,
    pub statement_count: usize,
    pub suppressed: bool,
}

/// An individual fragment location within a function.
#[derive(Debug, Clone)]
pub struct FragmentEntry {
    pub function_name: String,
    pub qualified_name: String,
    pub file: String,
    pub start_line: usize,
    pub end_line: usize,
}

// ── Internal types ──────────────────────────────────────────────

/// Metadata for a function whose body was scanned for fragments.
struct FnInfo {
    name: String,
    qualified_name: String,
    file: String,
    /// (start_line, end_line) for each top-level statement in the body.
    stmt_lines: Vec<(usize, usize)>,
}

/// A hashed window of consecutive statements within a function.
struct WindowEntry {
    fn_idx: usize,
    stmt_start: usize,
    hash: u64,
}

/// A matched pair of windows in two different functions.
struct PairMatch {
    fn_a: usize,
    fn_b: usize,
    stmt_a: usize,
    stmt_b: usize,
}

// ── Detection API ───────────────────────────────────────────────

/// Detect duplicate code fragments across parsed files.
/// Integration: orchestrates window collection, pair matching, and fragment merging.
pub fn detect_fragments(
    parsed: &[(String, String, syn::File)],
    config: &DuplicatesConfig,
) -> Vec<FragmentGroup> {
    let (fn_infos, windows) = collect_all_windows(parsed, config);
    let pairs = extract_matching_pairs(&windows);
    merge_into_fragments(pairs, &fn_infos, config.min_statements)
}

// ── Window collection ───────────────────────────────────────────

/// Collect all statement windows from all functions in parsed files.
/// Trivial: creates visitor and delegates to visit_all_files.
fn collect_all_windows(
    parsed: &[(String, String, syn::File)],
    config: &DuplicatesConfig,
) -> (Vec<FnInfo>, Vec<WindowEntry>) {
    let mut collector = FragmentCollector {
        config,
        file: String::new(),
        fn_infos: Vec::new(),
        windows: Vec::new(),
        in_test: false,
        parent_type: None,
        is_trait_impl: false,
    };
    super::visit_all_files(parsed, &mut collector);
    (collector.fn_infos, collector.windows)
}

// ── Pair matching ───────────────────────────────────────────────

/// Group windows by hash and extract cross-function matching pairs.
/// Operation: hash grouping + pair extraction logic, no own calls.
fn extract_matching_pairs(windows: &[WindowEntry]) -> Vec<PairMatch> {
    let mut by_hash: HashMap<u64, Vec<usize>> = HashMap::new();
    for (i, w) in windows.iter().enumerate() {
        by_hash.entry(w.hash).or_default().push(i);
    }

    let mut pairs = Vec::new();
    for indices in by_hash.values() {
        if indices.len() < 2 || indices.len() > MAX_WINDOW_GROUP_SIZE {
            continue;
        }
        for i in 0..indices.len() {
            for j in (i + 1)..indices.len() {
                let wa = &windows[indices[i]];
                let wb = &windows[indices[j]];
                if wa.fn_idx != wb.fn_idx {
                    pairs.push(PairMatch {
                        fn_a: wa.fn_idx,
                        fn_b: wb.fn_idx,
                        stmt_a: wa.stmt_start,
                        stmt_b: wb.stmt_start,
                    });
                }
            }
        }
    }
    pairs
}

// ── Fragment merging ────────────────────────────────────────────

/// Merge adjacent pair matches into maximal fragment groups.
/// Operation: sorting + interval merging logic, no own calls.
// qual:allow(complexity) reason: "interval merging algorithm with nested loops"
fn merge_into_fragments(
    mut pairs: Vec<PairMatch>,
    fn_infos: &[FnInfo],
    window_size: usize,
) -> Vec<FragmentGroup> {
    if pairs.is_empty() {
        return vec![];
    }

    // Canonical ordering: smaller fn_idx first in each pair
    for p in &mut pairs {
        if p.fn_a > p.fn_b {
            std::mem::swap(&mut p.fn_a, &mut p.fn_b);
            std::mem::swap(&mut p.stmt_a, &mut p.stmt_b);
        }
    }
    pairs.sort_unstable_by_key(|p| (p.fn_a, p.fn_b, p.stmt_a, p.stmt_b));
    pairs.dedup_by_key(|p| (p.fn_a, p.fn_b, p.stmt_a, p.stmt_b));

    let mut result = Vec::new();
    let mut i = 0;
    while i < pairs.len() {
        let fa = pairs[i].fn_a;
        let fb = pairs[i].fn_b;

        // Find end of this function pair's matches
        let mut j = i;
        while j < pairs.len() && pairs[j].fn_a == fa && pairs[j].fn_b == fb {
            j += 1;
        }

        // Merge consecutive matches: stmt_a and stmt_b both increment by 1
        let pair_slice = &pairs[i..j];
        let mut k = 0;
        while k < pair_slice.len() {
            let mut end = k;
            while end + 1 < pair_slice.len()
                && pair_slice[end + 1].stmt_a == pair_slice[end].stmt_a + 1
                && pair_slice[end + 1].stmt_b == pair_slice[end].stmt_b + 1
            {
                end += 1;
            }

            let stmt_count = end - k + window_size;
            let start_a = pair_slice[k].stmt_a;
            let end_a = start_a + stmt_count - 1;
            let start_b = pair_slice[k].stmt_b;
            let end_b = start_b + stmt_count - 1;

            // Look up actual source line numbers from fn_infos
            let line_a_start = fn_infos[fa].stmt_lines.get(start_a).map_or(0, |l| l.0);
            let line_a_end = fn_infos[fa]
                .stmt_lines
                .get(end_a)
                .map_or(line_a_start, |l| l.1);
            let line_b_start = fn_infos[fb].stmt_lines.get(start_b).map_or(0, |l| l.0);
            let line_b_end = fn_infos[fb]
                .stmt_lines
                .get(end_b)
                .map_or(line_b_start, |l| l.1);

            result.push(FragmentGroup {
                entries: vec![
                    FragmentEntry {
                        function_name: fn_infos[fa].name.clone(),
                        qualified_name: fn_infos[fa].qualified_name.clone(),
                        file: fn_infos[fa].file.clone(),
                        start_line: line_a_start,
                        end_line: line_a_end,
                    },
                    FragmentEntry {
                        function_name: fn_infos[fb].name.clone(),
                        qualified_name: fn_infos[fb].qualified_name.clone(),
                        file: fn_infos[fb].file.clone(),
                        start_line: line_b_start,
                        end_line: line_b_end,
                    },
                ],
                statement_count: stmt_count,
                suppressed: false,
            });

            k = end + 1;
        }

        i = j;
    }
    result
}

// ── FragmentCollector (AST visitor) ─────────────────────────────

/// AST visitor that collects statement windows from all function bodies.
struct FragmentCollector<'a> {
    config: &'a DuplicatesConfig,
    file: String,
    fn_infos: Vec<FnInfo>,
    windows: Vec<WindowEntry>,
    in_test: bool,
    parent_type: Option<String>,
    is_trait_impl: bool,
}

impl super::FileVisitor for FragmentCollector<'_> {
    fn reset_for_file(&mut self, file_path: &str) {
        self.file = file_path.to_string();
        self.in_test = false;
        self.parent_type = None;
        self.is_trait_impl = false;
    }
}

impl FragmentCollector<'_> {
    /// Process a function body: record fn_info and extract statement windows.
    /// Operation: window extraction logic; normalize/hash calls hidden in closure.
    fn process_body(&mut self, name: &str, body: &syn::Block, is_test_fn: bool) {
        let is_test = self.in_test || is_test_fn;
        if self.config.ignore_tests && is_test {
            return;
        }
        if self.config.ignore_trait_impls && self.is_trait_impl {
            return;
        }

        let window_size = self.config.min_statements;
        if body.stmts.len() < window_size {
            return;
        }

        let stmt_lines: Vec<(usize, usize)> = body
            .stmts
            .iter()
            .map(|s| (s.span().start().line, s.span().end().line))
            .collect();

        let qualified_name = self
            .parent_type
            .as_ref()
            .map(|p| format!("{p}::{name}"))
            .unwrap_or_else(|| name.to_string());

        let fn_idx = self.fn_infos.len();
        self.fn_infos.push(FnInfo {
            name: name.to_string(),
            qualified_name,
            file: self.file.clone(),
            stmt_lines,
        });

        // Closure hides own calls to normalize_stmts/structural_hash (lenient mode)
        let compute_hash = |stmts: &[syn::Stmt]| {
            let tokens = crate::normalize::normalize_stmts(stmts);
            let hash = crate::normalize::structural_hash(&tokens);
            (tokens.len(), hash)
        };

        let min_tokens = self.config.min_tokens;
        for i in 0..=body.stmts.len() - window_size {
            let window_stmts = &body.stmts[i..i + window_size];
            let (token_count, hash) = compute_hash(window_stmts);
            if token_count >= min_tokens {
                self.windows.push(WindowEntry {
                    fn_idx,
                    stmt_start: i,
                    hash,
                });
            }
        }
    }
}

impl<'ast> Visit<'ast> for FragmentCollector<'_> {
    fn visit_item_fn(&mut self, node: &'ast syn::ItemFn) {
        let name = node.sig.ident.to_string();
        let is_test = super::has_test_attr(&node.attrs);
        self.process_body(&name, &node.block, is_test);
        syn::visit::visit_item_fn(self, node);
    }

    fn visit_item_impl(&mut self, node: &'ast syn::ItemImpl) {
        let prev_parent = self.parent_type.take();
        let prev_is_trait = self.is_trait_impl;

        self.is_trait_impl = node.trait_.is_some();
        if let syn::Type::Path(tp) = &*node.self_ty {
            if let Some(seg) = tp.path.segments.last() {
                self.parent_type = Some(seg.ident.to_string());
            }
        }

        syn::visit::visit_item_impl(self, node);

        self.parent_type = prev_parent;
        self.is_trait_impl = prev_is_trait;
    }

    fn visit_impl_item_fn(&mut self, node: &'ast syn::ImplItemFn) {
        let name = node.sig.ident.to_string();
        let is_test = super::has_test_attr(&node.attrs);
        self.process_body(&name, &node.block, is_test);
    }

    fn visit_item_mod(&mut self, node: &'ast syn::ItemMod) {
        let prev_in_test = self.in_test;
        if super::has_cfg_test(&node.attrs) {
            self.in_test = true;
        }
        syn::visit::visit_item_mod(self, node);
        self.in_test = prev_in_test;
    }
}

#[cfg(test)]
mod tests {
    use super::*;

    fn parse(code: &str) -> Vec<(String, String, syn::File)> {
        let syntax = syn::parse_file(code).expect("parse failed");
        vec![("test.rs".to_string(), code.to_string(), syntax)]
    }

    fn parse_multi(files: &[(&str, &str)]) -> Vec<(String, String, syn::File)> {
        files
            .iter()
            .map(|(name, code)| {
                let syntax = syn::parse_file(code).expect("parse failed");
                (name.to_string(), code.to_string(), syntax)
            })
            .collect()
    }

    const TEST_MIN_TOKENS: usize = 3;
    const TEST_MIN_STATEMENTS: usize = 3;

    fn low_threshold_config() -> DuplicatesConfig {
        DuplicatesConfig {
            min_tokens: TEST_MIN_TOKENS,
            min_lines: 1,
            min_statements: TEST_MIN_STATEMENTS,
            ..DuplicatesConfig::default()
        }
    }

    #[test]
    fn test_detect_fragments_empty() {
        let parsed = parse("");
        let config = low_threshold_config();
        let groups = detect_fragments(&parsed, &config);
        assert!(groups.is_empty());
    }

    #[test]
    fn test_detect_fragments_no_match() {
        let parsed = parse_multi(&[
            (
                "a.rs",
                r#"
                fn foo() {
                    let x = 1;
                    let y = x + 2;
                    let z = y * x;
                }
            "#,
            ),
            (
                "b.rs",
                r#"
                fn bar() {
                    let a = "hello";
                    let b = a.len();
                    if b > 0 { return; }
                }
            "#,
            ),
        ]);
        let config = low_threshold_config();
        let groups = detect_fragments(&parsed, &config);
        assert!(groups.is_empty(), "Different structures should not match");
    }

    #[test]
    fn test_detect_fragments_matching_statements() {
        let parsed = parse_multi(&[
            (
                "a.rs",
                r#"
                fn foo() {
                    let x = 1;
                    let y = x + 2;
                    let z = y * x;
                }
            "#,
            ),
            (
                "b.rs",
                r#"
                fn bar() {
                    let a = 1;
                    let b = a + 2;
                    let c = b * a;
                }
            "#,
            ),
        ]);
        let config = low_threshold_config();
        let groups = detect_fragments(&parsed, &config);
        assert!(!groups.is_empty(), "Should detect matching fragment");
        assert_eq!(groups[0].entries.len(), 2);
    }

    #[test]
    fn test_detect_fragments_cross_file() {
        let parsed = parse_multi(&[
            (
                "module_a.rs",
                r#"
                fn process_a() {
                    let x = 1;
                    let y = x + 2;
                    let z = y * x;
                    let w = z + 1;
                }
            "#,
            ),
            (
                "module_b.rs",
                r#"
                fn process_b() {
                    let a = 1;
                    let b = a + 2;
                    let c = b * a;
                    let d = c + 1;
                }
            "#,
            ),
        ]);
        let config = low_threshold_config();
        let groups = detect_fragments(&parsed, &config);
        assert!(!groups.is_empty());
        if let Some(g) = groups.first() {
            let files: std::collections::HashSet<&str> =
                g.entries.iter().map(|e| e.file.as_str()).collect();
            assert!(
                files.len() >= 2,
                "Fragment entries should come from different files"
            );
        }
    }

    #[test]
    fn test_detect_fragments_same_function_excluded() {
        let parsed = parse(
            r#"
            fn foo() {
                let x = 1;
                let y = x + 2;
                let z = y * x;
                let a = 1;
                let b = a + 2;
                let c = b * a;
            }
        "#,
        );
        let config = low_threshold_config();
        let groups = detect_fragments(&parsed, &config);
        assert!(
            groups.is_empty(),
            "Same-function duplicates should be excluded"
        );
    }

    #[test]
    fn test_detect_fragments_merges_adjacent() {
        let parsed = parse_multi(&[
            (
                "a.rs",
                r#"
                fn foo() {
                    let x = 1;
                    let y = x + 2;
                    let z = y * x;
                    let w = z + 1;
                }
            "#,
            ),
            (
                "b.rs",
                r#"
                fn bar() {
                    let a = 1;
                    let b = a + 2;
                    let c = b * a;
                    let d = c + 1;
                }
            "#,
            ),
        ]);
        let config = low_threshold_config();
        let groups = detect_fragments(&parsed, &config);
        // Windows [0,1,2] and [1,2,3] both match → merge into 4-statement fragment
        if !groups.is_empty() {
            assert!(
                groups.iter().any(|g| g.statement_count >= 4),
                "Adjacent windows should merge: got counts {:?}",
                groups.iter().map(|g| g.statement_count).collect::<Vec<_>>()
            );
        }
    }

    #[test]
    fn test_detect_fragments_too_few_statements() {
        let parsed = parse_multi(&[
            ("a.rs", "fn foo() { let x = 1; let y = 2; }"),
            ("b.rs", "fn bar() { let a = 1; let b = 2; }"),
        ]);
        let mut config = low_threshold_config();
        config.min_statements = 3;
        let groups = detect_fragments(&parsed, &config);
        assert!(
            groups.is_empty(),
            "Functions with <min_statements should produce no fragments"
        );
    }

    #[test]
    fn test_detect_fragments_below_min_tokens() {
        let parsed = parse_multi(&[
            (
                "a.rs",
                r#"
                fn foo() {
                    let x = 1;
                    let y = 2;
                    let z = 3;
                }
            "#,
            ),
            (
                "b.rs",
                r#"
                fn bar() {
                    let a = 1;
                    let b = 2;
                    let c = 3;
                }
            "#,
            ),
        ]);
        let mut config = low_threshold_config();
        config.min_tokens = 100;
        let groups = detect_fragments(&parsed, &config);
        assert!(
            groups.is_empty(),
            "Windows below min_tokens should be excluded"
        );
    }

    #[test]
    fn test_detect_fragments_test_excluded() {
        let parsed = parse_multi(&[
            (
                "a.rs",
                r#"
                fn prod() {
                    let x = 1;
                    let y = x + 2;
                    let z = y * x;
                }
            "#,
            ),
            (
                "b.rs",
                r#"
                #[cfg(test)]
                mod tests {
                    fn test_helper() {
                        let a = 1;
                        let b = a + 2;
                        let c = b * a;
                    }
                }
            "#,
            ),
        ]);
        let mut config = low_threshold_config();
        config.ignore_tests = true;
        let groups = detect_fragments(&parsed, &config);
        assert!(
            groups.is_empty(),
            "Test functions should be excluded when ignore_tests=true"
        );
    }

    #[test]
    fn test_detect_fragments_test_included() {
        let parsed = parse_multi(&[
            (
                "a.rs",
                r#"
                fn prod() {
                    let x = 1;
                    let y = x + 2;
                    let z = y * x;
                }
            "#,
            ),
            (
                "b.rs",
                r#"
                #[cfg(test)]
                mod tests {
                    fn test_helper() {
                        let a = 1;
                        let b = a + 2;
                        let c = b * a;
                    }
                }
            "#,
            ),
        ]);
        let mut config = low_threshold_config();
        config.ignore_tests = false;
        let groups = detect_fragments(&parsed, &config);
        assert!(
            !groups.is_empty(),
            "Test functions should be included when ignore_tests=false"
        );
    }

    #[test]
    fn test_detect_fragments_entry_has_lines() {
        let parsed = parse_multi(&[
            (
                "a.rs",
                r#"
                fn foo() {
                    let x = 1;
                    let y = x + 2;
                    let z = y * x;
                }
            "#,
            ),
            (
                "b.rs",
                r#"
                fn bar() {
                    let a = 1;
                    let b = a + 2;
                    let c = b * a;
                }
            "#,
            ),
        ]);
        let config = low_threshold_config();
        let groups = detect_fragments(&parsed, &config);
        if !groups.is_empty() {
            for entry in &groups[0].entries {
                assert!(entry.start_line > 0, "start_line should be > 0");
                assert!(entry.end_line >= entry.start_line, "end_line >= start_line");
            }
        }
    }

    #[test]
    fn test_extract_matching_pairs_empty() {
        let pairs = extract_matching_pairs(&[]);
        assert!(pairs.is_empty());
    }

    #[test]
    fn test_merge_into_fragments_empty() {
        let fn_infos: Vec<FnInfo> = vec![];
        let groups = merge_into_fragments(vec![], &fn_infos, 3);
        assert!(groups.is_empty());
    }

    #[test]
    fn test_fragment_group_statement_count() {
        let parsed = parse_multi(&[
            (
                "a.rs",
                r#"
                fn foo() {
                    let x = 1;
                    let y = x + 2;
                    let z = y * x;
                }
            "#,
            ),
            (
                "b.rs",
                r#"
                fn bar() {
                    let a = 1;
                    let b = a + 2;
                    let c = b * a;
                }
            "#,
            ),
        ]);
        let config = low_threshold_config();
        let groups = detect_fragments(&parsed, &config);
        for group in &groups {
            assert!(
                group.statement_count >= 3,
                "Fragment must have at least min_statements"
            );
        }
    }

    #[test]
    fn test_detect_fragments_impl_method() {
        let parsed = parse_multi(&[
            (
                "a.rs",
                r#"
                struct Foo;
                impl Foo {
                    fn method(&self) {
                        let x = 1;
                        let y = x + 2;
                        let z = y * x;
                    }
                }
            "#,
            ),
            (
                "b.rs",
                r#"
                struct Bar;
                impl Bar {
                    fn method(&self) {
                        let a = 1;
                        let b = a + 2;
                        let c = b * a;
                    }
                }
            "#,
            ),
        ]);
        let config = low_threshold_config();
        let groups = detect_fragments(&parsed, &config);
        assert!(
            !groups.is_empty(),
            "Should detect fragments in impl methods"
        );
    }

    #[test]
    fn test_detect_fragments_three_way() {
        let parsed = parse_multi(&[
            (
                "a.rs",
                r#"
                fn func_a() {
                    let x = 1;
                    let y = x + 2;
                    let z = y * x;
                }
            "#,
            ),
            (
                "b.rs",
                r#"
                fn func_b() {
                    let a = 1;
                    let b = a + 2;
                    let c = b * a;
                }
            "#,
            ),
            (
                "c.rs",
                r#"
                fn func_c() {
                    let p = 1;
                    let q = p + 2;
                    let r = q * p;
                }
            "#,
            ),
        ]);
        let config = low_threshold_config();
        let groups = detect_fragments(&parsed, &config);
        // With 3 matching functions, we get pairs: (a,b), (a,c), (b,c)
        assert!(
            groups.len() >= 3,
            "Three matching functions should produce at least 3 pair groups"
        );
    }
}