abtop 0.4.6

AI agent monitor for your terminal
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

use crate::app::App;
use crate::locale::t;
use crate::theme::Theme;
use ratatui::layout::Rect;
use ratatui::style::{Modifier, Style};
use ratatui::text::{Line, Span};
use ratatui::widgets::Paragraph;
use ratatui::Frame;

use super::{btop_block_active, grad_at, make_gradient};

pub(crate) fn draw_ports_panel(f: &mut Frame, app: &App, area: Rect, theme: &Theme) {
    draw_ports_panel_active(f, app, area, theme, false);
}

pub(crate) fn draw_ports_panel_active(
    f: &mut Frame,
    app: &App,
    area: Rect,
    theme: &Theme,
    active: bool,
) {
    // Collect (port, project_name, session_id_short)
    let mut all_ports: Vec<(u16, String, String)> = Vec::new();
    for session in &app.sessions {
        let sid_short = if session.session_id.len() >= 8 {
            &session.session_id[..8]
        } else {
            &session.session_id
        };
        for child in &session.children {
            if let Some(port) = child.port {
                all_ports.push((port, session.project_name.clone(), sid_short.to_string()));
            }
        }
    }
    all_ports.sort_by_key(|p| p.0);

    let mut port_counts: std::collections::HashMap<u16, usize> = std::collections::HashMap::new();
    for (port, _, _) in &all_ports {
        *port_counts.entry(*port).or_default() += 1;
    }

    let proc_grad = make_gradient(
        theme.proc_grad.start,
        theme.proc_grad.mid,
        theme.proc_grad.end,
    );

    let header_style = Style::default()
        .fg(theme.main_fg)
        .add_modifier(Modifier::BOLD);
    let port_label = t("ports.port");
    let session_label = t("ports.session");
    let mut lines = vec![Line::from(vec![
        Span::styled(format!(" {}  ", port_label), header_style),
        Span::styled(session_label, header_style),
    ])];
    for (port, proj, sid) in &all_ports {
        let conflict = port_counts.get(port).copied().unwrap_or(0) > 1;
        let color = if conflict {
            grad_at(&proc_grad, 100.0)
        } else {
            theme.proc_misc
        };
        let warn = if conflict { " ⚠" } else { "" };
        let session_label_text = format!("{} {}{}", proj, sid, warn);
        lines.push(Line::from(vec![
            Span::styled(format!(" :{:<5}", port), Style::default().fg(color)),
            Span::styled(session_label_text, Style::default().fg(theme.main_fg)),
        ]));
    }

    // Orphan ports: processes whose parent session has ended but port is still open
    let orphan_color = grad_at(&proc_grad, 100.0);
    let orphan_label = t("ports.orphan");
    for orphan in &app.orphan_ports {
        let session_label_text = format!("{} ⚠{}", orphan.project_name, orphan_label);
        lines.push(Line::from(vec![
            Span::styled(
                format!(" :{:<5}", orphan.port),
                Style::default().fg(orphan_color),
            ),
            Span::styled(session_label_text, Style::default().fg(orphan_color)),
        ]));
    }

    let has_orphans = !app.orphan_ports.is_empty();

    let no_open_ports = t("ports.no_open_ports");
    if lines.len() <= 1 {
        lines.push(Line::from(Span::styled(
            format!(" {}", no_open_ports),
            Style::default().fg(theme.inactive_fg),
        )));
    }

    let kill_orphans = t("ports.kill_orphans");
    if has_orphans {
        lines.push(Line::from(Span::styled(
            format!(" {}", kill_orphans),
            Style::default().fg(theme.inactive_fg),
        )));
    }

    let block = btop_block_active("ports", "⁵", theme.net_box, theme, active);
    f.render_widget(Paragraph::new(lines).block(block), area);
}