gled 2.28.4

gled is an application for creating animations and effects on artnet or dmx installations
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

use kanal::{Receiver, Sender, unbounded};
use once_cell::sync::OnceCell;
use std::sync::atomic::{AtomicBool, Ordering::Relaxed};
use std::time::{SystemTime, UNIX_EPOCH};

static STREAM_ENABLED: AtomicBool = AtomicBool::new(false);
static SENDER: OnceCell<Sender<MidiMonitorEvent>> = OnceCell::new();

#[derive(Clone, Debug, Default)]
pub struct MidiPortDiagnostics {
    pub port_name: String,
    pub input_connected: bool,
    pub output_connected: bool,
    pub input_connect_failed: u32,
    pub output_connect_failed: u32,
    pub message_count: u64,
}

#[derive(Clone, Debug)]
pub struct MidiMonitorEvent {
    pub timestamp_ms: u128,
    pub port_name: String,
    pub label: String,
    pub bytes: Vec<u8>,
}

pub fn init() -> Receiver<MidiMonitorEvent> {
    let (sender, receiver) = unbounded();
    let _ = SENDER.set(sender);
    receiver
}

pub fn set_streaming_enabled(enabled: bool) {
    STREAM_ENABLED.store(enabled, Relaxed);
}

pub fn push_event(port_name: &str, label: &str, bytes: &[u8]) {
    // Keep lifecycle diagnostics (connect/fail) even when the live stream is off.
    // Only raw midi traffic is gated to avoid filling the queue in the background.
    if label == "midi" && !STREAM_ENABLED.load(Relaxed) {
        return;
    }

    let event = MidiMonitorEvent {
        timestamp_ms: SystemTime::now()
            .duration_since(UNIX_EPOCH)
            .map_or(0, |d| d.as_millis()),
        port_name: port_name.to_owned(),
        label: label.to_owned(),
        bytes: bytes.to_vec(),
    };

    if let Some(sender) = SENDER.get() {
        let _ = sender.send(event);
    }
}