This commit is contained in:
2023-08-07 01:47:44 +02:00
parent 9152242697
commit 22b3083d12

View File

@@ -12,6 +12,7 @@ use teloxide::{
}; };
use tokio::time::sleep; use tokio::time::sleep;
use tokio_util::compat::FuturesAsyncReadCompatExt; use tokio_util::compat::FuturesAsyncReadCompatExt;
use url::Url;
use crate::{ use crate::{
bots::{ bots::{
@@ -496,30 +497,37 @@ async fn download_archive(
return Ok(()); return Ok(());
} }
let downloaded_data = match download_file_by_link( // let downloaded_data = match download_file_by_link(
task.result_filename.unwrap(), // task.result_filename.unwrap(),
task.result_link.unwrap() // task.result_link.unwrap()
).await { // ).await {
Ok(v) => v, // Ok(v) => v,
Err(err) => { // Err(err) => {
send_error_message(bot, message.chat.id, message.id).await; // send_error_message(bot, message.chat.id, message.id).await;
log::error!("{:?}", err); // log::error!("{:?}", err);
return Err(err); // return Err(err);
}, // },
}; // };
match _send_downloaded_file( // match _send_downloaded_file(
&message, // &message,
bot.clone(), // bot.clone(),
downloaded_data, // downloaded_data,
).await { // ).await {
Ok(_) => (), // Ok(_) => (),
Err(err) => { // Err(err) => {
send_error_message(bot, message.chat.id, message.id).await; // send_error_message(bot, message.chat.id, message.id).await;
log::error!("{:?}", err); // log::error!("{:?}", err);
return Err(err); // return Err(err);
}, // },
} // }
let _ = bot
.send_document(
message.chat.id,
InputFile::url(Url::parse(&task.result_link.unwrap()).unwrap())
.file_name(task.result_filename.unwrap())
).await;
bot bot
.delete_message(message.chat.id, message.id) .delete_message(message.chat.id, message.id)