radio-utils-protocol 0.1.0

OpenHPSDR Protocol 1 client library for Hermes / Hermes Lite 2
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

use std::net::SocketAddr;

use crate::Result;

/// Transport abstraction for UDP communication.
/// Currently only native UDP is supported. A WebSocket relay transport
/// can be added for WASM environments.
pub struct UdpTransport {
    socket: tokio::net::UdpSocket,
}

impl UdpTransport {
    pub async fn bind(addr: &str) -> Result<Self> {
        let socket = tokio::net::UdpSocket::bind(addr).await?;
        socket.set_broadcast(true)?;
        Ok(Self { socket })
    }

    pub async fn bind_any() -> Result<Self> {
        Self::bind("0.0.0.0:0").await
    }

    pub async fn send_to(&self, buf: &[u8], addr: SocketAddr) -> Result<()> {
        self.socket.send_to(buf, addr).await?;
        Ok(())
    }

    pub async fn recv_from(&self, buf: &mut [u8]) -> Result<(usize, SocketAddr)> {
        let (len, addr) = self.socket.recv_from(buf).await?;
        Ok((len, addr))
    }

    /// Non-blocking receive. Returns `Err` if no data is available.
    pub fn try_recv_from(
        &self,
        buf: &mut [u8],
    ) -> std::result::Result<(usize, SocketAddr), std::io::Error> {
        self.socket.try_recv_from(buf)
    }

    pub fn local_addr(&self) -> Result<SocketAddr> {
        Ok(self.socket.local_addr()?)
    }

    pub fn socket(&self) -> &tokio::net::UdpSocket {
        &self.socket
    }
}