rvideo 0.5.3

Real-time video server for embedded apps
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

use std::{
    io::{Cursor, Read, Write},
    net::{TcpStream, ToSocketAddrs},
    time::Duration,
};

use binrw::BinRead;

use crate::{Error, Frame, Greetings, StreamInfo, StreamSelect};

/// Synchronous client
pub struct Client {
    stream: TcpStream,
    streams_available: u16,
    ready: bool,
}

impl Client {
    /// Connect to a server and create a client instance
    pub fn connect(addr: impl ToSocketAddrs, timeout: Duration) -> Result<Self, Error> {
        let mut stream = TcpStream::connect_timeout(
            &addr
                .to_socket_addrs()?
                .next()
                .ok_or(Error::InvalidAddress)?,
            timeout,
        )?;
        stream.set_read_timeout(Some(timeout))?;
        stream.set_write_timeout(Some(timeout))?;
        stream.set_nodelay(true)?;
        let mut buf = [0u8; 4];
        stream.read_exact(&mut buf)?;
        let greetings = Greetings::read(&mut Cursor::new(&buf))?;
        if greetings.api_version != crate::API_VERSION {
            return Err(Error::ApiVersion(greetings.api_version));
        }
        Ok(Self {
            stream,
            streams_available: greetings.streams_available,
            ready: false,
        })
    }
    /// Get the number of streams available
    pub fn streams_available(&self) -> u16 {
        self.streams_available
    }
    /// Select a stream on the server. As soon as a stream is selected, the client is ready to
    /// receive frames (use the client as an iterator).
    pub fn select_stream(&mut self, stream_id: u16, max_fps: u8) -> Result<StreamInfo, Error> {
        let stream_select = StreamSelect { stream_id, max_fps };
        let mut writer = Cursor::new(Vec::new());
        binrw::BinWrite::write(&stream_select, &mut writer)?;
        self.stream.write_all(&writer.into_inner())?;
        let mut buf = [0u8; 7];
        self.stream.read_exact(&mut buf)?;
        let stream_info = StreamInfo::read(&mut Cursor::new(&buf))?;
        if stream_info.id == stream_id {
            self.ready = true;
            Ok(stream_info)
        } else {
            Err(Error::InvalidStream)
        }
    }
}

impl Iterator for Client {
    type Item = Result<Frame, Error>;
    fn next(&mut self) -> Option<Self::Item> {
        if !self.ready {
            return Some(Err(Error::NotReady));
        }
        let mut len_buf = [0u8; 4];
        if let Err(e) = self.stream.read_exact(&mut len_buf) {
            return Some(Err(e.into()));
        }
        let Ok(len) = usize::try_from(u32::from_le_bytes(len_buf)) else {
            return Some(Err(Error::FrameMetaDataTooLarge));
        };
        let metadata = if len > 0 {
            let mut buf = vec![0u8; len];
            if let Err(e) = self.stream.read_exact(&mut buf) {
                return Some(Err(e.into()));
            }
            Some(buf)
        } else {
            None
        };
        if let Err(e) = self.stream.read_exact(&mut len_buf) {
            return Some(Err(e.into()));
        }
        let Ok(len) = usize::try_from(u32::from_le_bytes(len_buf)) else {
            return Some(Err(Error::FrameDataTooLarge));
        };
        let mut data = vec![0u8; len];
        if let Err(e) = self.stream.read_exact(&mut data) {
            return Some(Err(e.into()));
        }
        if let Err(e) = self.stream.write_all(&[0u8; 1]) {
            return Some(Err(e.into()));
        }
        Some(Ok(Frame {
            metadata: metadata.map(Into::into),
            data: data.into(),
        }))
    }
}