cargo fmt run

Author: reedstrm

src/handlers.rs

@@ -39,16 +39,19 @@ pub struct SubscriptionFlags {
 
 impl SubscriptionFlags {
     pub fn none() -> Self {
-        SubscriptionFlags { regular: false, raw: false }
+        SubscriptionFlags {
+            regular: false,
+            raw: false,
+        }
     }
-    
+
     pub fn from_flags(flags: u32) -> Self {
         SubscriptionFlags {
             regular: flags == 0 || (flags & SUBSCRIPTION_RAW_ADVERTISEMENTS) == 0,
             raw: (flags & SUBSCRIPTION_RAW_ADVERTISEMENTS) != 0,
         }
     }
-    
+
     pub fn is_subscribed(&self) -> bool {
         self.regular || self.raw
     }
@@ -251,15 +254,15 @@ pub async fn subscribe_bluetooth_le_advertisements_request(
         "Handling SubscribeBluetoothLEAdvertisementsRequest from {}",
         stream.peer_addr()?.ip()
     );
-    
+
     let req = SubscribeBluetoothLEAdvertisementsRequest::parse_from_bytes(payload)?;
     let subscription_flags = SubscriptionFlags::from_flags(req.flags);
-    
+
     info!(
         "BLE advertisement subscription flags: {:?} (raw flags: 0x{:02x})",
         subscription_flags, req.flags
     );
-    
+
     Ok(subscription_flags)
 }
 

src/main.rs

@@ -50,7 +50,10 @@ async fn main() -> std::io::Result<()> {
 
     // Validate HCI adapter exists before proceeding
     if utils::get_bt_mac(cli.hci).is_none() {
-        log::error!("Bluetooth adapter hci{} does not exist or is not accessible", cli.hci);
+        log::error!(
+            "Bluetooth adapter hci{} does not exist or is not accessible",
+            cli.hci
+        );
         log::error!("Fatal: Check available adapters with 'hciconfig' or 'bluetoothctl list'");
         std::process::exit(1);
     }
@@ -94,7 +97,7 @@ async fn main() -> std::io::Result<()> {
 
     // first cut: use bluez stack, ask for active scanning
     let mut ble_handle = tokio::spawn(ble::run_bluez_advertisement_listener(cli.hci, tx.clone()));
-    
+
     // Check if BLE listener started successfully
     tokio::select! {
         _ = tokio::time::sleep(tokio::time::Duration::from_millis(100)) => {

src/server.rs

@@ -93,7 +93,7 @@ async fn handle_client(
                 match ble_msg {
                     Ok(advert) => {
                         if subscription_flags.is_subscribed() {
-                            debug!("Forwarding BLE advertisement to {} (flags: {:?})", 
+                            debug!("Forwarding BLE advertisement to {} (flags: {:?})",
                                    stream.peer_addr()?.ip(), subscription_flags);
                             forward_ble_advertisement(&mut stream, advert).await?;
                         }