flibusta-apps/telegram_files_server
1
0
Fork 0
mirror of https://github.com/flibusta-apps/telegram_files_server.git synced 2025-12-06 04:25:38 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

Fix getFile timeouts

Browse Source
This commit is contained in:
Bulat Kurbanov
2024-05-08 20:36:20 +02:00
parent b944a9e724
commit bd62f1b076
1 changed files with 14 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
src/core/bot.rs
View File

@@ -1,7 +1,7 @@
use std::sync::{ use std::{sync::{
atomic::{AtomicUsize, Ordering}, atomic::{AtomicUsize, Ordering},
Arc, Arc,
}; }, time::Duration};
use once_cell::sync::Lazy; use once_cell::sync::Lazy;
use teloxide::Bot; use teloxide::Bot;
@@ -23,8 +23,18 @@ impl RoundRobinBot {
pub fn get_bot(&self) -> Bot { pub fn get_bot(&self) -> Bot {
let index = self.current_index.fetch_add(1, Ordering::Relaxed) % self.bot_tokens.len(); let index = self.current_index.fetch_add(1, Ordering::Relaxed) % self.bot_tokens.len();
Bot::new(self.bot_tokens[index].clone())
.set_api_url(reqwest::Url::parse(CONFIG.telegram_api_url.as_str()).unwrap()) let client = reqwest::Client::builder()
.connect_timeout(Duration::from_secs(5))
.timeout(Duration::from_secs(5 * 60))
.tcp_nodelay(true)
.build()
.unwrap();
Bot::with_client(
self.bot_tokens[index].clone(),
client
).set_api_url(reqwest::Url::parse(CONFIG.telegram_api_url.as_str()).unwrap())
} }
} }