fix(rustfmt): fix rustfmt errors in chain/ethereum/src/network.rs

Author: DaMandal0rian

chain/ethereum/src/network.rs

@@ -197,7 +197,7 @@ impl EthereumNetworkAdapters {
         Self::available_with_capabilities(all, required_capabilities)
     }
 
-    """    // handle adapter selection from a list, implements the availability checking with an abstracted
+    // handle adapter selection from a list, implements the availability checking with an abstracted
     // source of the adapter list.
     fn cheapest_from(
         &self,
@@ -213,8 +213,11 @@ impl EthereumNetworkAdapters {
         self.select_best_adapter(input, required_capabilities)
     }
 
-    fn retest_errored_adapter(&self, input: &[&EthereumNetworkAdapter]) -> Option<Arc<EthereumAdapter>> {
-        let retest_rng: f64 = (&mut rand::rng()).random();
+    fn retest_errored_adapter(
+        &self,
+        input: &[&EthereumNetworkAdapter],
+    ) -> Option<Arc<EthereumAdapter>> {
+        let retest_rng: f64 = rand::thread_rng().gen();
         if retest_rng < self.retest_percent {
             input
                 .iter()
@@ -250,7 +253,7 @@ impl EthereumNetworkAdapters {
         }
         let weights: Vec<_> = input.iter().map(|a| a.weight).collect();
         if let Ok(dist) = WeightedIndex::new(&weights) {
-            let idx = dist.sample(&mut rand::rng());
+            let idx = dist.sample(&mut rand::thread_rng());
             Ok(input[idx].adapter.clone())
         } else {
             // Fallback to random selection if weights are invalid
@@ -263,7 +266,9 @@ impl EthereumNetworkAdapters {
         input: Vec<&EthereumNetworkAdapter>,
         required_capabilities: &NodeCapabilities,
     ) -> Result<Arc<EthereumAdapter>, Error> {
-        let choices = input.into_iter().choose_multiple(&mut rand::rng(), 3);
+        let choices = input
+            .into_iter()
+            .choose_multiple(&mut rand::thread_rng(), 3);
         if let Some(adapter) = choices.iter().min_by_key(|a| a.current_error_count()) {
             Ok(adapter.adapter.clone())
         } else {
@@ -272,7 +277,7 @@ impl EthereumNetworkAdapters {
                 required_capabilities
             ))
         }
-    }""
+    }
 
     pub(crate) fn unverified_cheapest_with(
         &self,
@@ -339,15 +344,15 @@ impl EthereumNetworkAdapters {
             .call_only_adapters
             .iter()
             .min_by_key(|x| Arc::strong_count(&x.adapter))
-            .ok_or(anyhow!("no available call only endpoints"))?;
+            .ok_or(anyhow!("no available call only endpoints "))?;
 
         // TODO: This will probably blow up a lot sooner than [limit] amount of
         // subgraphs, since we probably use a few instances.
         if !adapters
             .limit
             .has_capacity(Arc::strong_count(&adapters.adapter))
         {
-            bail!("call only adapter has reached the concurrency limit");
+            bail!("call only adapter has reached the concurrency limit ");
         }
 
         // Cloning here ensure we have the correct count at any given time, if we return a reference it can be cloned later
@@ -364,11 +369,11 @@ mod tests {
     use graph::components::network_provider::ProviderName;
     use graph::data::value::Word;
     use graph::http::HeaderMap;
+    use graph::slog::{o, Discard, Logger};
     use graph::{
         endpoint::EndpointMetrics,
         firehose::SubgraphLimit,
-        prelude::MetricsRegistry,
-        slog::{o, Discard, Logger},
+        prelude::{MetricsRegistry, SubgraphAssignmentProvider},
         tokio,
         url::Url,
     };
@@ -788,6 +793,7 @@ mod tests {
                 },
                 adapter: adapter.clone(),
                 limit: limit.clone(),
+                weight: 1.0,
             });
             always_retest_adapters.push(EthereumNetworkAdapter {
                 endpoint_metrics: metrics.clone(),
@@ -797,6 +803,7 @@ mod tests {
                 },
                 adapter,
                 limit,
+                weight: 1.0,
             });
         });
         let manager = ProviderManager::<EthereumNetworkAdapter>::new(
@@ -878,6 +885,7 @@ mod tests {
             adapter: fake_adapter(&logger, &error_provider, &provider_metrics, &metrics, false)
                 .await,
             limit: SubgraphLimit::Unlimited,
+            weight: 1.0,
         });
 
         let mut always_retest_adapters = vec![];
@@ -896,6 +904,7 @@ mod tests {
             )
             .await,
             limit: SubgraphLimit::Unlimited,
+            weight: 1.0,
         });
         let manager = ProviderManager::<EthereumNetworkAdapter>::new(
             logger.clone(),
@@ -965,6 +974,7 @@ mod tests {
             )
             .await,
             limit: SubgraphLimit::Disabled,
+            weight: 1.0,
         });
         let manager = ProviderManager::new(
             logger,