Przeglądaj źródła

net: Clippy lints

parazyd 3 lat temu
rodzic
commit
1f47600402
2 zmienionych plików z 7 dodań i 8 usunięć
  1. 6 7
      src/net/p2p.rs
  2. 1 1
      src/net/session/inbound_session.rs

+ 6 - 7
src/net/p2p.rs

@@ -397,9 +397,8 @@ impl P2p {
                             continue
                         };
 
-                        let obj;
-                        if slot.state != OutboundState::Open {
-                            obj = serde_json::json!({
+                        let obj = if slot.state != OutboundState::Open {
+                            serde_json::json!({
                                 "addr": slot.addr.unwrap().to_string(),
                                 "state": slot.state.to_string(),
                                 "info": {
@@ -408,14 +407,14 @@ impl P2p {
                                     "remote_id": slot.channel.as_ref().unwrap().remote_node_id,
                                     "log": slot.channel.as_ref().unwrap().log.to_vec(),
                                 }
-                            });
+                            })
                         } else {
-                            obj = serde_json::json!({
+                            serde_json::json!({
                                 "addr": serde_json::Value::Null,
                                 "state": slot.state.to_string(),
                                 "info": serde_json::Value::Null,
-                            });
-                        }
+                            })
+                        };
 
                         slot_info.push(obj);
                     }

+ 1 - 1
src/net/session/inbound_session.rs

@@ -59,7 +59,7 @@ impl InboundInfo {
     async fn dnet_info(&self, p2p: P2pPtr) -> Option<Self> {
         let Some(ref addr) = self.addr else { return None };
 
-        let Some(chan) = p2p.channels().lock().await.get(&addr).cloned() else { return None };
+        let Some(chan) = p2p.channels().lock().await.get(addr).cloned() else { return None };
 
         Some(Self { addr: self.addr.clone(), channel: Some(chan.dnet_info().await) })
     }