foxglove 0.23.2

Foxglove SDK
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

use bytes::{Buf, BufMut};

use crate::protocol::{BinaryPayload, ParseError};

/// Enables the device to compute its own round-trip time.
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
pub struct PingAck {
    /// Milliseconds since epoch.
    pub device_timestamp: u64,
}

impl<'a> BinaryPayload<'a> for PingAck {
    fn parse_payload(data: &'a [u8]) -> Result<Self, ParseError> {
        if data.len() < 8 {
            return Err(ParseError::BufferTooShort);
        }
        let mut buf = data;
        let device_timestamp = buf.get_u64_le();
        Ok(Self { device_timestamp })
    }

    fn payload_size(&self) -> usize {
        8
    }

    fn write_payload(&self, buf: &mut impl BufMut) {
        buf.put_u64_le(self.device_timestamp);
    }
}

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

    #[test]
    fn test_roundtrip() {
        let orig = PingAck {
            device_timestamp: 1_711_500_000_000,
        };
        let mut buf = Vec::new();
        orig.write_payload(&mut buf);
        let parsed = PingAck::parse_payload(&buf).unwrap();
        assert_eq!(parsed, orig);
    }

    #[test]
    fn test_buffer_too_short() {
        let result = PingAck::parse_payload(&[0x01, 0x02, 0x03]);
        assert!(result.is_err());
    }
}