flibusta-apps/batch_downloader
1
0
Fork 0
mirror of https://github.com/flibusta-apps/batch_downloader.git synced 2025-12-06 14:25:36 +01:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Update deps

Browse Source
This commit is contained in:
Bulat Kurbanov
2024-04-25 16:44:47 +02:00
parent 71e37ed3c6
commit 1896c9724d
4 changed files with 615 additions and 611 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1184
Cargo.lock generated
View File

File diff suppressed because it is too large Load Diff

36
Cargo.toml
View File

@@ -6,42 +6,42 @@ edition = "2021"
# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
[dependencies] [dependencies]
tokio = { version = "1.35.0", features = ["full"] } tokio = { version = "1.37.0", features = ["full"] }
futures-core = "0.3.29" futures-core = "0.3.30"
tracing = "0.1.40" tracing = "0.1.40"
tracing-subscriber = { version = "0.3.18", features = ["env-filter"]} tracing-subscriber = { version = "0.3.18", features = ["env-filter"]}
tower-http = { version = "0.5.0", features = ["trace"] } tower-http = { version = "0.5.2", features = ["trace"] }
once_cell = "1.19.0" once_cell = "1.19.0"
axum = "0.7.2" axum = "0.7.5"
axum-prometheus = "0.5.0" axum-prometheus = "0.6.1"
serde = { version = "1.0.193", features = ["derive"] } serde = { version = "1.0.198", features = ["derive"] }
serde_json = "1.0.108" serde_json = "1.0.116"
moka = { version = "0.12.1", features = ["future"] } moka = { version = "0.12.7", features = ["future"] }
md5 = "0.7.0" md5 = "0.7.0"
smallvec = { version = "1.11.2", features = ["serde"] } smallvec = { version = "1.13.2", features = ["serde"] }
smartstring = { version = "1.0.1", features = ["serde"] } smartstring = { version = "1.0.1", features = ["serde"] }
reqwest = { version = "0.11.22", features = ["json", "stream", "multipart"] } reqwest = { version = "0.12.4", features = ["json", "stream", "multipart"] }
bytes = "1.5.0" bytes = "1.6.0"
tempfile = "3.8.1" tempfile = "3.10.1"
zip = "0.6.6" zip = "1.1.1"
base64 = "0.21.5" base64 = "0.22.0"
minio-rsc = "0.2.0" minio-rsc = "0.2.2"
async-stream = "0.3.5" async-stream = "0.3.5"
translit = "0.5.0" translit = "0.5.0"
sentry = { version = "0.32.0", features = ["debug-images"] } sentry = { version = "0.32.3", features = ["debug-images"] }
tokio-cron-scheduler = "0.9.4" tokio-cron-scheduler = "0.10.0"
chrono = "0.4.31" chrono = "0.4.38"

4
src/services/task_creator.rs
View File

@@ -163,7 +163,7 @@ pub async fn create_archive(
let output_file = tempfile::spooled_tempfile(5 * 1024 * 1024); let output_file = tempfile::spooled_tempfile(5 * 1024 * 1024);
let mut archive = zip::ZipWriter::new(output_file); let mut archive = zip::ZipWriter::new(output_file);
let options = FileOptions::default() let options: FileOptions<_> = FileOptions::default()
.compression_level(Some(9)) .compression_level(Some(9))
.compression_method(zip::CompressionMethod::Deflated) .compression_method(zip::CompressionMethod::Deflated)
.unix_permissions(0o755); .unix_permissions(0o755);
@@ -177,7 +177,7 @@ pub async fn create_archive(
Err(_) => continue, Err(_) => continue,
}; };
match archive.start_file(filename, options) { match archive.start_file::<std::string::String, ()>(filename, options) {
Ok(_) => (), Ok(_) => (),
Err(err) => return Err(Box::new(err)), Err(err) => return Err(Box::new(err)),
}; };

2
src/services/utils.rs
View File

@@ -55,7 +55,7 @@ pub async fn response_to_tempfile(res: &mut Response) -> Option<(SpooledTempFile
} }
pub fn get_stream( pub fn get_stream(
mut temp_file: Box<dyn Read + Send>, mut temp_file: Box<dyn Read + Send + Sync>,
) -> impl futures_core::Stream<Item = Result<Bytes, Error>> { ) -> impl futures_core::Stream<Item = Result<Bytes, Error>> {
stream! { stream! {
let mut buf = [0; 2048]; let mut buf = [0; 2048];