chore: run cargo fmt --fix

Author: lukasz-zet

edgeless_api/src/grpc_impl/tls_config_mtls.rs

@@ -90,8 +90,8 @@ impl super::tls_config::TlsConfig {
             log::info!("Client CA specified: TLS will be enforced.");
             tls_config = tls_config.ca_certificate(tonic::transport::Certificate::from_pem(std::fs::read(ca_path)?));
         } /* else {
-            log::info!("No Client CA specified: no TLS will be enforced.");
-        } */
+              log::info!("No Client CA specified: no TLS will be enforced.");
+          } */
 
         // Configure client certificate for mTLS
         if let Some(cert_path) = &self.client_cert_path {
@@ -174,11 +174,11 @@ impl super::tls_config::TlsConfig {
                 Ok(endpoint.connect().await?)
             }
             Err(e) => {
-                // if e.to_string().contains("not found") {
-                //     log::warn!("TLS configuration file 'tls_config.toml' not found. Continuing with plaintext connection (no TLS).");
-                // } else {
-                //     log::warn!("Failed to load TLS configuration: {}. Continuing with plaintext connection (no TLS).", e);
-                // }
+                if e.to_string().contains("not found") {
+                    log::warn!("TLS configuration file 'tls_config.toml' not found. Continuing with plaintext connection (no TLS).");
+                } else {
+                    log::warn!("Failed to load TLS configuration: {}. Continuing with plaintext connection (no TLS).", e);
+                }
                 let endpoint = tonic::transport::Endpoint::from_shared(server_addr.to_string())?;
                 Ok(endpoint.connect().await?)
             }
@@ -190,11 +190,11 @@ impl super::tls_config::TlsConfig {
         SERVER_TLS_CONFIG.get_or_init(|| match CombinedTlsConfig::from_file("tls_config.toml") {
             Ok(cfg) => cfg.server.unwrap_or_else(super::tls_config::TlsConfig::default),
             Err(err) => {
-                // if err.to_string().contains("not found") {
-                //     log::warn!("TLS configuration file 'tls_config.toml' not found. Using default TLS configuration (no TLS).");
-                // } else {
-                //     log::warn!("Failed to load server TLS config: {}. Using default TLS configuration (no TLS).", err);
-                // }
+                if err.to_string().contains("not found") {
+                    log::warn!("TLS configuration file 'tls_config.toml' not found. Using default TLS configuration (no TLS).");
+                } else {
+                    log::warn!("Failed to load server TLS config: {}. Using default TLS configuration (no TLS).", err);
+                }
                 super::tls_config::TlsConfig::default()
             }
         })

edgeless_dataplane/src/remote_node.rs

@@ -77,7 +77,7 @@ impl edgeless_api::invocation::InvocationAPI for RemoteRouter {
     async fn handle(&mut self, event: edgeless_api::invocation::Event) -> anyhow::Result<edgeless_api::invocation::LinkProcessingResult> {
         if let Some(node_client) = self.receivers.get_mut(&event.target.node_id) {
             if let Err(err) = node_client.handle(event).await {
-                // log::warn!("Error in handling event: {}", err);
+                log::warn!("Error in handling event: {}", err);
             }
             Ok(edgeless_api::invocation::LinkProcessingResult::FINAL)
         } else {

edgeless_orc/src/bin/proxy_cli.rs

@@ -142,7 +142,11 @@ fn main() -> anyhow::Result<()> {
                     println!(
                         "{} -> {}",
                         function,
-                        nodes.iter().map(|x| format!("{}({})", x.0, if x.1 { "active" } else { "hot-standby" })).collect::<Vec<String>>().join(",")
+                        nodes
+                            .iter()
+                            .map(|x| format!("{}({})", x.0, if x.1 { "active" } else { "hot-standby" }))
+                            .collect::<Vec<String>>()
+                            .join(",")
                     );
                 }
             }
@@ -156,7 +160,11 @@ fn main() -> anyhow::Result<()> {
                     println!(
                         "{} -> {}",
                         logical,
-                        physical.iter().map(|x| format!("{}({})", x.0, if x.1 { "active" } else { "standby" })).collect::<Vec<String>>().join(",")
+                        physical
+                            .iter()
+                            .map(|x| format!("{}({})", x.0, if x.1 { "active" } else { "standby" }))
+                            .collect::<Vec<String>>()
+                            .join(",")
                     );
                 }
             }

edgeless_orc/src/orchestration_logic.rs

@@ -185,10 +185,7 @@ impl OrchestrationLogic {
         exclude: &Vec<uuid::Uuid>,
     ) -> Option<uuid::Uuid> {
         let feasible_nodes = self.feasible_nodes(spawn_req, &self.nodes);
-        let candidates: Vec<uuid::Uuid> = feasible_nodes
-            .into_iter()
-            .filter(|node_id| !exclude.contains(node_id))
-            .collect();
+        let candidates: Vec<uuid::Uuid> = feasible_nodes.into_iter().filter(|node_id| !exclude.contains(node_id)).collect();
         if candidates.is_empty() {
             return None;
         }
@@ -200,7 +197,7 @@ impl OrchestrationLogic {
             }
             crate::OrchestrationStrategy::RoundRobin => {
                 // Prevent infinite loop: evaluate each node at most once.
-                for _ in 0..candidates.len() {
+                if let Some(_) = (0..candidates.len()).next() {
                     // Wrap-around if the current index is out of bounds.
                     if self.round_robin_current_index >= candidates.len() {
                         self.round_robin_current_index = 0;