ci: make cargo fmt happy

Author: neithanmo

crates/monitor/src/horizon_detection.rs

@@ -11,7 +11,6 @@ use indexer_query::horizon_detection::{self, HorizonDetectionQuery};
 
 use crate::client::SubgraphClient;
 
-
 /// Detects if Horizon (V2) contracts are active in the network.
 ///
 /// This function queries the network subgraph to check if any PaymentsEscrow accounts exist.
@@ -36,7 +35,10 @@ pub async fn is_horizon_active(network_subgraph: &SubgraphClient) -> Result<bool
     let account_count = response.payments_escrow_accounts.len();
 
     if account_count > 0 {
-        tracing::info!(accounts = account_count, "Horizon (V2) schema available - found existing PaymentsEscrow accounts");
+        tracing::info!(
+            accounts = account_count,
+            "Horizon (V2) schema available - found existing PaymentsEscrow accounts"
+        );
     } else {
         tracing::info!("Horizon (V2) schema available - no accounts found at startup, but will detect new accounts automatically");
     }

crates/service/src/middleware/auth.rs

@@ -27,9 +27,8 @@ mod tests {
     use tower::{Service, ServiceBuilder, ServiceExt};
     use tower_http::auth::AsyncRequireAuthorizationLayer;
 
-    use crate::middleware::auth::tap::tap_receipt_authorize;
     use crate::{
-        middleware::auth::{Bearer, OrExt},
+        middleware::auth::{tap::tap_receipt_authorize, Bearer, OrExt},
         tap::{IndexerTapContext, TapReceipt},
     };
 

crates/service/src/middleware/auth/tap.rs

@@ -188,13 +188,12 @@ mod tests {
     use tower::{Service, ServiceBuilder, ServiceExt};
     use tower_http::auth::AsyncRequireAuthorizationLayer;
 
+    use super::tap_receipt_authorize;
     use crate::{
         middleware::prometheus_metrics::{MetricLabelProvider, MetricLabels},
         tap::{CheckingReceipt, IndexerTapContext, TapReceipt},
     };
 
-    use super::tap_receipt_authorize;
-
     #[fixture]
     fn metric() -> &'static prometheus::CounterVec {
         let registry = prometheus::Registry::new();

crates/tap-agent/src/agent/sender_accounts_manager.rs

@@ -1148,7 +1148,10 @@ async fn new_receipts_watcher(
         .await
         {
             Ok(()) => {
-                tracing::debug!(event = "notification_handled", "Successfully handled notification");
+                tracing::debug!(
+                    event = "notification_handled",
+                    "Successfully handled notification"
+                );
             }
             Err(e) => {
                 tracing::error!(error = %e, "Error handling notification");

crates/tap-agent/src/tap/context.rs

@@ -125,18 +125,16 @@ impl NetworkVersion for Legacy {
             .collect::<Result<_, _>>()?;
         let rav_request = AggregatorRequestV1::new(valid_receipts, previous_rav);
 
-        let response =
-            client
-                .aggregate_receipts(rav_request)
-                .await
-                .inspect_err(|status: &Status| {
-                    if status.code() == Code::DeadlineExceeded {
-                        tracing::warn!(
-                            code = ?status.code(),
-                            "RAV request deadline exceeded; consider increasing request_timeout_secs"
-                        );
-                    }
-                })?;
+        let response = client.aggregate_receipts(rav_request).await.inspect_err(
+            |status: &Status| {
+                if status.code() == Code::DeadlineExceeded {
+                    tracing::warn!(
+                        code = ?status.code(),
+                        "RAV request deadline exceeded; consider increasing request_timeout_secs"
+                    );
+                }
+            },
+        )?;
         response.into_inner().signed_rav()
     }
 }
@@ -168,18 +166,16 @@ impl NetworkVersion for Horizon {
             .collect::<Result<_, _>>()?;
         let rav_request = AggregatorRequestV2::new(valid_receipts, previous_rav);
 
-        let response =
-            client
-                .aggregate_receipts(rav_request)
-                .await
-                .inspect_err(|status: &Status| {
-                    if status.code() == Code::DeadlineExceeded {
-                        tracing::warn!(
-                            code = ?status.code(),
-                            "RAV request deadline exceeded; consider increasing request_timeout_secs"
-                        );
-                    }
-                })?;
+        let response = client.aggregate_receipts(rav_request).await.inspect_err(
+            |status: &Status| {
+                if status.code() == Code::DeadlineExceeded {
+                    tracing::warn!(
+                        code = ?status.code(),
+                        "RAV request deadline exceeded; consider increasing request_timeout_secs"
+                    );
+                }
+            },
+        )?;
         response.into_inner().signed_rav()
     }
 }

crates/tap-agent/src/tap/mod.rs

@@ -24,7 +24,7 @@ pub async fn signers_trimmed(
     sender: Address,
 ) -> Result<Vec<String>, anyhow::Error> {
     let escrow_accounts = escrow_accounts_rx.borrow();
-    
+
     tracing::info!(sender = %sender, "signers_trimmed called");
 
     let signers = escrow_accounts

crates/tap-agent/src/tracker/generic_tracker.rs

@@ -79,10 +79,7 @@ where
     #[tracing::instrument(skip(self), ret, level = "trace")]
     pub fn get_heaviest_allocation_id(&mut self) -> Option<Address> {
         let total_allocations = self.id_to_fee.len();
-        tracing::debug!(
-            total_allocations,
-            "Evaluating allocations for RAV request",
-        );
+        tracing::debug!(total_allocations, "Evaluating allocations for RAV request",);
 
         if total_allocations == 0 {
             tracing::warn!("No allocations found in fee tracker");