csi-webclient 0.1.3

Desktop egui client for csi-webserver REST/WebSocket control and CSI stream monitoring
Documentation 
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 crate::state::{DeviceAction, DeviceState};

/// Max height of the per-device frame list (keeps multi-device view usable).
const FRAME_LIST_HEIGHT: f32 = 220.0;

/// Render the stream inspection view for one device.
///
/// Recording start/stop are queued into `actions`. The shared export directory
/// is edited once at the top of the Stream tab (see [`render_export_dir`]).
pub fn render(ui: &mut egui::Ui, device: &mut DeviceState, actions: &mut Vec<DeviceAction>) {
    ui.add(
        egui::Label::new(format!("Stream — {}", device.id))
            .wrap(),
    );
    ui.add_space(8.0);

    ui.horizontal_wrapped(|ui| {
        ui.checkbox(&mut device.auto_scroll_stream, "Auto-scroll");
        ui.label(format!("Frames: {}", device.frames_received));
        ui.label(format!("Bytes: {}", device.bytes_received));
    });

    render_recording_controls(ui, device, actions);

    ui.add_space(8.0);
    ui.strong("Recent frames");
    ui.add_space(4.0);

    egui::ScrollArea::vertical()
        .id_salt("stream_frames_scroll")
        .auto_shrink([false, false])
        .max_height(FRAME_LIST_HEIGHT)
        .stick_to_bottom(device.auto_scroll_stream)
        .show(ui, |ui| {
            ui.set_width(ui.available_width());
            if device.recent_frames.is_empty() {
                ui.label("No frames yet — connect the WebSocket and start collection.");
                return;
            }

            ui.horizontal_wrapped(|ui| {
                ui.strong("Time");
                ui.label("·");
                ui.strong("Len");
                ui.label("·");
                ui.strong("Preview (hex)");
            });
            ui.separator();

            for frame in device.recent_frames.iter().rev().take(250) {
                ui.horizontal_wrapped(|ui| {
                    ui.label(&frame.timestamp);
                    ui.label(format!("{} B", frame.length));
                    ui.add(
                        egui::Label::new(
                            egui::RichText::new(&frame.preview_hex).monospace(),
                        )
                        .wrap(),
                    );
                });
                ui.add_space(2.0);
            }
        });
}

/// Shared Parquet output directory (shown once above all device panels).
pub fn render_export_dir(ui: &mut egui::Ui, export_dir: &mut String) {
    ui.strong("Export to Parquet");
    ui.horizontal_wrapped(|ui| {
        ui.label("Output dir");
        let field_w = (ui.available_width() - 80.0).clamp(120.0, 480.0);
        ui.add(egui::TextEdit::singleline(export_dir).desired_width(field_w));
    });
}

/// Per-device recording start/stop and status.
fn render_recording_controls(
    ui: &mut egui::Ui,
    device: &DeviceState,
    actions: &mut Vec<DeviceAction>,
) {
    ui.add_space(6.0);
    ui.strong("Recording");
    ui.add_space(4.0);

    let chip_known = device
        .latest_info
        .as_ref()
        .and_then(|i| i.chip.as_deref())
        .is_some();

    ui.horizontal_wrapped(|ui| {
        if device.recording {
            if ui.button("⏹ Stop Recording").clicked() {
                actions.push(DeviceAction::StopRecording);
            }
            ui.colored_label(
                egui::Color32::from_rgb(220, 80, 80),
                format!("● Recording — {} frame(s)", device.recorded_frames),
            );
            if device.record_decode_errors > 0 {
                ui.label(format!("({} undecodable)", device.record_decode_errors));
            }
        } else {
            let start = ui.add_enabled(chip_known, egui::Button::new("⏺ Start Recording"));
            if start.clicked() {
                actions.push(DeviceAction::StartRecording);
            }
            if !chip_known {
                ui.label("— chip unknown; Fetch Info first");
            } else if !device.ws_connected {
                ui.label("— connect WebSocket to capture");
            }
        }
    });

    if let Some(path) = &device.record_path {
        let label = if device.recording {
            format!("Writing: {path}")
        } else {
            format!("Saved: {path}")
        };
        ui.add(egui::Label::new(label).wrap());
    }
}