.

neptun/src/device/api.rs

@@ -128,6 +128,7 @@ pub fn api_exec<R: Read, W: Write>(
         };
         // The protocol requires to return an error code as the response, or zero on success
         writeln!(writer, "errno={}\n", status).ok();
+        _ = writer.flush();
         cmd.clear();
     }
 }

neptun/src/device/integration_tests/mod.rs

@@ -398,26 +398,32 @@ mod tests {
             }
         }
 
+        fn read_until_double_new_line(&self, socket: &mut UnixStream) -> String {
+            let mut reader = BufReader::new(socket);
+            let mut ret = Vec::new();
+            loop {
+                if reader.read_until(b'\n', &mut ret).is_ok_and(|n| n == 1) {
+                    break
+                }
+            }
+            String::from_utf8(ret).unwrap()
+        }
+
         /// Issue a get command on the interface
         fn wg_get(&self) -> String {
             let path = format!("/var/run/wireguard/{}.sock", self.name);
 
             let mut socket = UnixStream::connect(path).unwrap();
             write!(socket, "get=1\n\n").unwrap();
-
-            let mut ret = String::new();
-            socket.read_to_string(&mut ret).unwrap();
-            ret
+            self.read_until_double_new_line(&mut socket)
         }
 
         /// Issue a set command on the interface
         fn wg_set(&self, setting: &str) -> String {
             let path = format!("/var/run/wireguard/{}.sock", self.name);
             let mut socket = UnixStream::connect(path).unwrap();
             write!(socket, "set=1\n{}\n\n", setting).unwrap();
-
-            let mut ret = String::new();
-            socket.read_to_string(&mut ret).unwrap();
+            let ret = self.read_until_double_new_line(&mut socket);
             ret
         }