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;
|
mod workers;
|
||||||
use grammers_client::{types::chat::PackedChat, Client, Config, InputMessage, Update};
|
use grammers_client::{types::chat::PackedChat, Client, Config, InputMessage, Update};
|
||||||
use grammers_session::Session;
|
use grammers_session::Session;
|
||||||
use grammers_tl_types::functions::Ping;
|
use rand::{thread_rng, Rng};
|
||||||
use rand::{random, thread_rng, Rng};
|
|
||||||
use regex::Regex;
|
use regex::Regex;
|
||||||
use reqwest::ClientBuilder;
|
use reqwest::ClientBuilder;
|
||||||
use std::collections::{HashSet, VecDeque};
|
use std::collections::{HashSet, VecDeque};
|
||||||
|
@ -60,18 +59,6 @@ async fn async_main() {
|
||||||
eprintln!("Failed to save session: {:?}", err);
|
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() {
|
if config::STORAGE_CHAT.is_none() {
|
||||||
while let Some(update) = tclient
|
while let Some(update) = tclient
|
||||||
.next_update()
|
.next_update()
|
||||||
|
|
|
@ -679,34 +679,40 @@ pub async fn upload_worker(
|
||||||
.mime_type("video/x-matroska")
|
.mime_type("video/x-matroska")
|
||||||
.file(uploaded);
|
.file(uploaded);
|
||||||
if let Err(err) = tclient.send_message(&chat, message).await {
|
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
|
if let Err(err) = tclient
|
||||||
.send_message(
|
.send_message(
|
||||||
&chat,
|
&chat,
|
||||||
InputMessage::text("Failed to send video, see logs"),
|
InputMessage::text(&format!(
|
||||||
|
"Failed to send video {}, see logs",
|
||||||
|
&video_id
|
||||||
|
)),
|
||||||
)
|
)
|
||||||
.await
|
.await
|
||||||
{
|
{
|
||||||
eprintln!(
|
eprintln!(
|
||||||
"Failed to send message about failing to send video: {:?}",
|
"Failed to send message about failing to send video {}: {:?}",
|
||||||
err
|
&video_id, err
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
Err(err) => {
|
Err(err) => {
|
||||||
success = false;
|
success = false;
|
||||||
eprintln!("Failed to upload video: {:?}", err);
|
eprintln!("Failed to upload video {}: {:?}", &video_id, err);
|
||||||
if let Err(err) = tclient
|
if let Err(err) = tclient
|
||||||
.send_message(
|
.send_message(
|
||||||
&chat,
|
&chat,
|
||||||
InputMessage::text("Failed to upload video, see logs"),
|
InputMessage::text(&format!(
|
||||||
|
"Failed to upload video {}, see logs",
|
||||||
|
&video_id
|
||||||
|
)),
|
||||||
)
|
)
|
||||||
.await
|
.await
|
||||||
{
|
{
|
||||||
eprintln!(
|
eprintln!(
|
||||||
"Failed to send message about failing to upload video: {:?}",
|
"Failed to send message about failing to upload video {}: {:?}",
|
||||||
err
|
&video_id, err
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue