Compare commits

...

2 Commits

Author SHA1 Message Date
blank X 76dfd825f3
Mention video id when failing to send/upload video 2021-06-22 12:36:27 +07:00
blank X 8c2db3c958
Stop pinging Telegram
Turns out grammers does it by itself
2021-06-22 12:17:47 +07:00
2 changed files with 15 additions and 22 deletions

View File

@ -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()

View File

@ -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
);
}
}