Cargo.toml

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

src/cloud.rs

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

src/command/request.rs

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

src/device.rs

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