localsend 0.2.2

A rust implementation of the localsend protocol
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

use crate::Client;

impl Client {
    pub async fn announce_multicast(&self) -> crate::error::Result<()> {
        let msg = self.device.to_json()?;
        let addr = self.multicast_addr.clone();
        self.socket.send_to(msg.as_bytes(), addr).await?;
        Ok(())
    }

    pub async fn listen_multicast(&self) -> crate::error::Result<()> {
        let mut buf = [0; 65536];
        println!("Socket local addr: {:?}", self.socket.local_addr()?);
        println!("Listening on multicast addr: {}", self.multicast_addr);

        loop {
            match self.socket.recv_from(&mut buf).await {
                Ok((size, src)) => {
                    let received_msg = String::from_utf8_lossy(&buf[..size]);
                    self.process_device(&received_msg, src).await;
                }
                Err(e) => {
                    eprintln!("Error receiving message: {}", e);
                    tokio::time::sleep(tokio::time::Duration::from_secs(1)).await;
                }
            }
        }
    }
}