code cleanup

src/config.rs

@@ -1,7 +1,6 @@
 use std;
 use std::collections::HashMap;
 use toml;
-use serde;
 pub use tracker::TrackerMode;
 
 #[derive(Deserialize)]
@@ -51,7 +50,6 @@ pub enum ConfigError {
 
 impl std::fmt::Display for ConfigError {
     fn fmt(&self, formatter: &mut std::fmt::Formatter) -> std::fmt::Result {
-        use std::fmt::Display;
         match self {
             ConfigError::IOError(e) => e.fmt(formatter),
             ConfigError::ParseError(e) => e.fmt(formatter),

src/main.rs

@@ -24,7 +24,7 @@ fn main() {
     let tracker = std::sync::Arc::new(tracker::TorrentTracker::new(cfg.get_mode().clone()));
 
     // start http server:
-    if let Some(http_cfg) = cfg.get_http_config() {
+    if cfg.get_http_config().is_some() {
         let http_tracker_ref = tracker.clone();
         let cfg_ref = cfg.clone();
         std::thread::spawn(move || {

src/server.rs

@@ -34,16 +34,6 @@ pub enum Events {
     Stopped = 3,
 }
 
-fn pack<T: Serialize>(data: &T) -> Option<Vec<u8>> {
-    let mut bo = bincode::config();
-    bo.big_endian();
-
-    match bo.serialize(data) {
-        Ok(v) => Some(v),
-        Err(_) => None,
-    }
-}
-
 fn pack_into<T: Serialize, W: std::io::Write>(w: &mut W, data: &T) -> Result<(), ()> {
     let mut config = bincode::config();
     config.big_endian();
@@ -190,7 +180,7 @@ impl UDPTracker {
         if let Ok(_plen) = bincode::serialized_size(&packet) {
             let plen = _plen as usize;
             if payload.len() > plen {
-                let bep41_payload = &payload[plen..];
+                let _bep41_payload = &payload[plen..];
 
                 // TODO: process BEP0041 payload.
             }
@@ -205,7 +195,7 @@ impl UDPTracker {
         let client_addr = SocketAddr::new(remote_addr.ip(), packet.port);
 
         match self.tracker.update_torrent_and_get_stats(&packet.info_hash, &packet.peer_id, &client_addr, packet.uploaded, packet.downloaded, packet.left, packet.event) {
-            tracker::TorrentStats::Stats {leechers, complete, seeders} => {
+            tracker::TorrentStats::Stats {leechers, complete: _, seeders} => {
                 let peers = match self.tracker.get_torrent_peers(&packet.info_hash, &client_addr) {
                     Some(v) => v,
                     None => {

src/tracker.rs

@@ -196,7 +196,7 @@ impl TorrentTracker {
                 ve.insert(TorrentEntry::new());
                 return Ok(());
             },
-            std::collections::btree_map::Entry::Occupied(entry) => {
+            std::collections::btree_map::Entry::Occupied(_entry) => {
                 return Err(());
             }
         }

src/webserver.rs

@@ -118,7 +118,7 @@ impl actix_web::middleware::Middleware<UdptState> for UdptMiddleware {
         Ok(actix_web::middleware::Started::Done)
     }
 
-    fn response(&self, req: &actix_web::HttpRequest<UdptState>, mut resp: actix_web::HttpResponse) -> actix_web::Result<actix_web::middleware::Response> {
+    fn response(&self, _req: &actix_web::HttpRequest<UdptState>, mut resp: actix_web::HttpResponse) -> actix_web::Result<actix_web::middleware::Response> {
         resp.headers_mut()
             .insert(actix_web::http::header::SERVER, actix_web::http::header::HeaderValue::from_static(SERVER));
 
@@ -176,7 +176,7 @@ impl WebServer {
         WebServer{}
     }
 
-    fn view_root(req: &actix_web::HttpRequest<UdptState>) -> actix_web::HttpResponse {
+    fn view_root(_req: &actix_web::HttpRequest<UdptState>) -> actix_web::HttpResponse {
         actix_web::HttpResponse::build(actix_web::http::StatusCode::OK)
             .content_type("text/html")
             .body(r#"Powered by <a href="https://github.com/naim94a/udpt">https://github.com/naim94a/udpt</a>"#)