Compare commits
2 Commits
9993e52e0d
...
76dfd825f3
Author | SHA1 | Date |
---|---|---|
|
76dfd825f3 | |
|
8c2db3c958 |
15
src/main.rs
15
src/main.rs
|
@ -4,8 +4,7 @@ mod utils;
|
|||
mod workers;
|
||||
use grammers_client::{types::chat::PackedChat, Client, Config, InputMessage, Update};
|
||||
use grammers_session::Session;
|
||||
use grammers_tl_types::functions::Ping;
|
||||
use rand::{random, thread_rng, Rng};
|
||||
use rand::{thread_rng, Rng};
|
||||
use regex::Regex;
|
||||
use reqwest::ClientBuilder;
|
||||
use std::collections::{HashSet, VecDeque};
|
||||
|
@ -60,18 +59,6 @@ async fn async_main() {
|
|||
eprintln!("Failed to save session: {:?}", err);
|
||||
}
|
||||
}
|
||||
{
|
||||
let tclient = tclient.clone();
|
||||
tokio::task::spawn(async move {
|
||||
loop {
|
||||
let ping_id = random();
|
||||
if let Err(err) = tclient.invoke(&Ping { ping_id }).await {
|
||||
eprintln!("Failed to ping Telegram: {:?}", err);
|
||||
}
|
||||
sleep(Duration::from_secs(60)).await;
|
||||
}
|
||||
});
|
||||
}
|
||||
if config::STORAGE_CHAT.is_none() {
|
||||
while let Some(update) = tclient
|
||||
.next_update()
|
||||
|
|
|
@ -679,34 +679,40 @@ pub async fn upload_worker(
|
|||
.mime_type("video/x-matroska")
|
||||
.file(uploaded);
|
||||
if let Err(err) = tclient.send_message(&chat, message).await {
|
||||
eprintln!("Failed to send video: {:?}", err);
|
||||
eprintln!("Failed to send video {}: {:?}", &video_id, err);
|
||||
if let Err(err) = tclient
|
||||
.send_message(
|
||||
&chat,
|
||||
InputMessage::text("Failed to send video, see logs"),
|
||||
InputMessage::text(&format!(
|
||||
"Failed to send video {}, see logs",
|
||||
&video_id
|
||||
)),
|
||||
)
|
||||
.await
|
||||
{
|
||||
eprintln!(
|
||||
"Failed to send message about failing to send video: {:?}",
|
||||
err
|
||||
"Failed to send message about failing to send video {}: {:?}",
|
||||
&video_id, err
|
||||
);
|
||||
}
|
||||
}
|
||||
}
|
||||
Err(err) => {
|
||||
success = false;
|
||||
eprintln!("Failed to upload video: {:?}", err);
|
||||
eprintln!("Failed to upload video {}: {:?}", &video_id, err);
|
||||
if let Err(err) = tclient
|
||||
.send_message(
|
||||
&chat,
|
||||
InputMessage::text("Failed to upload video, see logs"),
|
||||
InputMessage::text(&format!(
|
||||
"Failed to upload video {}, see logs",
|
||||
&video_id
|
||||
)),
|
||||
)
|
||||
.await
|
||||
{
|
||||
eprintln!(
|
||||
"Failed to send message about failing to upload video: {:?}",
|
||||
err
|
||||
"Failed to send message about failing to upload video {}: {:?}",
|
||||
&video_id, err
|
||||
);
|
||||
}
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue