diff --git a/src/config.rs b/src/config.rs index 545d6f4..f73c1c2 100644 --- a/src/config.rs +++ b/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), diff --git a/src/main.rs b/src/main.rs index 0156fc8..251ad23 100644 --- a/src/main.rs +++ b/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 || { diff --git a/src/server.rs b/src/server.rs index 8c3a336..19e8294 100644 --- a/src/server.rs +++ b/src/server.rs @@ -34,16 +34,6 @@ pub enum Events { Stopped = 3, } -fn pack(data: &T) -> Option> { - let mut bo = bincode::config(); - bo.big_endian(); - - match bo.serialize(data) { - Ok(v) => Some(v), - Err(_) => None, - } -} - fn pack_into(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 => { diff --git a/src/tracker.rs b/src/tracker.rs index 6d5cefd..9091cd9 100644 --- a/src/tracker.rs +++ b/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(()); } } diff --git a/src/webserver.rs b/src/webserver.rs index 67b3b17..49b441f 100644 --- a/src/webserver.rs +++ b/src/webserver.rs @@ -118,7 +118,7 @@ impl actix_web::middleware::Middleware for UdptMiddleware { Ok(actix_web::middleware::Started::Done) } - fn response(&self, req: &actix_web::HttpRequest, mut resp: actix_web::HttpResponse) -> actix_web::Result { + fn response(&self, _req: &actix_web::HttpRequest, mut resp: actix_web::HttpResponse) -> actix_web::Result { 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) -> actix_web::HttpResponse { + fn view_root(_req: &actix_web::HttpRequest) -> actix_web::HttpResponse { actix_web::HttpResponse::build(actix_web::http::StatusCode::OK) .content_type("text/html") .body(r#"Powered by https://github.com/naim94a/udpt"#)