openipc-core 0.1.33

Shared OpenIPC FPV packet, RTP, and Realtek RX parsing logic
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

//! WiFi channel/frequency conversion and sweep-list parsing.

/// Map a 2.4 GHz or 5 GHz center frequency in MHz to a WiFi channel.
pub const fn frequency_to_channel(frequency_mhz: u16) -> Option<u8> {
    if frequency_mhz == 2484 {
        return Some(14);
    }
    if frequency_mhz >= 2412 && frequency_mhz <= 2472 {
        return Some(((frequency_mhz - 2407) / 5) as u8);
    }
    if frequency_mhz >= 5000 && frequency_mhz <= 5895 {
        return Some(((frequency_mhz - 5000) / 5) as u8);
    }
    None
}

/// Map a WiFi channel to its center frequency in MHz.
pub const fn channel_to_frequency(channel: u8) -> Option<u16> {
    if channel == 0 {
        None
    } else if channel == 14 {
        Some(2484)
    } else if channel <= 13 {
        Some(2407 + 5 * channel as u16)
    } else if channel <= 179 {
        Some(5000 + 5 * channel as u16)
    } else {
        None
    }
}

/// Expand a Devourer-compatible channel or frequency sweep specification.
///
/// Tokens are comma separated and may be individual channels (`1,6,11`),
/// inclusive channel ranges (`36-48/4`), or MHz ranges (`5170-5250/5`).
/// Invalid and out-of-band bins are skipped, matching Devourer's diagnostic
/// sweep grammar.
pub fn parse_channel_sweep(spec: &str) -> Vec<u8> {
    let mut channels = Vec::new();
    for raw_token in spec.split(',') {
        let mut token = raw_token.trim();
        if token.is_empty() {
            continue;
        }
        let mut step = 1u32;
        if let Some((range, raw_step)) = token.split_once('/') {
            token = range;
            step = parse_integer(raw_step).unwrap_or(1).max(1);
        }
        let Some((raw_start, raw_end)) = token.split_once('-') else {
            if let Some(channel) = parse_integer(token)
                .and_then(|value| u8::try_from(value).ok())
                .filter(|channel| *channel > 0)
            {
                channels.push(channel);
            }
            continue;
        };
        let (Some(start), Some(end)) = (parse_integer(raw_start), parse_integer(raw_end)) else {
            continue;
        };
        if start == 0 || end < start {
            continue;
        }
        let frequencies = start >= 1_000;
        if frequencies {
            step = step.max(5);
        }
        let mut value = start;
        while value <= end {
            let channel = if frequencies {
                u16::try_from(value).ok().and_then(frequency_to_channel)
            } else {
                u8::try_from(value).ok().filter(|channel| *channel > 0)
            };
            if let Some(channel) = channel {
                channels.push(channel);
            }
            let Some(next) = value.checked_add(step) else {
                break;
            };
            value = next;
        }
    }
    channels
}

fn parse_integer(value: &str) -> Option<u32> {
    let value = value.trim();
    value
        .strip_prefix("0x")
        .or_else(|| value.strip_prefix("0X"))
        .map_or_else(
            || value.parse().ok(),
            |hex| u32::from_str_radix(hex, 16).ok(),
        )
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn maps_wifi_channels_and_frequencies_like_devourer() {
        assert_eq!(frequency_to_channel(2412), Some(1));
        assert_eq!(frequency_to_channel(2484), Some(14));
        assert_eq!(frequency_to_channel(5180), Some(36));
        assert_eq!(frequency_to_channel(4900), None);
        assert_eq!(channel_to_frequency(1), Some(2412));
        assert_eq!(channel_to_frequency(14), Some(2484));
        assert_eq!(channel_to_frequency(36), Some(5180));
    }

    #[test]
    fn expands_devourer_sweep_grammar() {
        assert_eq!(parse_channel_sweep("1,6,11"), [1, 6, 11]);
        assert_eq!(parse_channel_sweep("36-48/4"), [36, 40, 44, 48]);
        assert_eq!(parse_channel_sweep("0x24-0x30/0x4"), [36, 40, 44, 48]);
        assert_eq!(parse_channel_sweep("5170-5250/20"), [34, 38, 42, 46, 50]);
        assert!(parse_channel_sweep("bad,0,500-100").is_empty());
    }
}