turbolog 0.2.1

Ultralight log anomaly detection — no API key, no Python, pipe-friendly CLI with local LLM explain
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125

use ratatui::{
    layout::{Alignment, Constraint, Direction, Layout},
    style::{Color, Modifier, Style},
    symbols,
    text::{Line, Span},
    widgets::{Block, Borders, List, ListItem, Paragraph, Sparkline},
    Frame,
};

use crate::tui::app::{AppState, DashMode};

pub fn draw(f: &mut Frame, app: &AppState) {
    let chunks = Layout::default()
        .direction(Direction::Vertical)
        .constraints([
            Constraint::Percentage(40),
            Constraint::Percentage(35),
            Constraint::Percentage(25),
        ])
        .split(f.area());

    draw_log_stream(f, app, chunks[0]);
    draw_sparkline(f, app, chunks[1]);
    draw_stats_bar(f, app, chunks[2]);
}

fn draw_log_stream(f: &mut Frame, app: &AppState, area: ratatui::layout::Rect) {
    let items: Vec<ListItem> = app
        .recent_logs
        .iter()
        .map(|entry| {
            let style = if entry.is_anomaly {
                Style::default().fg(Color::Red).add_modifier(Modifier::BOLD)
            } else {
                Style::default()
            };
            let prefix = if let Some(score) = entry.score {
                if entry.is_anomaly {
                    format!("[ANOMALY {score:.2}] ")
                } else {
                    String::new()
                }
            } else {
                "[calibrating] ".to_string()
            };
            let text = format!("{}{}", prefix, entry.text);
            // Truncate to terminal width to avoid wrapping.
            let display = if text.chars().count() > area.width as usize {
                let limit = area.width.saturating_sub(1) as usize;
                let mut truncated: String = text.chars().take(limit).collect();
                truncated.push('…');
                truncated
            } else {
                text
            };
            ListItem::new(Line::from(Span::styled(display, style)))
        })
        .collect();

    let block = Block::default()
        .borders(Borders::ALL)
        .title(" Log Stream (last 20) ")
        .title_alignment(Alignment::Left);
    let list = List::new(items).block(block);
    f.render_widget(list, area);
}

fn draw_sparkline(f: &mut Frame, app: &AppState, area: ratatui::layout::Rect) {
    let data: Vec<u64> = app.anomaly_sparkline.iter().copied().collect();
    let block = Block::default()
        .borders(Borders::ALL)
        .title(" Anomaly Rate — last 60 ticks ")
        .title_alignment(Alignment::Left);
    let spark = Sparkline::default()
        .block(block)
        .data(&data)
        .style(Style::default().fg(Color::Yellow))
        .bar_set(symbols::bar::NINE_LEVELS);
    f.render_widget(spark, area);
}

fn draw_stats_bar(f: &mut Frame, app: &AppState, area: ratatui::layout::Rect) {
    let uptime = app.uptime_secs();
    let h = uptime / 3600;
    let m = (uptime % 3600) / 60;
    let s = uptime % 60;
    let uptime_str = format!("{h}h{m:02}m{s:02}s");

    let mode_str = match app.mode {
        DashMode::HttpClient => format!("HTTP ({})", app.server_url),
        DashMode::Standalone => "Standalone".to_string(),
    };

    let cal_str = if app.detector_calibrated {
        "YES"
    } else {
        "calibrating…"
    };
    let cal_color = if app.detector_calibrated {
        Color::Green
    } else {
        Color::Yellow
    };

    let text = vec![
        Line::from(vec![
            Span::raw(format!(" Ingested/s: {:.0}  │  ", app.ingested_per_sec)),
            Span::raw(format!("Anomaly: {:.2}%  │  ", app.anomaly_rate * 100.0)),
            Span::raw(format!("Cache: {:.1}%  │  ", app.cache_hit_rate * 100.0)),
            Span::raw(format!("Uptime: {uptime_str}")),
        ]),
        Line::from(vec![
            Span::raw(" Calibrated: "),
            Span::styled(cal_str, Style::default().fg(cal_color)),
            Span::raw(format!("  │  Mode: {mode_str}  │  [q] quit")),
        ]),
    ];

    let block = Block::default()
        .borders(Borders::ALL)
        .title(" Stats ")
        .title_alignment(Alignment::Left);
    let para = Paragraph::new(text).block(block);
    f.render_widget(para, area);
}