src/concurrent_processor.rs

@@ -3,7 +3,7 @@ use crate::{
     error::{Error, UploadError},
     repo::Hash,
 };
-use actix_web::web;
+
 use dashmap::{mapref::entry::Entry, DashMap};
 use flume::{r#async::RecvFut, Receiver, Sender};
 use std::{

src/details.rs

@@ -6,7 +6,7 @@ use crate::{
     serde_str::Serde,
     state::State,
 };
-use actix_web::web;
+
 use time::{format_description::well_known::Rfc3339, OffsetDateTime};
 
 #[derive(Copy, Clone, Debug, serde::Deserialize, serde::Serialize)]

src/discover.rs

@@ -2,7 +2,7 @@ mod exiftool;
 mod ffmpeg;
 mod magick;
 
-use actix_web::web::Bytes;
+
 
 use crate::{bytes_stream::BytesStream, formats::InputFile, state::State};
 

src/discover/exiftool.rs

@@ -1,4 +1,4 @@
-use actix_web::web::Bytes;
+
 
 use crate::{
     bytes_stream::BytesStream,

src/discover/ffmpeg.rs

@@ -13,7 +13,7 @@ use crate::{
     process::Process,
     state::State,
 };
-use actix_web::web::Bytes;
+
 
 use super::Discovery;
 

src/discover/magick.rs

@@ -1,7 +1,7 @@
 #[cfg(test)]
 mod tests;
 
-use actix_web::web::Bytes;
+
 
 use crate::{
     bytes_stream::BytesStream,

src/exiftool.rs

@@ -3,7 +3,7 @@ use crate::{
     error_code::ErrorCode,
     process::{Process, ProcessError, ProcessRead},
 };
-use actix_web::web::Bytes;
+
 
 #[derive(Debug, thiserror::Error)]
 pub(crate) enum ExifError {

src/generate.rs

@@ -2,7 +2,6 @@ mod ffmpeg;
 mod magick;
 
 use crate::{
-    bytes_stream::BytesStream,
     concurrent_processor::ProcessMap,
     details::Details,
     error::{Error, UploadError},
@@ -12,7 +11,7 @@ use crate::{
     state::State,
     store::Store,
 };
-use actix_web::web::Bytes;
+
 use std::{
     path::PathBuf,
     sync::Arc,

src/process.rs

@@ -1,4 +1,4 @@
-use actix_web::web::Bytes;
+
 use std::{
     ffi::OsStr,
     future::Future,
@@ -6,9 +6,9 @@ use std::{
     sync::Arc,
     time::{Duration, Instant},
 };
-use streem::IntoStreamer;
+
 use tokio::{
-    io::{AsyncReadExt, AsyncWriteExt},
+    io::{AsyncReadExt},
     process::{Child, ChildStdin, Command},
 };
 use tokio_util::io::ReaderStream;

src/validate.rs

@@ -14,7 +14,7 @@ use crate::{
     process::ProcessRead,
     state::State,
 };
-use actix_web::web::Bytes;
+
 
 #[derive(Debug, thiserror::Error)]
 pub(crate) enum ValidationError {

src/validate/exiftool.rs

@@ -1,4 +1,4 @@
-use actix_web::web::Bytes;
+
 
 use crate::{
     bytes_stream::BytesStream,

src/validate/ffmpeg.rs

@@ -1,6 +1,6 @@
 use std::{ffi::OsStr, sync::Arc};
 
-use actix_web::web::Bytes;
+
 use uuid::Uuid;
 
 use crate::{

src/validate/magick.rs

@@ -1,6 +1,6 @@
 use std::ffi::OsStr;
 
-use actix_web::web::Bytes;
+
 
 use crate::{
     bytes_stream::BytesStream,