fix: read terminating CLSE when installing APK

Cargo.toml

@@ -9,7 +9,7 @@ homepage = "https://github.com/cocool97/adb_client"
 keywords = ["adb", "android", "tcp", "usb"]
 license = "MIT"
 repository = "https://github.com/cocool97/adb_client"
-version = "2.1.13"
+version = "2.1.12"
 
 # To build locally when working on a new release
 [patch.crates-io]

adb_cli/src/models/reboot_type.rs

@@ -8,7 +8,6 @@ pub enum RebootTypeCommand {
     Recovery,
     Sideload,
     SideloadAutoReboot,
-    Fastboot,
 }
 
 impl From<RebootTypeCommand> for RebootType {
@@ -19,7 +18,6 @@ impl From<RebootTypeCommand> for RebootType {
             RebootTypeCommand::Recovery => RebootType::Recovery,
             RebootTypeCommand::Sideload => RebootType::Sideload,
             RebootTypeCommand::SideloadAutoReboot => RebootType::SideloadAutoReboot,
-            RebootTypeCommand::Fastboot => RebootType::Fastboot,
         }
     }
 }

adb_client/Cargo.toml

@@ -13,26 +13,22 @@ version.workspace = true
 base64 = { version = "0.22.1" }
 bincode = { version = "1.3.3" }
 byteorder = { version = "1.5.0" }
-chrono = { version = "0.4.40", default-features = false, features = ["std"] }
+chrono = { version = "0.4.40" }
 homedir = { version = "0.3.4" }
-image = { version = "0.25.5", default-features = false }
+image = { version = "0.25.5" }
+lazy_static = { version = "1.5.0" }
 log = { version = "0.4.26" }
-mdns-sd = { version = "0.13.9", default-features = false, features = [
+mdns-sd = { version = "0.13.2" }
-    "logging",
-] }
 num-bigint = { version = "0.8.4", package = "num-bigint-dig" }
 num-traits = { version = "0.2.19" }
 quick-protobuf = { version = "0.8.1" }
 rand = { version = "0.9.0" }
-rcgen = { version = "0.13.1", default-features = false, features = [
+rcgen = { version = "0.13.1" }
-    "aws_lc_rs",
-    "pem",
-] }
 regex = { version = "1.11.1", features = ["perf", "std", "unicode"] }
 rsa = { version = "0.9.7" }
 rusb = { version = "0.9.4", features = ["vendored"] }
-rustls = { version = "0.23.27" }
+rustls = { version = "0.23.22" }
-rustls-pki-types = { version = "1.11.0" }
+rustls-pki-types = "1.11.0"
 serde = { version = "1.0.216", features = ["derive"] }
 serde_repr = { version = "0.1.19" }
 sha1 = { version = "0.10.6", features = ["oid"] }

adb_client/src/device/commands/install.rs

@@ -2,7 +2,7 @@ use std::{fs::File, path::Path};
 
 use crate::{
     ADBMessageTransport, Result,
-    device::{MessageWriter, adb_message_device::ADBMessageDevice},
+    device::{MessageCommand, MessageWriter, adb_message_device::ADBMessageDevice},
     utils::check_extension_is_apk,
 };
 
@@ -30,6 +30,9 @@ impl<T: ADBMessageTransport> ADBMessageDevice<T> {
                     "APK file {} successfully installed",
                     apk_path.as_ref().display()
                 );
+                self.get_transport_mut()
+                    .read_message()?
+                    .assert_command(MessageCommand::Clse)?;
                 Ok(())
             }
             d => Err(crate::RustADBError::ADBRequestFailed(String::from_utf8(

adb_client/src/models/reboot_type.rs

@@ -13,8 +13,6 @@ pub enum RebootType {
     Sideload,
     /// Same as `Sideload` but reboots after sideloading
     SideloadAutoReboot,
-    /// Reboots to fastboot
-    Fastboot,
 }
 
 impl Display for RebootType {
@@ -25,7 +23,6 @@ impl Display for RebootType {
             RebootType::Recovery => write!(f, "recovery"),
             RebootType::Sideload => write!(f, "sideload"),
             RebootType::SideloadAutoReboot => write!(f, "sideload-auto-reboot"),
-            RebootType::Fastboot => write!(f, "fastboot"),
         }
     }
 }

adb_client/src/server/commands/devices.rs

@@ -36,7 +36,7 @@ impl ADBServer {
                 break;
             }
 
-            vec_devices.push(DeviceLong::try_from(device)?);
+            vec_devices.push(DeviceLong::try_from(device.to_vec())?);
         }
 
         Ok(vec_devices)

adb_client/src/server/models/device_long.rs

@@ -6,7 +6,7 @@ use crate::{DeviceState, RustADBError};
 use regex::bytes::Regex;
 
 static DEVICES_LONG_REGEX: LazyLock<Regex> = LazyLock::new(|| {
-    Regex::new(r"^(?P<identifier>\S+)\s+(?P<state>\w+)\s+(usb:(?P<usb1>\S+)|(?P<usb2>\S+))?\s*(product:(?P<product>\S+)\s+model:(?P<model>\w+)\s+device:(?P<device>\S+)\s+)?transport_id:(?P<transport_id>\d+)$").expect("cannot build devices long regex")
+    Regex::new(r"^(?P<identifier>\S+)\s+(?P<state>\w+)\s+(usb:(?P<usb1>\S+)|(?P<usb2>\S+))?\s*(product:(?P<product>\w+)\s+model:(?P<model>\w+)\s+device:(?P<device>\w+)\s+)?transport_id:(?P<transport_id>\d+)$").expect("cannot build devices long regex")
 });
 
 /// Represents a new device with more informations.
@@ -44,12 +44,12 @@ impl Display for DeviceLong {
     }
 }
 
-impl TryFrom<&[u8]> for DeviceLong {
+impl TryFrom<Vec<u8>> for DeviceLong {
     type Error = RustADBError;
 
-    fn try_from(value: &[u8]) -> Result<Self, Self::Error> {
+    fn try_from(value: Vec<u8>) -> Result<Self, Self::Error> {
         let groups = DEVICES_LONG_REGEX
-            .captures(value)
+            .captures(&value)
             .ok_or(RustADBError::RegexParsingError)?;
 
         Ok(DeviceLong {
@@ -98,17 +98,3 @@ impl TryFrom<&[u8]> for DeviceLong {
         })
     }
 }
-
-#[test]
-fn test_static_devices_long() {
-    let inputs = [
-        "7a5158f05122195aa       device 1-5 product:gts210vewifixx model:SM_T813 device:gts210vewifi transport_id:4",
-        "n311r05e               device usb:0-1.5 product:alioth model:M2012K11AC device:alioth transport_id:58",
-        "192.168.100.192:5555   device product:alioth model:M2012K11AC device:alioth transport_id:97",
-        "emulator-5554          device product:sdk_gphone64_arm64 model:sdk_gphone64_arm64 device:emu64a transport_id:101",
-        "QQ20131020250511       device 20-4 product:NOH-AN00 model:NOH_AN00 device:HWNOH transport_id:3",
-    ];
-    for input in inputs {
-        DeviceLong::try_from(input.as_bytes()).expect(&format!("cannot parse input: '{input}'"));
-    }
-}

tests/tests.rs

@@ -0,0 +1,101 @@
+#[cfg(test)]
+mod tests {
+    use std::io::Cursor;
+
+    use adb_client::{ADBServer, ADBServerDevice, DeviceLong};
+    use rand::Rng;
+
+    fn new_client() -> ADBServer {
+        ADBServer::default()
+    }
+
+    fn new_device() -> ADBServerDevice {
+        let mut client = new_client();
+        return client.get_device().expect("cannot get device");
+    }
+
+    #[test]
+    fn test_version() {
+        let mut adb = new_client();
+        adb.version().expect("cannot get adb version");
+    }
+
+    #[test]
+    fn test_shell_commands() {
+        let mut device = new_device();
+
+        device.shell_command(["ls"]).expect("error while executing `ls` command");
+        device.shell_command(["pwd"]).expect("error while executing `pwd` command");
+    }
+
+    #[test]
+    fn test_devices() {
+        let mut adb = new_client();
+        adb.devices().expect("cannot list devices");
+    }
+
+    #[test]
+    fn test_devices_long() {
+        let mut adb = new_client();
+        adb.devices_long().expect("cannot list devices long");
+    }
+
+    #[test]
+    fn test_static_devices_long() {
+        let inputs = ["7a5158f05122195aa       device 1-5 product:gts210vewifixx model:SM_T813 device:gts210vewifi transport_id:4",
+        "n311r05e               device usb:0-1.5 product:alioth model:M2012K11AC device:alioth transport_id:58",
+        "192.168.100.192:5555   device product:alioth model:M2012K11AC device:alioth transport_id:97",
+        "emulator-5554          device product:sdk_gphone64_arm64 model:sdk_gphone64_arm64 device:emu64a transport_id:101"];
+        for input in inputs {
+            DeviceLong::try_from(input.as_bytes().to_vec())
+                .expect(&format!("cannot parse input: '{input}'"));
+        }
+    }
+
+    #[test]
+    fn test_send_recv() {
+        // Create random "Reader" in memory
+        let mut key = [0u8; 1000];
+        rand::thread_rng().fill(&mut key[..]);
+        let mut c: Cursor<Vec<u8>> = Cursor::new(key.to_vec());
+
+        let mut device = new_device();
+
+        const TEST_FILENAME: &'static str = "/data/local/tmp/test_file";
+        // Send it
+        device
+            .send(&mut c, TEST_FILENAME)
+            .expect("cannot send file");
+
+        // Pull it to memory
+        let mut res = vec![];
+        device
+            .recv(TEST_FILENAME, &mut res)
+            .expect("cannot recv file");
+
+        // diff
+        assert_eq!(c.get_ref(), &res);
+
+        device
+            .shell_command::<&str>([format!("rm {TEST_FILENAME}").as_str()])
+            .expect("cannot remove test file");
+    }
+
+    #[test]
+    fn multiple_connexions() {
+        let mut connection = new_client();
+
+        for _ in 0..2 {
+            let _ = connection.devices().expect("cannot get version");
+        }
+    }
+
+    #[test]
+    fn command_emulator() {
+        let mut connection = new_client();
+        let mut emulator = connection
+            .get_emulator_device()
+            .expect("no emulator running");
+        emulator.hello().expect("cannot hello");
+    }
+}