fix linter errors [skip ci]

Author: erhant

compute/src/utils/available_nodes/mod.rs

@@ -72,8 +72,7 @@ impl AvailableNodes {
         } else {
             log::debug!("Using additional bootstrap nodes: {:#?}", bootstrap_nodes);
         }
-        self.bootstrap_nodes
-            .extend(parse_vec(bootstrap_nodes).into_iter());
+        self.bootstrap_nodes.extend(parse_vec(bootstrap_nodes));
 
         // parse relay nodes
         let relay_nodes = split_csv_line(&env::var("DKN_RELAY_NODES").unwrap_or_default());
@@ -82,17 +81,17 @@ impl AvailableNodes {
         } else {
             log::debug!("Using additional relay nodes: {:#?}", relay_nodes);
         }
-        self.relay_nodes.extend(parse_vec(relay_nodes).into_iter());
+        self.relay_nodes.extend(parse_vec(relay_nodes));
     }
 
     /// Adds the static nodes to the struct, with respect to network type.
     pub fn populate_with_statics(&mut self) {
         self.bootstrap_nodes
-            .extend(self.network_type.get_static_bootstrap_nodes().into_iter());
+            .extend(self.network_type.get_static_bootstrap_nodes());
         self.relay_nodes
-            .extend(self.network_type.get_static_relay_nodes().into_iter());
+            .extend(self.network_type.get_static_relay_nodes());
         self.rpc_nodes
-            .extend(self.network_type.get_static_rpc_peer_ids().into_iter());
+            .extend(self.network_type.get_static_rpc_peer_ids());
     }
 
     /// Refresh available nodes using the API.
@@ -110,13 +109,11 @@ impl AvailableNodes {
         let response = reqwest::get(self.network_type.get_available_nodes_url()).await?;
         let response_body = response.json::<AvailableNodesApiResponse>().await?;
         self.bootstrap_nodes
-            .extend(parse_vec(response_body.bootstraps).into_iter());
-        self.relay_nodes
-            .extend(parse_vec(response_body.relays).into_iter());
-        self.rpc_addrs
-            .extend(parse_vec(response_body.rpc_addrs).into_iter());
+            .extend(parse_vec(response_body.bootstraps));
+        self.relay_nodes.extend(parse_vec(response_body.relays));
+        self.rpc_addrs.extend(parse_vec(response_body.rpc_addrs));
         self.rpc_nodes
-            .extend(parse_vec::<PeerId>(response_body.rpcs).into_iter());
+            .extend(parse_vec::<PeerId>(response_body.rpcs));
         self.last_refreshed = Instant::now();
 
         Ok(())

p2p/src/client.rs

@@ -42,6 +42,7 @@ impl DriaP2PClient {
     ///
     /// The `version` is used to create the protocol strings for the client, and its very important that
     /// they match with the clients existing within the network.
+    #[allow(clippy::type_complexity)]
     pub fn new(
         keypair: Keypair,
         listen_addr: Multiaddr,

p2p/src/commands.rs

@@ -188,7 +188,7 @@ impl DriaP2PCommander {
         self.sender
             .send(DriaP2PCommand::ValidateMessage {
                 msg_id: msg_id.clone(),
-                propagation_source: propagation_source.clone(),
+                propagation_source: *propagation_source,
                 acceptance,
                 sender,
             })

workflows/src/bin/tps.rs

@@ -1,13 +1,17 @@
-#![cfg(feature = "profiling")]
-
-use dkn_workflows::{DriaWorkflowsConfig, OllamaConfig};
-use ollama_workflows::ollama_rs::{generation::completion::request::GenerationRequest, Ollama};
-use ollama_workflows::Model;
-use prettytable::{Cell, Row, Table};
-use sysinfo::{CpuRefreshKind, RefreshKind, System, MINIMUM_CPU_UPDATE_INTERVAL};
+#[cfg(not(feature = "profiling"))]
+fn main() {
+    unimplemented!("This binary requires the 'profiling' feature to be enabled");
+}
 
+#[cfg(feature = "profiling")]
 #[tokio::main]
 async fn main() {
+    use dkn_workflows::{DriaWorkflowsConfig, OllamaConfig};
+    use ollama_workflows::ollama_rs::{generation::completion::request::GenerationRequest, Ollama};
+    use ollama_workflows::Model;
+    use prettytable::{Cell, Row, Table};
+    use sysinfo::{CpuRefreshKind, RefreshKind, System, MINIMUM_CPU_UPDATE_INTERVAL};
+
     // initialize logger
     env_logger::init();