From 70cb61f41588d852c77ec32ef750375a692470b1 Mon Sep 17 00:00:00 2001
From: Kyle Machulis <kyle@nonpolynomial.com>
Date: Sun, 6 Oct 2024 19:40:07 -0700
Subject: [PATCH] chore: run rustfmt

---
 .../src/server/device/protocol/lovense.rs     | 53 +++++++++++++------
 1 file changed, 36 insertions(+), 17 deletions(-)

diff --git a/buttplug/src/server/device/protocol/lovense.rs b/buttplug/src/server/device/protocol/lovense.rs
index 6f978035f..9654cd2a6 100644
--- a/buttplug/src/server/device/protocol/lovense.rs
+++ b/buttplug/src/server/device/protocol/lovense.rs
@@ -15,7 +15,7 @@ use crate::{
     hardware::{Hardware, HardwareCommand, HardwareEvent, HardwareSubscribeCmd, HardwareWriteCmd},
     protocol::{ProtocolHandler, ProtocolIdentifier, ProtocolInitializer},
   },
-  util::{sleep, async_manager}
+  util::{async_manager, sleep},
 };
 use async_trait::async_trait;
 use futures::{future::BoxFuture, FutureExt};
@@ -158,12 +158,10 @@ impl ProtocolInitializer for LovenseInitializer {
       .filter(|x| x.actuator().is_some())
       .count();
 
-    
     // This might need better tuning if other complex Lovenses are released
     // Currently this only applies to the Flexer/Lapis/Solace
-    let use_mply = (vibrator_count == 2 && actuator_count > 2)
-      || vibrator_count > 2
-      || device_type == "H";
+    let use_mply =
+      (vibrator_count == 2 && actuator_count > 2) || vibrator_count > 2 || device_type == "H";
 
     debug!(
       "Device type {} initialized with {} vibrators {} using Mply",
@@ -172,7 +170,12 @@ impl ProtocolInitializer for LovenseInitializer {
       if use_mply { "" } else { "not " }
     );
 
-    Ok(Arc::new(Lovense::new(hardware, &device_type, vibrator_count, use_mply)))
+    Ok(Arc::new(Lovense::new(
+      hardware,
+      &device_type,
+      vibrator_count,
+      use_mply,
+    )))
   }
 }
 
@@ -186,11 +189,18 @@ pub struct Lovense {
 }
 
 impl Lovense {
-  pub fn new(hardware: Arc<Hardware>, device_type: &str, vibrator_count: usize, use_mply: bool) -> Self {
-
+  pub fn new(
+    hardware: Arc<Hardware>,
+    device_type: &str,
+    vibrator_count: usize,
+    use_mply: bool,
+  ) -> Self {
     let linear_info = Arc::new((AtomicU8::new(0), AtomicU32::new(0)));
     if device_type == "BA" {
-      async_manager::spawn(update_linear_movement(hardware.clone(), linear_info.clone()));
+      async_manager::spawn(update_linear_movement(
+        hardware.clone(),
+        linear_info.clone(),
+      ));
     }
 
     Self {
@@ -404,13 +414,22 @@ impl ProtocolHandler for Lovense {
   }
 
   fn handle_linear_cmd(
-      &self,
-      message: message::LinearCmdV4,
-    ) -> Result<Vec<HardwareCommand>, ButtplugDeviceError> {
-    let vector = message.vectors().first().expect("Already checked for vector subcommand");
-    self.linear_info.0.store((vector.position() * 100f64) as u8, Ordering::SeqCst);
-    self.linear_info.1.store(vector.duration(), Ordering::SeqCst);
-    Ok(vec!())
+    &self,
+    message: message::LinearCmdV4,
+  ) -> Result<Vec<HardwareCommand>, ButtplugDeviceError> {
+    let vector = message
+      .vectors()
+      .first()
+      .expect("Already checked for vector subcommand");
+    self
+      .linear_info
+      .0
+      .store((vector.position() * 100f64) as u8, Ordering::SeqCst);
+    self
+      .linear_info
+      .1
+      .store(vector.duration(), Ordering::SeqCst);
+    Ok(vec![])
   }
 }
 
@@ -456,4 +475,4 @@ async fn update_linear_movement(device: Arc<Hardware>, linear_info: Arc<(AtomicU
     }
     sleep(Duration::from_millis(100)).await;
   }
-}
\ No newline at end of file
+}