Update Rust crate if-addrs to 0.10.2 #2

Merged
hodasemi merged 2 commits from renovate/if-addrs-0.x into master 2023-10-07 05:06:27 +00:00
4 changed files with 21 additions and 14 deletions

View file

@ -7,7 +7,7 @@ edition = "2021"
[dependencies] [dependencies]
anyhow = { version = "1.0.75", features = ["backtrace"] } anyhow = { version = "1.0.75", features = ["backtrace"] }
if-addrs = "0.10.1" if-addrs = "0.10.2"
rand = "0.8.5" rand = "0.8.5"
chrono = "0.4.31" chrono = "0.4.31"
serde = { version = "1.0", features = ["derive"] } serde = { version = "1.0", features = ["derive"] }

View file

@ -474,6 +474,7 @@ mod test {
use super::Cloud; use super::Cloud;
#[tokio::test] #[tokio::test]
#[serial]
async fn reroute() -> Result<()> { async fn reroute() -> Result<()> {
let mut cloud = Cloud::new("michaelh.95@t-online.de", "Hoda.semi1")?; let mut cloud = Cloud::new("michaelh.95@t-online.de", "Hoda.semi1")?;
@ -483,6 +484,7 @@ mod test {
} }
#[tokio::test] #[tokio::test]
#[serial]
async fn login_id() -> Result<()> { async fn login_id() -> Result<()> {
let mut cloud = Cloud::new("michaelh.95@t-online.de", "Hoda.semi1")?; let mut cloud = Cloud::new("michaelh.95@t-online.de", "Hoda.semi1")?;

View file

@ -5,6 +5,7 @@ pub trait RequestSerializer {
fn serialize(&self) -> Vec<u8>; fn serialize(&self) -> Vec<u8>;
} }
#[derive(Clone)]
pub struct CommandRequest { pub struct CommandRequest {
#[cfg(debug_assertions)] #[cfg(debug_assertions)]
pub name: &'static str, pub name: &'static str,

View file

@ -124,7 +124,8 @@ impl Device {
} }
for cmd in cmds { for cmd in cmds {
self.build_send(cmd)?; 'sending: loop {
self.build_send(cmd.clone())?;
loop { loop {
let mut buf = [0; 512]; let mut buf = [0; 512];
@ -134,15 +135,16 @@ impl Device {
}; };
if bytes_read == 0 { if bytes_read == 0 {
bail!("socket error"); break;
} }
match self.parse_message(&buf[..bytes_read])? { match self.parse_message(&buf[..bytes_read])? {
ParseMessage::Success => break, ParseMessage::Success => break 'sending,
ParseMessage::Padding => continue, ParseMessage::Padding => continue,
} }
} }
} }
}
Ok(()) Ok(())
} }
@ -252,6 +254,7 @@ mod test {
use crate::{device::Device, devices::AttributeValue, Cloud, Startup}; use crate::{device::Device, devices::AttributeValue, Cloud, Startup};
#[tokio::test] #[tokio::test]
#[serial]
async fn verify_hex() -> Result<()> { async fn verify_hex() -> Result<()> {
let devices = Startup::discover().await?; let devices = Startup::discover().await?;
@ -272,6 +275,7 @@ mod test {
} }
#[tokio::test] #[tokio::test]
#[serial]
async fn connect_py_token() -> Result<()> { async fn connect_py_token() -> Result<()> {
let devices = Startup::discover().await?; let devices = Startup::discover().await?;