From 6e24983ad7046c956ec4bb3db7de235de2c9ce6c Mon Sep 17 00:00:00 2001 From: _ <> Date: Sat, 3 Apr 2021 15:30:32 +0000 Subject: [PATCH] :rotating_light: refactor: cargo clippy --- crates/ptth_server/src/file_server/internal.rs | 8 +++++--- crates/ptth_server/src/file_server/mod.rs | 5 ++++- crates/ptth_server/src/lib.rs | 4 ++-- 3 files changed, 11 insertions(+), 6 deletions(-) diff --git a/crates/ptth_server/src/file_server/internal.rs b/crates/ptth_server/src/file_server/internal.rs index c60c483..2d2bebd 100644 --- a/crates/ptth_server/src/file_server/internal.rs +++ b/crates/ptth_server/src/file_server/internal.rs @@ -5,7 +5,6 @@ use std::{ collections::HashMap, - convert::TryInto, path::{Path, PathBuf}, }; @@ -16,7 +15,6 @@ use tokio::{ read_dir, ReadDir, }, - io::AsyncReadExt, }; #[cfg (test)] @@ -133,7 +131,7 @@ fn serve_dir ( } async fn serve_file ( - mut file: tokio::fs::File, + file: tokio::fs::File, uri: &http::Uri, send_body: bool, headers: &HashMap > @@ -175,7 +173,11 @@ async fn serve_file ( return Ok (Response::MarkdownErr (MarkdownErrWrapper::new (markdown::Error::TooBig))); } else { + use std::convert::TryInto; + use tokio::io::AsyncReadExt; + let mut buffer = vec! [0_u8; MAX_BUF_SIZE.try_into ().expect ("Couldn't fit u32 into usize")]; + let mut file = file; let bytes_read = file.read (&mut buffer).await?; buffer.truncate (bytes_read); diff --git a/crates/ptth_server/src/file_server/mod.rs b/crates/ptth_server/src/file_server/mod.rs index 8fbd383..291e9e4 100644 --- a/crates/ptth_server/src/file_server/mod.rs +++ b/crates/ptth_server/src/file_server/mod.rs @@ -294,7 +294,10 @@ pub async fn serve_all ( } #[cfg (not (feature = "markdown"))] - serve_error (StatusCode::BadRequest, "Markdown feature is disabled") + { + let _e = e; + serve_error (StatusCode::BadRequest, "Markdown feature is disabled") + } }, MarkdownPreview (s) => html::serve (s), }) diff --git a/crates/ptth_server/src/lib.rs b/crates/ptth_server/src/lib.rs index c1a558c..85f364b 100644 --- a/crates/ptth_server/src/lib.rs +++ b/crates/ptth_server/src/lib.rs @@ -95,10 +95,10 @@ async fn handle_one_req ( tokio::spawn (async move { while let Some (chunk) = body.recv ().await { - let len = chunk.as_ref ().map (|x| x.len ()).ok (); + let len = chunk.as_ref ().map (Vec::len).ok (); tx.send (chunk).await?; - if let Some (len) = len { + if let Some (_len) = len { // debug! ("Throttling {} byte chunk", len); }