src/cloud.rs

@@ -474,6 +474,7 @@ mod test {
     use super::Cloud;
 
     #[tokio::test]
+    #[serial]
     async fn reroute() -> Result<()> {
         let mut cloud = Cloud::new("michaelh.95@t-online.de", "Hoda.semi1")?;
 
@@ -483,6 +484,7 @@ 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,6 +5,7 @@ pub trait RequestSerializer {
     fn serialize(&self) -> Vec<u8>;
 }
 
+#[derive(Clone)]
 pub struct CommandRequest {
     #[cfg(debug_assertions)]
     pub name: &'static str,

src/device.rs

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