chore: Update Rust to 1.91, fix new clippy complaints

Author: rustybee42

mgmtd/src/bee_msg/common.rs

@@ -43,12 +43,11 @@ pub(super) async fn update_node(msg: RegisterNode, app: &impl App) -> Result<Nod
                 None
             };
 
-            if let Some(machine_uuid) = machine_uuid {
-                if db::node::count_machines(tx, machine_uuid, node.as_ref().map(|n| n.uid))?
+            if let Some(machine_uuid) = machine_uuid
+                && db::node::count_machines(tx, machine_uuid, node.as_ref().map(|n| n.uid))?
                     >= licensed_machines
-                {
-                    bail!("Licensed machine limit reached. Node registration denied.");
-                }
+            {
+                bail!("Licensed machine limit reached. Node registration denied.");
             }
 
             let (node, is_new) = if let Some(node) = node {

mgmtd/src/config.rs

@@ -429,10 +429,10 @@ generate_structs! {
 
 impl Config {
     pub fn check_validity(&self) -> Result<()> {
-        if let Some(ref uuid) = self.fs_uuid {
-            if uuid.get_version_num() != 4 {
-                bail!("Provided file system UUID is not a valid v4 UUID");
-            }
+        if let Some(ref uuid) = self.fs_uuid
+            && uuid.get_version_num() != 4
+        {
+            bail!("Provided file system UUID is not a valid v4 UUID");
         }
 
         if self.quota_enforce && !self.quota_enable {

mgmtd/src/grpc/get_quota_usage.rs

@@ -131,20 +131,20 @@ pub(crate) async fn get_quota_usage(
 
             // If this if the first entry, include the quota refresh period. Do not send it again
             // after to minimize message size.
-            if offset == 0 {
-                if let Some(entry) = entries.next() {
-                    stream
-                        .send(pm::GetQuotaUsageResponse {
-                            entry: Some(entry),
-                            refresh_period_s: Some(
-                                app.static_info()
-                                    .user_config
-                                    .quota_update_interval
-                                    .as_secs(),
-                            ),
-                        })
-                        .await?;
-                }
+            if offset == 0
+                && let Some(entry) = entries.next()
+            {
+                stream
+                    .send(pm::GetQuotaUsageResponse {
+                        entry: Some(entry),
+                        refresh_period_s: Some(
+                            app.static_info()
+                                .user_config
+                                .quota_update_interval
+                                .as_secs(),
+                        ),
+                    })
+                    .await?;
             }
 
             // Send all the (remaining) entries to the client

rust-toolchain.toml

@@ -1,3 +1,3 @@
 [toolchain]
-channel = "1.88"
+channel = "1.91"
 profile = "default"

shared/src/conn/incoming.rs

@@ -111,11 +111,11 @@ async fn stream_loop(
         .await
         {
             // If the error comes from the connection being closed, we only log a debug message
-            if let Some(inner) = err.downcast_ref::<io::Error>() {
-                if let ErrorKind::UnexpectedEof = inner.kind() {
-                    log::debug!("Closed stream from {:?}: {err:#}", stream.addr());
-                    return;
-                }
+            if let Some(inner) = err.downcast_ref::<io::Error>()
+                && let ErrorKind::UnexpectedEof = inner.kind()
+            {
+                log::debug!("Closed stream from {:?}: {err:#}", stream.addr());
+                return;
             }
 
             log::error!(

shared/src/nic.rs

@@ -45,12 +45,11 @@ impl NicFilter {
         let mut split = input.split_whitespace().peekable();
         let mut res = Self::default();
 
-        if let Some(field) = split.peek() {
-            if *field == "!" {
+        if let Some(field) = split.peek()
+            && *field == "!" {
                 res.invert = true;
                 split.next();
             }
-        }
 
         if let Some(field) = split.next() && field != "*" {
             res.name = Some(field.to_string());