semantic-diff 0.9.0

use crate::diff::DiffData;
use crate::grouper::llm::LlmBackend;
use crate::grouper::{GroupingStatus, SemanticGroup};
use crate::highlight::HighlightCache;
use crate::preview::mermaid::{ImageSupport, MermaidCache};
use crate::review::{GroupReview, ReviewCache, ReviewSection, ReviewSource, SectionState};
use crate::theme::Theme;
use crate::ui::file_tree::TreeNodeId;
use crossterm::event::{KeyCode, KeyEvent, KeyModifiers};
use std::cell::{Cell, RefCell};
use std::collections::{HashMap, HashSet};
use tokio::sync::mpsc;
use tui_tree_widget::TreeState;

/// Hunk-level filter: maps file path → set of hunk indices to show.
/// An empty set means show all hunks for that file.
pub type HunkFilter = HashMap<String, HashSet<usize>>;

/// Input mode for the application.
#[derive(Debug, Clone, PartialEq)]
pub enum InputMode {
    Normal,
    Search,
    Help,
    Settings,
}

/// Which panel currently has keyboard focus.
#[derive(Debug, Clone, PartialEq)]
pub enum FocusedPanel {
    FileTree,
    DiffView,
}

/// Messages processed by the TEA update loop.
#[derive(Debug)]
pub enum Message {
    KeyPress(KeyEvent),
    Resize(u16, u16),
    RefreshSignal,
    DebouncedRefresh,
    DiffParsed(DiffData, String), // parsed data + raw diff for cache hashing
    GroupingComplete(Vec<SemanticGroup>, u64), // groups + diff_hash for cache saving
    GroupingFailed(String),
    IncrementalGroupingComplete(
        Vec<SemanticGroup>,
        crate::grouper::DiffDelta,
        HashMap<String, u64>,
        u64,    // diff_hash
        String, // head_commit
    ),
    /// A mermaid diagram finished rendering — triggers UI refresh.
    MermaidReady,
    ReviewSectionReady(u64, ReviewSection, Result<String, String>),
}


/// Commands returned by update() for the main loop to execute.
#[allow(dead_code)]
pub enum Command {
    SpawnDiffParse { git_diff_args: Vec<String> },
    SpawnGrouping {
        backend: LlmBackend,
        model: String,
        summaries: String,
        diff_hash: u64,
        head_commit: Option<String>,
        file_hashes: HashMap<String, u64>,
    },
    SpawnIncrementalGrouping {
        backend: LlmBackend,
        model: String,
        summaries: String,
        diff_hash: u64,
        head_commit: String,
        file_hashes: HashMap<String, u64>,
        delta: crate::grouper::DiffDelta,
    },
    SpawnReviewSection {
        backend: crate::grouper::llm::LlmBackend,
        model: String,
        section: ReviewSection,
        prompt: String,
        group_content_hash: u64,
    },
    SpawnReviewBatch(Vec<Command>),
    CancelReview(u64),
    Quit,
}

/// Identifies a collapsible node in the diff tree.
#[derive(Debug, Clone, Hash, Eq, PartialEq)]
pub enum NodeId {
    File(usize),
    Hunk(usize, usize),
}

/// UI state for navigation and collapse tracking.
pub struct UiState {
    pub selected_index: usize,
    pub scroll_offset: u16,
    pub collapsed: HashSet<NodeId>,
    /// Terminal viewport height, updated each frame.
    pub viewport_height: u16,
    /// Width of the diff view panel (Cell for interior mutability during render).
    pub diff_view_width: Cell<u16>,
    /// Scroll offset for preview mode (line-based, not item-based).
    pub preview_scroll: usize,
}

/// An item in the flattened visible list.
#[derive(Debug, Clone)]
pub enum VisibleItem {
    FileHeader { file_idx: usize },
    HunkHeader { file_idx: usize, hunk_idx: usize },
    DiffLine { file_idx: usize, hunk_idx: usize, line_idx: usize },
}

/// The main application state (TEA Model).
pub struct App {
    pub diff_data: DiffData,
    pub ui_state: UiState,
    pub highlight_cache: HighlightCache,
    #[allow(dead_code)]
    pub should_quit: bool,
    /// Channel sender for spawning debounce timers that send DebouncedRefresh.
    pub event_tx: Option<mpsc::Sender<Message>>,
    /// Handle to the current debounce timer task, if any.
    pub debounce_handle: Option<tokio::task::JoinHandle<()>>,
    /// Current input mode (Normal or Search).
    pub input_mode: InputMode,
    /// Current search query being typed.
    pub search_query: String,
    /// The confirmed filter pattern (set on Enter in search mode).
    pub active_filter: Option<String>,
    /// Semantic groups from LLM, if available. None = ungrouped.
    pub semantic_groups: Option<Vec<SemanticGroup>>,
    /// Lifecycle state of the current grouping request.
    pub grouping_status: GroupingStatus,
    /// Handle to the in-flight grouping task, for cancellation (ROB-05).
    pub grouping_handle: Option<tokio::task::JoinHandle<()>>,
    /// Which LLM backend is available (Claude preferred, Copilot fallback), if any.
    pub llm_backend: Option<LlmBackend>,
    /// Model string resolved for the active backend.
    pub llm_model: String,
    /// Which panel currently has keyboard focus.
    pub focused_panel: FocusedPanel,
    /// Persistent tree state for tui-tree-widget (RefCell for interior mutability in render).
    pub tree_state: RefCell<TreeState<TreeNodeId>>,
    /// When a group is selected in the sidebar, filter the diff view to those (file, hunk) pairs.
    /// Key = file path (stripped), Value = set of hunk indices (empty = all hunks).
    pub tree_filter: Option<HunkFilter>,
    /// Active theme (colors + syntect theme name), derived from config at startup.
    pub theme: Theme,
    /// HEAD commit hash when current groups were computed. Used for incremental grouping.
    pub previous_head: Option<String>,
    /// Per-file content hashes from the last grouping. Used to detect what changed.
    pub previous_file_hashes: HashMap<String, u64>,
    /// Git diff arguments from the CLI, used for refreshes.
    pub git_diff_args: Vec<String>,
    /// Whether markdown preview mode is active (toggled with "p").
    pub preview_mode: bool,
    /// Whether the terminal supports inline image rendering.
    pub image_support: ImageSupport,
    /// Mermaid diagram cache (only used when image_support == Supported).
    pub mermaid_cache: Option<MermaidCache>,
    pub review_cache: ReviewCache,
    pub review_handles: std::collections::HashMap<(u64, ReviewSection), tokio::task::JoinHandle<()>>,
    pub active_review_group: Option<u64>,
    pub review_scroll: usize,
    pub review_source: ReviewSource,
}

impl App {
    /// Create a new App with parsed diff data, user config, and git diff arguments.
    pub fn new(diff_data: DiffData, config: &crate::config::Config, git_diff_args: Vec<String>) -> Self {
        let theme = Theme::from_mode(config.theme_mode);
        let highlight_cache = HighlightCache::new(&diff_data, theme.syntect_theme);
        let image_support = crate::preview::mermaid::detect_image_support();
        let mermaid_cache = match &image_support {
            ImageSupport::Supported(_) => Some(MermaidCache::new()),
            _ => None,
        };
        Self {
            diff_data,
            ui_state: UiState {
                selected_index: 0,
                scroll_offset: 0,
                collapsed: HashSet::new(),
                viewport_height: 24, // will be updated on first draw
                diff_view_width: Cell::new(80),
                preview_scroll: 0,
            },
            highlight_cache,
            should_quit: false,
            event_tx: None,
            debounce_handle: None,
            input_mode: InputMode::Normal,
            search_query: String::new(),
            active_filter: None,
            semantic_groups: None,
            grouping_status: GroupingStatus::Idle,
            grouping_handle: None,
            llm_backend: config.detect_backend(),
            llm_model: config
                .detect_backend()
                .map(|b| config.model_for_backend(b).to_string())
                .unwrap_or_default(),
            focused_panel: FocusedPanel::DiffView,
            tree_state: RefCell::new(TreeState::default()),
            tree_filter: None,
            theme,
            previous_head: None,
            previous_file_hashes: HashMap::new(),
            git_diff_args,
            preview_mode: false,
            image_support,
            mermaid_cache,
            review_cache: ReviewCache::new(),
            review_handles: std::collections::HashMap::new(),
            active_review_group: None,
            review_scroll: 0,
            review_source: crate::review::detect_review_skill(),
        }
    }

    /// TEA update: dispatch message to handler, return optional command.
    pub fn update(&mut self, msg: Message) -> Option<Command> {
        match msg {
            Message::KeyPress(key) => self.handle_key(key),
            Message::Resize(_w, h) => {
                self.ui_state.viewport_height = h.saturating_sub(1);
                None
            }
            Message::RefreshSignal => {
                // Cancel any existing debounce timer
                if let Some(handle) = self.debounce_handle.take() {
                    handle.abort();
                }
                // Spawn a new debounce timer: 500ms delay before refresh
                if let Some(tx) = &self.event_tx {
                    let tx = tx.clone();
                    self.debounce_handle = Some(tokio::spawn(async move {
                        tokio::time::sleep(std::time::Duration::from_millis(500)).await;
                        let _ = tx.send(Message::DebouncedRefresh).await;
                    }));
                }
                None
            }
            Message::DebouncedRefresh => {
                self.debounce_handle = None;
                Some(Command::SpawnDiffParse {
                    git_diff_args: self.git_diff_args.clone(),
                })
            }
            Message::DiffParsed(new_data, raw_diff) => {
                self.apply_new_diff_data(new_data);
                let hash = crate::cache::diff_hash(&raw_diff);
                let current_head = crate::cache::get_head_commit();

                // Check exact diff hash cache first (handles identical re-triggers)
                if let Some(cached) = crate::cache::load(hash) {
                    let mut groups = cached;
                    crate::grouper::normalize_hunk_indices(&mut groups, &self.diff_data);
                    self.semantic_groups = Some(groups);
                    self.grouping_status = GroupingStatus::Done;
                    self.grouping_handle = None;
                    // Update incremental state
                    if let Some(ref head) = current_head {
                        self.previous_head = Some(head.clone());
                    }
                    self.previous_file_hashes =
                        crate::grouper::compute_all_file_hashes(&self.diff_data);
                    return None;
                }

                // Try incremental path: same HEAD + have previous groups
                let can_incremental = current_head.is_some()
                    && self.previous_head.as_ref() == current_head.as_ref()
                    && self.semantic_groups.is_some()
                    && !self.previous_file_hashes.is_empty();

                if can_incremental {
                    let new_hashes = crate::grouper::compute_all_file_hashes(&self.diff_data);
                    let delta =
                        crate::grouper::compute_diff_delta(&new_hashes, &self.previous_file_hashes);

                    if !delta.has_changes() {
                        // Nothing changed — keep existing groups
                        self.grouping_status = GroupingStatus::Done;
                        return None;
                    }

                    if delta.is_only_removals() {
                        // Only files removed — prune groups locally, no LLM needed
                        let mut groups = self.semantic_groups.clone().unwrap_or_default();
                        crate::grouper::remove_files_from_groups(&mut groups, &delta.removed_files);
                        crate::grouper::normalize_hunk_indices(&mut groups, &self.diff_data);
                        self.semantic_groups = Some(groups);
                        self.grouping_status = GroupingStatus::Done;
                        self.previous_file_hashes = new_hashes.clone();
                        // Save updated cache
                        if let Some(ref head) = current_head {
                            crate::cache::save_with_state(
                                hash,
                                self.semantic_groups.as_ref().unwrap(),
                                Some(head),
                                &new_hashes,
                            );
                        }
                        return None;
                    }

                    // New or modified files — spawn incremental LLM grouping
                    if let Some(backend) = self.llm_backend {
                        if let Some(handle) = self.grouping_handle.take() {
                            handle.abort();
                        }
                        self.grouping_status = GroupingStatus::Loading;
                        let existing = self.semantic_groups.as_ref().unwrap();
                        let summaries = crate::grouper::incremental_hunk_summaries(
                            &self.diff_data,
                            &delta,
                            existing,
                        );
                        tracing::info!(
                            new = delta.new_files.len(),
                            modified = delta.modified_files.len(),
                            removed = delta.removed_files.len(),
                            unchanged = delta.unchanged_files.len(),
                            "Incremental grouping"
                        );
                        return Some(Command::SpawnIncrementalGrouping {
                            backend,
                            model: self.llm_model.clone(),
                            summaries,
                            diff_hash: hash,
                            head_commit: current_head.unwrap(),
                            file_hashes: new_hashes,
                            delta,
                        });
                    }
                }

                // Fallback: full re-group
                if let Some(backend) = self.llm_backend {
                    // Cancel in-flight grouping (ROB-05)
                    if let Some(handle) = self.grouping_handle.take() {
                        handle.abort();
                    }
                    self.grouping_status = GroupingStatus::Loading;
                    let summaries = crate::grouper::hunk_summaries(&self.diff_data);
                    let file_hashes = crate::grouper::compute_all_file_hashes(&self.diff_data);
                    Some(Command::SpawnGrouping {
                        backend,
                        model: self.llm_model.clone(),
                        summaries,
                        diff_hash: hash,
                        head_commit: current_head,
                        file_hashes,
                    })
                } else {
                    self.grouping_status = GroupingStatus::Idle;
                    None
                }
            }
            Message::GroupingComplete(groups, diff_hash) => {
                let mut groups = groups;
                crate::grouper::normalize_hunk_indices(&mut groups, &self.diff_data);
                // Update incremental state for next refresh
                let current_head = crate::cache::get_head_commit();
                let file_hashes = crate::grouper::compute_all_file_hashes(&self.diff_data);
                // Save with full incremental state
                crate::cache::save_with_state(
                    diff_hash,
                    &groups,
                    current_head.as_deref(),
                    &file_hashes,
                );
                self.previous_head = current_head;
                self.previous_file_hashes = file_hashes;
                self.semantic_groups = Some(groups);
                self.grouping_status = GroupingStatus::Done;
                self.grouping_handle = None;
                // Reset tree state since structure changed from flat→grouped
                let mut ts = self.tree_state.borrow_mut();
                *ts = TreeState::default();
                ts.select_first();
                drop(ts);
                // Clear any stale tree filter from the flat view
                self.tree_filter = None;
                // Spawn reviews for all groups in parallel
                self.spawn_all_reviews()
            }
            Message::IncrementalGroupingComplete(new_assignments, delta, file_hashes, diff_hash, head_commit) => {
                let existing = self.semantic_groups.as_ref().cloned().unwrap_or_default();
                let mut merged =
                    crate::grouper::merge_groups(&existing, &new_assignments, &delta);
                crate::grouper::normalize_hunk_indices(&mut merged, &self.diff_data);
                // Save merged groups to cache with incremental state
                crate::cache::save_with_state(
                    diff_hash,
                    &merged,
                    Some(&head_commit),
                    &file_hashes,
                );
                self.semantic_groups = Some(merged);
                self.grouping_status = GroupingStatus::Done;
                self.grouping_handle = None;
                self.previous_file_hashes = file_hashes;
                self.previous_head = Some(head_commit);
                // Reset tree state since structure changed
                let mut ts = self.tree_state.borrow_mut();
                *ts = TreeState::default();
                ts.select_first();
                drop(ts);
                self.tree_filter = None;
                // Spawn reviews for all groups in parallel
                self.spawn_all_reviews()
            }
            Message::GroupingFailed(err) => {
                tracing::warn!("Grouping failed: {}", err);
                self.grouping_status = GroupingStatus::Error(err);
                self.grouping_handle = None;
                None // Continue showing ungrouped — graceful degradation (ROB-06)
            }
            Message::MermaidReady => None, // just triggers UI refresh
            Message::ReviewSectionReady(hash, section, result) => {
                self.review_handles.remove(&(hash, section));
                if let Some(review) = self.review_cache.get_mut(&hash) {
                    match result {
                        Ok(content) => {
                            if section == ReviewSection::How && content.trim() == "SKIP" {
                                review.sections.insert(section, SectionState::Skipped);
                            } else {
                                review.sections.insert(section, SectionState::Ready(content));
                            }
                        }
                        Err(msg) => {
                            review.sections.insert(section, SectionState::Error(msg));
                        }
                    }
                    let all_complete = review.sections.values().all(|s| s.is_complete());
                    if all_complete {
                        let review_clone = review.clone();
                        crate::review::save_review_to_disk(&review_clone);
                    }
                }
                None
            }
        }
    }

    /// Apply new diff data while preserving scroll position and collapse state.
    fn apply_new_diff_data(&mut self, new_data: DiffData) {
        // 1. Record collapsed state by file path (not index)
        let mut collapsed_files: HashSet<String> = HashSet::new();
        let mut collapsed_hunks: HashSet<(String, usize)> = HashSet::new();

        for node in &self.ui_state.collapsed {
            match node {
                NodeId::File(fi) => {
                    if let Some(file) = self.diff_data.files.get(*fi) {
                        collapsed_files.insert(file.target_file.clone());
                    }
                }
                NodeId::Hunk(fi, hi) => {
                    if let Some(file) = self.diff_data.files.get(*fi) {
                        collapsed_hunks.insert((file.target_file.clone(), *hi));
                    }
                }
            }
        }

        // 2. Record current selected file path for position preservation
        let selected_path = self.selected_file_path();

        // 3. Replace diff data and rebuild highlight cache
        self.diff_data = new_data;
        self.highlight_cache = HighlightCache::new(&self.diff_data, self.theme.syntect_theme);

        // 4. Rebuild collapsed set with new indices
        self.ui_state.collapsed.clear();
        for (fi, file) in self.diff_data.files.iter().enumerate() {
            if collapsed_files.contains(&file.target_file) {
                self.ui_state.collapsed.insert(NodeId::File(fi));
            }
            for (hi, _) in file.hunks.iter().enumerate() {
                if collapsed_hunks.contains(&(file.target_file.clone(), hi)) {
                    self.ui_state.collapsed.insert(NodeId::Hunk(fi, hi));
                }
            }
        }

        // 5. Restore selected position by file path, or clamp
        if let Some(path) = selected_path {
            let items = self.visible_items();
            let restored = items.iter().position(|item| {
                if let VisibleItem::FileHeader { file_idx } = item {
                    self.diff_data.files[*file_idx].target_file == path
                } else {
                    false
                }
            });
            if let Some(idx) = restored {
                self.ui_state.selected_index = idx;
            } else {
                self.ui_state.selected_index = self
                    .ui_state
                    .selected_index
                    .min(items.len().saturating_sub(1));
            }
        } else {
            let items_len = self.visible_items().len();
            self.ui_state.selected_index = self
                .ui_state
                .selected_index
                .min(items_len.saturating_sub(1));
        }

        self.adjust_scroll();
    }

    /// Get the file path of the currently selected item (for position preservation).
    fn selected_file_path(&self) -> Option<String> {
        let items = self.visible_items();
        let item = items.get(self.ui_state.selected_index)?;
        let fi = match item {
            VisibleItem::FileHeader { file_idx } => *file_idx,
            VisibleItem::HunkHeader { file_idx, .. } => *file_idx,
            VisibleItem::DiffLine { file_idx, .. } => *file_idx,
        };
        self.diff_data.files.get(fi).map(|f| f.target_file.clone())
    }

    /// Handle a key press event, branching on input mode.
    fn handle_key(&mut self, key: KeyEvent) -> Option<Command> {
        match self.input_mode {
            InputMode::Normal => self.handle_key_normal(key),
            InputMode::Search => self.handle_key_search(key),
            InputMode::Help => {
                // Any key closes help
                self.input_mode = InputMode::Normal;
                None
            }
            InputMode::Settings => self.handle_key_settings(key),
        }
    }

    /// Handle keys while the Settings overlay is open.
    fn handle_key_settings(&mut self, key: KeyEvent) -> Option<Command> {
        match key.code {
            KeyCode::Char('d') => {
                self.toggle_theme();
                None
            }
            KeyCode::Esc => {
                self.input_mode = InputMode::Normal;
                None
            }
            _ => None,
        }
    }

    /// Toggle between dark and light theme, rebuilding the highlight cache.
    pub fn toggle_theme(&mut self) {
        let new_theme = if self.theme.syntect_theme.contains("dark") {
            crate::theme::Theme::light()
        } else {
            crate::theme::Theme::dark()
        };
        self.theme = new_theme;
        self.highlight_cache = HighlightCache::new(&self.diff_data, self.theme.syntect_theme);
    }

    /// Handle keys in Normal mode.
    fn handle_key_normal(&mut self, key: KeyEvent) -> Option<Command> {
        // Global keys that work regardless of focused panel
        match key.code {
            KeyCode::Char('q') => return Some(Command::Quit),
            KeyCode::Char('?') => {
                self.input_mode = InputMode::Help;
                return None;
            }
            KeyCode::Char(',') => {
                self.input_mode = InputMode::Settings;
                return None;
            }
            KeyCode::Tab => {
                self.focused_panel = match self.focused_panel {
                    FocusedPanel::FileTree => FocusedPanel::DiffView,
                    FocusedPanel::DiffView => FocusedPanel::FileTree,
                };
                return None;
            }
            KeyCode::Esc => {
                if self.tree_filter.is_some() || self.active_filter.is_some() {
                    self.tree_filter = None;
                    self.active_filter = None;
                    self.ui_state.selected_index = 0;
                    self.adjust_scroll();
                    return None;
                } else {
                    return Some(Command::Quit);
                }
            }
            KeyCode::Char('/') => {
                self.input_mode = InputMode::Search;
                self.search_query.clear();
                return None;
            }
            KeyCode::Char('p') => {
                if crate::ui::preview_view::is_current_file_markdown(self) {
                    self.preview_mode = !self.preview_mode;
                    if self.preview_mode {
                        self.ui_state.preview_scroll = 0;
                    }
                }
                return None;
            }
            _ => {}
        }

        // Route to panel-specific handler
        match self.focused_panel {
            FocusedPanel::FileTree => self.handle_key_tree(key),
            FocusedPanel::DiffView => self.handle_key_diff(key),
        }
    }

    /// Handle keys when the file tree sidebar is focused.
    fn handle_key_tree(&mut self, key: KeyEvent) -> Option<Command> {
        let mut ts = self.tree_state.borrow_mut();
        match key.code {
            KeyCode::Char('j') | KeyCode::Down => {
                ts.key_down();
            }
            KeyCode::Char('k') | KeyCode::Up => {
                ts.key_up();
            }
            KeyCode::Left => {
                ts.key_left();
            }
            KeyCode::Right => {
                ts.key_right();
            }
            KeyCode::Enter => {
                ts.toggle_selected();
            }
            KeyCode::Char('g') => {
                ts.select_first();
            }
            KeyCode::Char('G') => {
                ts.select_last();
            }
            _ => return None,
        }

        // After any navigation, sync the diff view to the selected tree node
        let selected = ts.selected().to_vec();
        drop(ts); // release borrow before mutating self
        self.apply_tree_selection(&selected)
    }

    /// Update the diff view filter based on the currently selected tree node.
    fn apply_tree_selection(&mut self, selected: &[TreeNodeId]) -> Option<Command> {
        match selected.last() {
            Some(TreeNodeId::File(group_idx, path)) => {
                self.select_tree_file(path, *group_idx);
                // Clear review pane display, but let in-flight reviews finish
                // in the background so results get cached.
                self.active_review_group = None;
                self.review_scroll = 0;
                None
            }
            Some(TreeNodeId::Group(gi)) => {
                self.select_tree_group(*gi);
                // Set this group as active for the review pane display.
                // Reviews are pre-spawned for all groups when grouping completes,
                // so by the time the user navigates here the review is likely
                // already cached or in-flight.
                if let Some(groups) = &self.semantic_groups {
                    if let Some(group) = groups.get(*gi) {
                        let hash = crate::review::group_content_hash(group);
                        if self.active_review_group == Some(hash) {
                            return None; // already showing
                        }
                        self.active_review_group = Some(hash);
                        self.review_scroll = 0;

                        // If review isn't in memory yet, try disk cache
                        if self.review_cache.get(&hash).is_none() {
                            if let Some(cached) = crate::review::load_review_from_disk(hash, &self.review_source) {
                                self.review_cache.insert(cached);
                            }
                        }
                        // If still not cached (and not in-flight), spawn on demand as fallback
                        if self.review_cache.get(&hash).is_none() {
                            return self.spawn_all_reviews();
                        }
                    }
                }
                None
            }
            None => None,
        }
    }

    /// Spawn reviews for ALL groups. Checks disk cache first, only spawns LLM
    /// calls for groups without cached reviews. Returns a SpawnReviewBatch with
    /// all needed sections, or None if everything is already cached.
    pub fn spawn_all_reviews(&mut self) -> Option<Command> {
        let backend = self.llm_backend?;
        let groups = self.semantic_groups.as_ref()?.clone();
        let mut all_cmds: Vec<Command> = Vec::new();

        for group in &groups {
            let hash = crate::review::group_content_hash(group);

            // Already in memory cache?
            if self.review_cache.get(&hash).is_some() {
                continue;
            }

            // Check disk cache
            if let Some(cached) = crate::review::load_review_from_disk(hash, &self.review_source) {
                self.review_cache.insert(cached);
                continue;
            }

            // Cache miss — prepare LLM calls for this group
            let mut sections_map = std::collections::HashMap::new();
            for s in ReviewSection::all() {
                sections_map.insert(s, SectionState::Loading);
            }
            self.review_cache.insert(GroupReview {
                content_hash: hash,
                sections: sections_map,
                source: self.review_source.clone(),
            });

            let model = self.llm_model.clone();
            let review_source = self.review_source.clone();
            for &section in &ReviewSection::all() {
                let prompt = crate::review::llm::build_review_prompt(
                    section, group, &self.diff_data, &review_source,
                );
                all_cmds.push(Command::SpawnReviewSection {
                    backend,
                    model: model.clone(),
                    section,
                    prompt,
                    group_content_hash: hash,
                });
            }
        }

        if all_cmds.is_empty() {
            None
        } else {
            Some(Command::SpawnReviewBatch(all_cmds))
        }
    }

    /// Handle keys when the diff view is focused (original behavior).
    fn handle_key_diff(&mut self, key: KeyEvent) -> Option<Command> {
        // Review pane scroll and controls take priority when a review is active
        if self.active_review_group.is_some() {
            return self.handle_key_review(key);
        }

        // In preview mode, redirect navigation keys to preview scroll
        if self.preview_mode {
            return self.handle_key_preview(key);
        }

        let items_len = self.visible_items().len();
        if items_len == 0 {
            return None;
        }

        match key.code {
            // Jump to next/previous search match
            KeyCode::Char('n') => {
                self.jump_to_match(true);
                None
            }
            KeyCode::Char('N') => {
                self.jump_to_match(false);
                None
            }

            // Navigation
            KeyCode::Char('j') | KeyCode::Down => {
                self.move_selection(1, items_len);
                None
            }
            KeyCode::Char('k') | KeyCode::Up => {
                self.move_selection(-1, items_len);
                None
            }
            KeyCode::Char('g') => {
                self.ui_state.selected_index = 0;
                self.adjust_scroll();
                None
            }
            KeyCode::Char('G') => {
                self.ui_state.selected_index = items_len.saturating_sub(1);
                self.adjust_scroll();
                None
            }
            KeyCode::Char('d') if key.modifiers.contains(KeyModifiers::CONTROL) => {
                let half_page = (self.ui_state.viewport_height / 2) as usize;
                self.move_selection(half_page as isize, items_len);
                None
            }
            KeyCode::Char('u') if key.modifiers.contains(KeyModifiers::CONTROL) => {
                let half_page = (self.ui_state.viewport_height / 2) as usize;
                self.move_selection(-(half_page as isize), items_len);
                None
            }

            // Collapse/Expand
            KeyCode::Enter => {
                self.toggle_collapse();
                None
            }

            _ => None,
        }
    }

    /// Filter the diff view to show only the hunks for the selected file within its group.
    /// `group_idx` identifies which group the file was selected from (None = flat/ungrouped).
    fn select_tree_file(&mut self, path: &str, group_idx: Option<usize>) {
        let filter = self.hunk_filter_for_file(path, group_idx);
        // Always apply the filter (don't toggle — that's what group headers are for)
        self.tree_filter = Some(filter);
        // Rebuild visible items and scroll to the selected file's header
        let items = self.visible_items();
        let target_idx = items.iter().position(|item| {
            if let VisibleItem::FileHeader { file_idx } = item {
                self.diff_data.files[*file_idx]
                    .target_file
                    .trim_start_matches("b/")
                    == path
            } else {
                false
            }
        });
        self.ui_state.selected_index = target_idx.unwrap_or(0);
        // Pin scroll so the file header is at the top of the viewport
        self.ui_state.scroll_offset = self.ui_state.selected_index as u16;
    }

    /// Filter the diff view to all changes in the selected group.
    fn select_tree_group(&mut self, group_idx: usize) {
        let filter = self.hunk_filter_for_group(group_idx);
        if filter.is_empty() {
            return;
        }
        self.tree_filter = Some(filter);
        self.ui_state.selected_index = 0;
        self.ui_state.scroll_offset = 0;
    }

    /// Build a HunkFilter for a single file's hunks within a specific group.
    /// Only shows the hunks relevant to that group, not the entire group's files.
    fn hunk_filter_for_file(&self, path: &str, group_idx: Option<usize>) -> HunkFilter {
        if let Some(groups) = &self.semantic_groups {
            if let Some(gi) = group_idx {
                if gi >= groups.len() {
                    // "Other" group — extract only this file's ungrouped hunks
                    return self.hunk_filter_for_file_in_other(path);
                }
                if let Some(group) = groups.get(gi) {
                    if let Some(filter) = self.hunk_filter_for_file_in_group(path, group) {
                        return filter;
                    }
                }
            }
            // Fallback (no group_idx or file not found in specified group):
            // search all groups for the first match
            for group in groups.iter() {
                if let Some(filter) = self.hunk_filter_for_file_in_group(path, group) {
                    return filter;
                }
            }
            return self.hunk_filter_for_file_in_other(path);
        }
        // No semantic groups — show all hunks for this file
        let mut filter = HunkFilter::new();
        filter.insert(path.to_string(), HashSet::new());
        filter
    }

    /// Build a single-file HunkFilter from a specific group's changes.
    fn hunk_filter_for_file_in_group(
        &self,
        path: &str,
        group: &crate::grouper::SemanticGroup,
    ) -> Option<HunkFilter> {
        for change in &group.changes() {
            if let Some(diff_path) = self.resolve_diff_path(&change.file) {
                if diff_path == path {
                    let mut filter = HunkFilter::new();
                    let hunk_set: HashSet<usize> = change.hunks.iter().copied().collect();
                    filter.insert(diff_path, hunk_set);
                    return Some(filter);
                }
            }
        }
        None
    }

    /// Build a single-file HunkFilter from the "Other" (ungrouped) hunks.
    fn hunk_filter_for_file_in_other(&self, path: &str) -> HunkFilter {
        let other = self.hunk_filter_for_other();
        let mut filter = HunkFilter::new();
        if let Some(hunk_set) = other.get(path) {
            filter.insert(path.to_string(), hunk_set.clone());
        } else {
            filter.insert(path.to_string(), HashSet::new());
        }
        filter
    }

    /// Build a HunkFilter for group at `group_idx`.
    fn hunk_filter_for_group(&self, group_idx: usize) -> HunkFilter {
        if let Some(groups) = &self.semantic_groups {
            if let Some(group) = groups.get(group_idx) {
                let mut filter = HunkFilter::new();
                for change in &group.changes() {
                    // Resolve to actual diff path
                    if let Some(diff_path) = self.resolve_diff_path(&change.file) {
                        let hunk_set: HashSet<usize> = change.hunks.iter().copied().collect();
                        filter
                            .entry(diff_path)
                            .or_default()
                            .extend(hunk_set.iter());
                    }
                }
                return filter;
            }
            // group_idx beyond actual groups = "Other" group
            if group_idx >= groups.len() {
                return self.hunk_filter_for_other();
            }
        }
        HunkFilter::new()
    }

    /// Build a HunkFilter for the "Other" group (ungrouped hunks).
    fn hunk_filter_for_other(&self) -> HunkFilter {
        let groups = match &self.semantic_groups {
            Some(g) => g,
            None => return HunkFilter::new(),
        };

        // Collect all grouped (file, hunk) pairs
        let mut grouped: HashMap<String, HashSet<usize>> = HashMap::new();
        for group in groups {
            for change in &group.changes() {
                if let Some(dp) = self.resolve_diff_path(&change.file) {
                    grouped.entry(dp).or_default().extend(change.hunks.iter());
                }
            }
        }

        // For each diff file, include hunks NOT covered by any group
        let mut filter = HunkFilter::new();
        for file in &self.diff_data.files {
            let dp = file.target_file.trim_start_matches("b/").to_string();
            if let Some(grouped_hunks) = grouped.get(&dp) {
                // If grouped_hunks is empty, all hunks are claimed
                if grouped_hunks.is_empty() {
                    continue;
                }
                let ungrouped: HashSet<usize> = (0..file.hunks.len())
                    .filter(|hi| !grouped_hunks.contains(hi))
                    .collect();
                if !ungrouped.is_empty() {
                    filter.insert(dp, ungrouped);
                }
            } else {
                // File not in any group — all hunks are "other"
                filter.insert(dp, HashSet::new());
            }
        }
        filter
    }

    /// Resolve a group file path to the actual diff file path (stripped of b/ prefix).
    fn resolve_diff_path(&self, group_path: &str) -> Option<String> {
        self.diff_data.files.iter().find_map(|f| {
            let dp = f.target_file.trim_start_matches("b/");
            if dp == group_path || dp.ends_with(group_path) {
                Some(dp.to_string())
            } else {
                None
            }
        })
    }

    /// Handle keys in Search mode.
    fn handle_key_search(&mut self, key: KeyEvent) -> Option<Command> {
        match key.code {
            KeyCode::Esc => {
                self.input_mode = InputMode::Normal;
                self.search_query.clear();
                self.active_filter = None;
                None
            }
            KeyCode::Enter => {
                self.input_mode = InputMode::Normal;
                self.active_filter = if self.search_query.is_empty() {
                    None
                } else {
                    Some(self.search_query.clone())
                };
                self.ui_state.selected_index = 0;
                self.adjust_scroll();
                None
            }
            KeyCode::Backspace => {
                self.search_query.pop();
                None
            }
            KeyCode::Char(c) => {
                self.search_query.push(c);
                None
            }
            _ => None,
        }
    }

    /// Jump to the next or previous file header matching the active filter.
    fn jump_to_match(&mut self, forward: bool) {
        if self.active_filter.is_none() {
            return;
        }
        let items = self.visible_items();
        if items.is_empty() {
            return;
        }

        let pattern = self.active_filter.as_ref().unwrap().to_lowercase();
        let len = items.len();
        let start = self.ui_state.selected_index;

        // Search through all items wrapping around
        for offset in 1..=len {
            let idx = if forward {
                (start + offset) % len
            } else {
                (start + len - offset) % len
            };
            if let VisibleItem::FileHeader { file_idx } = &items[idx] {
                let path = &self.diff_data.files[*file_idx].target_file;
                if path.to_lowercase().contains(&pattern) {
                    self.ui_state.selected_index = idx;
                    self.adjust_scroll();
                    return;
                }
            }
        }
    }

    /// Move selection by delta, clamping to valid range.
    fn move_selection(&mut self, delta: isize, items_len: usize) {
        let max_idx = items_len.saturating_sub(1);
        let new_idx = if delta > 0 {
            (self.ui_state.selected_index + delta as usize).min(max_idx)
        } else {
            self.ui_state.selected_index.saturating_sub((-delta) as usize)
        };
        self.ui_state.selected_index = new_idx;
        self.adjust_scroll();
    }

    /// Toggle collapse on the currently selected item.
    fn toggle_collapse(&mut self) {
        let items = self.visible_items();
        if let Some(item) = items.get(self.ui_state.selected_index) {
            let node_id = match item {
                VisibleItem::FileHeader { file_idx } => Some(NodeId::File(*file_idx)),
                VisibleItem::HunkHeader { file_idx, hunk_idx } => {
                    Some(NodeId::Hunk(*file_idx, *hunk_idx))
                }
                VisibleItem::DiffLine { .. } => None, // no-op on diff lines
            };

            if let Some(id) = node_id {
                if self.ui_state.collapsed.contains(&id) {
                    self.ui_state.collapsed.remove(&id);
                } else {
                    self.ui_state.collapsed.insert(id);
                }

                // Clamp selected_index after collapse/expand changes visible items
                let new_items_len = self.visible_items().len();
                if self.ui_state.selected_index >= new_items_len {
                    self.ui_state.selected_index = new_items_len.saturating_sub(1);
                }
                self.adjust_scroll();
            }
        }
    }

    /// Estimate the character width of a visible item's rendered line.
    fn item_char_width(&self, item: &VisibleItem) -> usize {
        match item {
            VisibleItem::FileHeader { file_idx } => {
                let file = &self.diff_data.files[*file_idx];
                let name = if file.is_rename {
                    format!(
                        "renamed: {} -> {}",
                        file.source_file.trim_start_matches("a/"),
                        file.target_file.trim_start_matches("b/")
                    )
                } else {
                    file.target_file.trim_start_matches("b/").to_string()
                };
                // " v " + name + " " + "+N" + " -N"
                3 + name.len()
                    + 1
                    + format!("+{}", file.added_count).len()
                    + format!(" -{}", file.removed_count).len()
            }
            VisibleItem::HunkHeader { file_idx, hunk_idx } => {
                let hunk = &self.diff_data.files[*file_idx].hunks[*hunk_idx];
                // "   v " + header
                5 + hunk.header.len()
            }
            VisibleItem::DiffLine {
                file_idx,
                hunk_idx,
                line_idx,
            } => {
                let line =
                    &self.diff_data.files[*file_idx].hunks[*hunk_idx].lines[*line_idx];
                // gutter (10) + prefix (2) + content
                12 + line.content.len()
            }
        }
    }

    /// Calculate the visual row count for an item given the available width.
    pub fn item_visual_rows(&self, item: &VisibleItem, width: u16) -> usize {
        if width == 0 {
            return 1;
        }
        let char_width = self.item_char_width(item);
        char_width.div_ceil(width as usize).max(1)
    }

    /// Adjust scroll offset to keep the selected item visible,
    /// accounting for line wrapping.
    fn adjust_scroll(&mut self) {
        let width = self.ui_state.diff_view_width.get();
        let viewport = self.ui_state.viewport_height as usize;
        let items = self.visible_items();
        let selected = self.ui_state.selected_index;

        if items.is_empty() || viewport == 0 {
            self.ui_state.scroll_offset = 0;
            return;
        }

        let scroll = self.ui_state.scroll_offset as usize;

        // Selected is above viewport
        if selected < scroll {
            self.ui_state.scroll_offset = selected as u16;
            return;
        }

        // Check if selected fits within viewport from current scroll
        let mut rows = 0usize;
        for (i, item) in items.iter().enumerate().take(selected + 1).skip(scroll) {
            rows += self.item_visual_rows(item, width);
            if rows > viewport && i < selected {
                break;
            }
        }

        if rows <= viewport {
            return;
        }

        // Selected is below viewport — find scroll that shows it at bottom
        let selected_height = self.item_visual_rows(&items[selected], width);
        if selected_height >= viewport {
            self.ui_state.scroll_offset = selected as u16;
            return;
        }

        let mut remaining = viewport - selected_height;
        let mut new_scroll = selected;
        for i in (0..selected).rev() {
            let h = self.item_visual_rows(&items[i], width);
            if h > remaining {
                break;
            }
            remaining -= h;
            new_scroll = i;
        }
        self.ui_state.scroll_offset = new_scroll as u16;
    }

    /// Compute the list of visible items respecting collapsed state, active filter,
    /// and hunk-level tree filter.
    pub fn visible_items(&self) -> Vec<VisibleItem> {
        let filter_lower = self
            .active_filter
            .as_ref()
            .map(|f| f.to_lowercase());

        let mut items = Vec::new();
        for (fi, file) in self.diff_data.files.iter().enumerate() {
            let file_path = file.target_file.trim_start_matches("b/");

            // If search filter is active, skip files that don't match
            if let Some(ref pattern) = filter_lower {
                if !file.target_file.to_lowercase().contains(pattern) {
                    continue;
                }
            }

            // Determine which hunks are visible based on tree filter
            let allowed_hunks: Option<&HashSet<usize>> =
                self.tree_filter.as_ref().and_then(|f| f.get(file_path));

            // If tree filter is active but this file isn't in it, skip entirely
            if self.tree_filter.is_some() && allowed_hunks.is_none() {
                continue;
            }

            items.push(VisibleItem::FileHeader { file_idx: fi });
            if !self.ui_state.collapsed.contains(&NodeId::File(fi)) {
                for (hi, hunk) in file.hunks.iter().enumerate() {
                    // If hunk filter is active and this hunk isn't in the set, skip it
                    // (empty set = show all hunks for this file)
                    if let Some(hunk_set) = allowed_hunks {
                        if !hunk_set.is_empty() && !hunk_set.contains(&hi) {
                            continue;
                        }
                    }

                    items.push(VisibleItem::HunkHeader {
                        file_idx: fi,
                        hunk_idx: hi,
                    });
                    if !self.ui_state.collapsed.contains(&NodeId::Hunk(fi, hi)) {
                        for (li, _line) in hunk.lines.iter().enumerate() {
                            items.push(VisibleItem::DiffLine {
                                file_idx: fi,
                                hunk_idx: hi,
                                line_idx: li,
                            });
                        }
                    }
                }
            }
        }
        items
    }

    /// Handle keys when the review pane is active.
    fn handle_key_review(&mut self, key: KeyEvent) -> Option<Command> {
        match key.code {
            KeyCode::Char('j') | KeyCode::Down => {
                self.review_scroll = self.review_scroll.saturating_add(1);
                None
            }
            KeyCode::Char('k') | KeyCode::Up => {
                self.review_scroll = self.review_scroll.saturating_sub(1);
                None
            }
            KeyCode::Char('d') if key.modifiers.contains(KeyModifiers::CONTROL) => {
                self.review_scroll = self.review_scroll.saturating_add(
                    (self.ui_state.viewport_height / 2) as usize,
                );
                None
            }
            KeyCode::Char('u') if key.modifiers.contains(KeyModifiers::CONTROL) => {
                self.review_scroll = self.review_scroll.saturating_sub(
                    (self.ui_state.viewport_height / 2) as usize,
                );
                None
            }
            KeyCode::Char('g') => {
                self.review_scroll = 0;
                None
            }
            KeyCode::Char('G') => {
                self.review_scroll = 999; // will be clamped by renderer
                None
            }
            KeyCode::Char('R') => {
                // Force-refresh review
                if let Some(hash) = self.active_review_group {
                    // Cancel in-flight tasks for this hash
                    let keys: Vec<_> = self
                        .review_handles
                        .keys()
                        .filter(|(h, _)| *h == hash)
                        .cloned()
                        .collect();
                    for key in keys {
                        if let Some(handle) = self.review_handles.remove(&key) {
                            handle.abort();
                        }
                    }
                    // Clear caches
                    self.review_cache.remove(&hash);
                    crate::review::delete_review_from_disk(hash);
                    self.active_review_group = None;

                    // Re-trigger by re-applying current tree selection
                    let selected = self.tree_state.borrow().selected().to_vec();
                    return self.apply_tree_selection(&selected);
                }
                None
            }
            KeyCode::Esc => {
                // Clear review mode
                if let Some(old_hash) = self.active_review_group.take() {
                    let keys: Vec<_> = self
                        .review_handles
                        .keys()
                        .filter(|(h, _)| *h == old_hash)
                        .cloned()
                        .collect();
                    for key in keys {
                        if let Some(handle) = self.review_handles.remove(&key) {
                            handle.abort();
                        }
                    }
                }
                self.review_scroll = 0;
                None
            }
            _ => None,
        }
    }

    /// Handle keys in preview mode (line-based scrolling).
    fn handle_key_preview(&mut self, key: KeyEvent) -> Option<Command> {
        match key.code {
            KeyCode::Char('j') | KeyCode::Down => {
                self.ui_state.preview_scroll = self.ui_state.preview_scroll.saturating_add(1);
                None
            }
            KeyCode::Char('k') | KeyCode::Up => {
                self.ui_state.preview_scroll = self.ui_state.preview_scroll.saturating_sub(1);
                None
            }
            KeyCode::Char('g') => {
                self.ui_state.preview_scroll = 0;
                None
            }
            KeyCode::Char('G') => {
                self.ui_state.preview_scroll = usize::MAX; // will be clamped in render
                None
            }
            KeyCode::Char('d') if key.modifiers.contains(KeyModifiers::CONTROL) => {
                let half_page = (self.ui_state.viewport_height / 2) as usize;
                self.ui_state.preview_scroll = self.ui_state.preview_scroll.saturating_add(half_page);
                None
            }
            KeyCode::Char('u') if key.modifiers.contains(KeyModifiers::CONTROL) => {
                let half_page = (self.ui_state.viewport_height / 2) as usize;
                self.ui_state.preview_scroll = self.ui_state.preview_scroll.saturating_sub(half_page);
                None
            }
            // Collapse/expand still works in preview mode (no-op but don't block)
            KeyCode::Enter => None,
            // Search match jumping
            KeyCode::Char('n') | KeyCode::Char('N') => None,
            _ => None,
        }
    }

    /// TEA view: delegate rendering to the UI module.
    /// Returns pending images that must be flushed after terminal.draw().
    pub fn view(&self, frame: &mut ratatui::Frame) -> Vec<crate::ui::preview_view::PendingImage> {
        crate::ui::draw(self, frame)
    }
}