Function monitor_loop

src/monitor.rs:424–635

(
    reader: &mut MmapReader,
    entries: &mut Vec<MonitorEntry>,
    recent_updates: &mut Vec<(String, String)>,
    last_idx: &mut u64,
    stdout: &mut std::io::Stdout,
)

}

fn monitor_loop(
    reader: &mut MmapReader,
    entries: &mut Vec<MonitorEntry>,
    recent_updates: &mut Vec<(String, String)>,
    last_idx: &mut u64,
    stdout: &mut std::io::Stdout,
) -> std::io::Result<()> {
    use crossterm::{cursor, event, execute, terminal};
    use std::collections::HashMap;

    let mut cost_cache = CostCache::new();
    let mut scroll_offset: usize = 0;
    let mut last_log_lines: usize = 20;

    loop {
        // Poll for key events (100ms timeout = our refresh rate).
        if event::poll(std::time::Duration::from_millis(100))? {
            if let event::Event::Key(key) = event::read()? {
                match key.code {
                    event::KeyCode::Char('c')
                        if key.modifiers.contains(event::KeyModifiers::CONTROL) =>
                    {
                        break;
                    }
                    event::KeyCode::Char('r')
                        if key.modifiers.contains(event::KeyModifiers::CONTROL) =>
                    {
                        entries.clear();
                        recent_updates.clear();
                        scroll_offset = 0;
                    }
                    event::KeyCode::Up => {
                        scroll_offset = scroll_offset.saturating_add(1);
                    }
                    event::KeyCode::Down => {
                        scroll_offset = scroll_offset.saturating_sub(1);
                    }
                    event::KeyCode::PageUp => {
                        scroll_offset = scroll_offset.saturating_add(last_log_lines.max(1));
                    }
                    event::KeyCode::PageDown => {
                        scroll_offset = scroll_offset.saturating_sub(last_log_lines.max(1));
                    }
                    _ => {}
                }
            }
        }

        // Re-read mmap for new entries.
        let _ = reader.refresh();
        let current_idx = reader.write_idx();
        if current_idx > *last_idx {
            for i in *last_idx..current_idx {
                let slot = (i as usize) % RING_CAPACITY;
                if let Some(e) = reader.entry(slot) {
                    push_recent_update(recent_updates, &e.project, &e.tool_name);
                    entries.push(e);
                }