Fixed lints.

Signed-off-by: Pavel Kirilin <win10@list.ru>

src/data_storage/impls/file_storage.rs

@@ -95,7 +95,7 @@ impl Storage for FileStorage {
             .open(path.as_str())
             .await?;
         let mut writer = tokio::io::BufWriter::new(file);
-        writer.write_all(&mut bytes).await?;
+        writer.write_all(&bytes).await?;
         writer.flush().await?;
         if self.force_fsync {
             writer.get_ref().sync_data().await?;
@@ -144,7 +144,7 @@ impl Storage for FileStorage {
                 .await?;
             let mut reader = tokio::io::BufReader::new(part_file);
             tokio::io::copy_buf(&mut reader, &mut writer).await?;
-            reader.shutdown().await?
+            reader.shutdown().await?;
         }
         writer.flush().await?;
         if self.force_fsync {

src/main.rs

@@ -48,6 +48,7 @@ fn greeting(app_conf: &config::Config) {
 fn main() -> RustusResult<()> {
     let args = config::Config::parse();
     greeting(&args);
+    #[allow(clippy::no_effect_underscore_binding)]
     let mut _guard = None;
     if let Some(sentry_dsn) = &args.sentry_config.dsn {
         let default_options = sentry::ClientOptions::default();
@@ -66,7 +67,7 @@ fn main() -> RustusResult<()> {
                 .sentry_config
                 .environment
                 .clone()
-                .map(|val| Cow::from(val))
+                .map(Cow::from)
                 .clone(),
             release: sentry::release_name!(),
             debug: args.sentry_config.debug,

src/notifiers/impls/file_notifier.rs

@@ -38,7 +38,7 @@ impl Notifier for FileNotifier {
             .spawn()?;
         let stat = command.wait().await?;
         if !stat.success() {
-            tracing::Span::current().record("exit_status", &stat.code().unwrap_or(0));
+            tracing::Span::current().record("exit_status", stat.code().unwrap_or(0));
             return Err(RustusError::HookError("Returned wrong status code".into()));
         }
         Ok(())

src/server/mod.rs

@@ -144,7 +144,7 @@ pub async fn start(config: Config) -> RustusResult<()> {
         })
         .on_response(
             |response: &Response, latency: Duration, span: &tracing::Span| {
-                span.record("status", &response.status().as_u16());
+                span.record("status", response.status().as_u16());
                 span.record("duration", latency.as_millis());
                 tracing::info!("response");
             },

src/server/routes/upload.rs

@@ -28,7 +28,7 @@ pub async fn handler(
     Path(upload_id): Path<String>,
     body: Bytes,
 ) -> RustusResult<axum::response::Response> {
-    tracing::Span::current().record("upload_id", &upload_id.as_str());
+    tracing::Span::current().record("upload_id", upload_id.as_str());
     if !headers.check("Content-Type", |val| {
         val == "application/offset+octet-stream"
     }) {

src/utils/result.rs

@@ -4,25 +4,28 @@ pub trait MonadLogger: Sized {
     #[must_use]
     fn _should_log(&self) -> bool;
 
+    #[must_use]
     fn mlog_err(self, msg: &str) -> Self {
         if self._should_log() {
-            tracing::error!(msg)
+            tracing::error!(msg);
         }
         self
     }
 
+    #[must_use]
     fn mlog_warn(self, msg: &str) -> Self {
         if self._should_log() {
-            tracing::warn!(msg)
+            tracing::warn!(msg);
         }
         self
     }
 
+    #[must_use]
     #[allow(unused_variables)]
     fn mlog_dbg(self, msg: &str) -> Self {
         #[cfg(debug_assertions)]
         if self._should_log() {
-            tracing::debug!(msg)
+            tracing::debug!(msg);
         }
         self
     }