✨feature: lint clean up

rust/src/actor/core.rs

@@ -1,13 +1,10 @@
-use std::{collections::HashMap, net::Ipv4Addr, str::FromStr};
+use std::{net::Ipv4Addr, str::FromStr};
 
 use log::debug;
 use tokio::sync::{mpsc, oneshot, watch};
 
 use super::{
-    device::DeviceActorHandle,
-    http::HttpServerHandle,
-    mission::MissionHandle,
-    model::{Mission, NodeDevice},
+    device::DeviceActorHandle, http::HttpServerHandle, mission::MissionHandle, model::NodeDevice,
 };
 
 #[derive(Clone)]

rust/src/actor/discovery.rs

@@ -7,7 +7,7 @@ use tokio::sync::watch;
 
 use tokio::net::UdpSocket;
 
-use crate::actor::model::{NodeAnnounce, NodeDevice};
+use crate::actor::model::NodeDevice;
 
 use super::core::CoreActorHandle;
 

rust/src/actor/mission/pending.rs

@@ -1,5 +1,3 @@
-use std::collections::HashMap;
-
 use log::debug;
 use tokio::sync::{mpsc, oneshot, watch};
 

rust/src/actor/mission/transfer.rs

@@ -1,4 +1,4 @@
-use std::{collections::HashMap, sync::Mutex};
+use std::collections::HashMap;
 
 use log::debug;
 use tokio::sync::{mpsc, oneshot, watch};
@@ -143,7 +143,7 @@ impl Actor {
                     files.insert(k, info);
                 }
 
-                let (tx, rx) = watch::channel(TransferMissionDto {
+                let (_tx, _rx) = watch::channel(TransferMissionDto {
                     state: MissionState::Transfering,
                     files: files.values().map(|x| x.clone()).collect::<Vec<_>>(),
                 });
@@ -158,7 +158,7 @@ impl Actor {
                 let _ = respond_to.send(Ok(()));
             }
             Message::Listen { respond_to } => match &self.store.mission {
-                Some(mission) => {
+                Some(_mission) => {
                     let rx = self.listener.clone();
                     let _ = respond_to.send(Ok(rx));
                 }
@@ -214,8 +214,8 @@ impl Actor {
             }
             Message::StateTask {
                 id,
-                token,
-                state,
+                token: _,
+                state: _,
                 respond_to,
             } => {
                 match &self.store.mission {

rust/src/actor/model.rs

@@ -1,7 +1,6 @@
 use std::collections::HashMap;
 
 use serde_derive::{Deserialize, Serialize};
-use tokio::sync::watch;
 
 use crate::api::model::FileInfo;
 
@@ -82,7 +81,7 @@ impl Mission {
         let id = uuid::Uuid::new_v4().to_string();
         let mut token_map = HashMap::new();
         let mut reverse_token_map = HashMap::new();
-        info_map.iter().for_each(|(key, value)| {
+        info_map.iter().for_each(|(key, _value)| {
             let token = uuid::Uuid::new_v4().to_string();
             reverse_token_map.insert(key.clone(), token.clone());
             token_map.insert(token.clone(), key.clone());

rust/src/api/v2.rs

@@ -1,9 +1,9 @@
-use std::{collections::HashMap, net::SocketAddr, sync::Arc};
+use std::{net::SocketAddr, sync::Arc};
 
-use super::model::{FileInfo, FileRequest, FileResponse, UploadTask};
+use super::model::{FileRequest, FileResponse, UploadTask};
 use axum::{
-    body::{Bytes, HttpBody},
-    extract::{ConnectInfo, Path, Query, Request, State},
+    body::Bytes,
+    extract::{ConnectInfo, Query, Request, State},
     http::StatusCode,
     routing::{get, post},
     BoxError, Json, Router,

rust/src/bridge.rs

@@ -1,14 +1,7 @@
-use std::{
-    net::{IpAddr, SocketAddr},
-    sync::Arc,
-};
+use std::net::{IpAddr, SocketAddr};
 
-use futures::lock::Mutex;
 use lazy_static::lazy_static;
-use tokio::{
-    net::UdpSocket,
-    sync::{watch, OnceCell},
-};
+use tokio::{net::UdpSocket, sync::OnceCell};
 
 use crate::{
     actor::{

rust/src/logger.rs

@@ -5,7 +5,7 @@ use crate::frb_generated::StreamSink;
 use lazy_static::lazy_static;
 use log::{error, info, warn, Log, Metadata, Record};
 use parking_lot::RwLock;
-use serde_derive::{Deserialize, Serialize};
+
 use simplelog::*;
 
 static INIT_LOGGER_ONCE: Once = Once::new();

rust/src/util.rs

@@ -4,7 +4,7 @@ use std::task::{Context, Poll};
 use std::time::Duration;
 
 use pin_project_lite::pin_project;
-use tokio::io::{AsyncRead, AsyncWrite, ReadBuf};
+use tokio::io::AsyncWrite;
 use tokio::sync::watch::Sender;
 use tokio::time::{interval, Interval};