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

Browse Source
This commit is contained in:
Bulat Kurbanov
2023-08-06 23:17:41 +02:00
parent baf0605ca7
commit 7f62309813
1 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/services/task_creator.rs
View File

@@ -142,7 +142,7 @@ pub async fn create_archive(key: String, books: Vec<Book>, file_format: SmartStr
Err(err) => return Err(Box::new(err)), Err(err) => return Err(Box::new(err)),
}; };
set_progress_description(key.clone(), format!("Обработано: {}/{}", index + 1, books_count)).await; set_progress_description(key.clone(), format!("Загрузка книг: {}/{}", index + 1, books_count)).await;
} }
let mut archive_result = match archive.finish() { let mut archive_result = match archive.finish() {
@@ -163,6 +163,8 @@ pub async fn create_archive_task(key: String, data: CreateTask) {
ObjectType::Translator => get_books(data.object_id, data.allowed_langs, get_translator_books, data.file_format.clone()).await, ObjectType::Translator => get_books(data.object_id, data.allowed_langs, get_translator_books, data.file_format.clone()).await,
}; };
set_progress_description(key.clone(), "Получение списка книг...".to_string()).await;
let books = match books { let books = match books {
Ok(v) => v, Ok(v) => v,
Err(err) => { Err(err) => {
@@ -186,6 +188,8 @@ pub async fn create_archive_task(key: String, data: CreateTask) {
}, },
}; };
set_progress_description(key.clone(), "Сборка архива...".to_string()).await;
let archive_result = match create_archive(key.clone(), books, data.file_format).await { let archive_result = match create_archive(key.clone(), books, data.file_format).await {
Ok(v) => v, Ok(v) => v,
Err(err) => { Err(err) => {
@@ -195,6 +199,8 @@ pub async fn create_archive_task(key: String, data: CreateTask) {
}, },
}; };
set_progress_description(key.clone(), "Загрузка архива...".to_string()).await;
let link = match upload_to_minio(archive_result, final_filename.clone()).await { let link = match upload_to_minio(archive_result, final_filename.clone()).await {
Ok(v) => v, Ok(v) => v,
Err(err) => { Err(err) => {