fix: replace rusb GlobalContext with explicit Context::new() to prevent panics

rusb's GlobalContext uses Once::call_once internally, which panics if
libusb_init fails (e.g. in CI servers, containers, or environments
without USB support). Replace all uses with explicit rusb::Context::new()
which returns a Result instead of panicking.

Author: zbowling

adb_client/src/message_devices/usb/usb_transport.rs

@@ -1,7 +1,7 @@
 use std::{sync::Arc, time::Duration};
 
 use rusb::{
-    Device, DeviceHandle, Direction, GlobalContext, TransferType,
+    Context, Device, DeviceHandle, Direction, TransferType, UsbContext,
     constants::LIBUSB_CLASS_VENDOR_SPEC,
 };
 
@@ -25,8 +25,8 @@ struct Endpoint {
 /// Transport running on USB
 #[derive(Debug, Clone)]
 pub struct USBTransport {
-    device: Device<GlobalContext>,
-    handle: Option<Arc<DeviceHandle<GlobalContext>>>,
+    device: Device<Context>,
+    handle: Option<Arc<DeviceHandle<Context>>>,
     read_endpoint: Option<Endpoint>,
     write_endpoint: Option<Endpoint>,
 }
@@ -35,7 +35,8 @@ impl USBTransport {
     /// Instantiate a new [`USBTransport`].
     /// Only the first device with given `vendor_id` and `product_id` is returned.
     pub fn new(vendor_id: u16, product_id: u16) -> Result<Self> {
-        for device in rusb::devices()?.iter() {
+        let context = Context::new()?;
+        for device in context.devices()?.iter() {
             if let Ok(descriptor) = device.device_descriptor()
                 && descriptor.vendor_id() == vendor_id
                 && descriptor.product_id() == product_id
@@ -51,9 +52,9 @@ impl USBTransport {
 
     /// Instantiate a new [`USBTransport`] from a [`rusb::Device`].
     ///
-    /// Devices can be enumerated using [`rusb::devices()`] and then filtered out to get desired device.
+    /// Devices can be enumerated using [`rusb::Context::devices()`] and then filtered out to get desired device.
     #[must_use]
-    pub const fn new_from_device(rusb_device: rusb::Device<GlobalContext>) -> Self {
+    pub const fn new_from_device(rusb_device: rusb::Device<Context>) -> Self {
         Self {
             device: rusb_device,
             handle: None,
@@ -70,7 +71,7 @@ impl USBTransport {
         Ok(self.device.device_descriptor().map(|d| d.product_id())?)
     }
 
-    pub(crate) fn get_raw_connection(&self) -> Result<Arc<DeviceHandle<GlobalContext>>> {
+    pub(crate) fn get_raw_connection(&self) -> Result<Arc<DeviceHandle<Context>>> {
         self.handle
             .as_ref()
             .ok_or(RustADBError::IOError(std::io::Error::new(
@@ -99,7 +100,7 @@ impl USBTransport {
             )))
     }
 
-    fn configure_endpoint(handle: &DeviceHandle<GlobalContext>, endpoint: &Endpoint) -> Result<()> {
+    fn configure_endpoint(handle: &DeviceHandle<Context>, endpoint: &Endpoint) -> Result<()> {
         match handle.claim_interface(endpoint.iface) {
             Ok(()) => Ok(()),
             // busy state likely indicates an ADB server is running and has taken the lock over the device
@@ -108,7 +109,7 @@ impl USBTransport {
         }
     }
 
-    fn find_endpoints(handle: &DeviceHandle<GlobalContext>) -> Result<(Endpoint, Endpoint)> {
+    fn find_endpoints(handle: &DeviceHandle<Context>) -> Result<(Endpoint, Endpoint)> {
         let mut read_endpoint: Option<Endpoint> = None;
         let mut write_endpoint: Option<Endpoint> = None;
 

adb_client/src/message_devices/usb/utils.rs

@@ -1,4 +1,4 @@
-use rusb::{Device, DeviceDescriptor, UsbContext, constants::LIBUSB_CLASS_VENDOR_SPEC};
+use rusb::{Context, Device, DeviceDescriptor, UsbContext, constants::LIBUSB_CLASS_VENDOR_SPEC};
 
 use crate::{Result, RustADBError};
 
@@ -17,7 +17,8 @@ pub struct ADBDeviceInfo {
 pub fn find_all_connected_adb_devices() -> Result<Vec<ADBDeviceInfo>> {
     let mut found_devices = vec![];
 
-    for device in rusb::devices()?.iter() {
+    let context = Context::new()?;
+    for device in context.devices()?.iter() {
         let Ok(des) = device.device_descriptor() else {
             continue;
         };