chirpstack_api 4.19.0

ChirpStack Protobuf / gRPC API definitions.
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

include!(concat!(env!("OUT_DIR"), "/internal/internal.rs"));
#[cfg(feature = "json")]
include!(concat!(env!("OUT_DIR"), "/internal/internal.serde.rs"));

impl DeviceSession {
    pub fn get_a_f_cnt_down(&self) -> u32 {
        if self.mac_version().to_string().starts_with("1.0") {
            // LoRaWAN 1.0
            self.n_f_cnt_down
        } else {
            // LoRaWAN 1.1
            self.a_f_cnt_down
        }
    }

    pub fn set_a_f_cnt_down(&mut self, f_cnt: u32) {
        if self.mac_version().to_string().starts_with("1.0") {
            // LoRaWAN 1.0
            self.n_f_cnt_down = f_cnt;
        } else {
            // LoRaWAN 1.1
            self.a_f_cnt_down = f_cnt;
        }
    }

    pub fn append_gateway_rx_info_history(
        &mut self,
        item: GatewayRxInfoHistory,
        max_history: usize,
    ) {
        if self.gateway_rx_info_history.len() >= max_history {
            let start_index = self.gateway_rx_info_history.len() - max_history + 1;
            self.gateway_rx_info_history = self.gateway_rx_info_history[start_index..].to_vec();
        }

        self.gateway_rx_info_history.push(item);
    }
}

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

    #[test]
    fn test_append_gateway_rx_info_history() {
        let mut ds = DeviceSession::default();

        for _i in 0..10 {
            ds.append_gateway_rx_info_history(
                GatewayRxInfoHistory {
                    dr: 0,
                    items: vec![],
                },
                8,
            );
        }

        assert_eq!(8, ds.gateway_rx_info_history.len());
    }
}