Upload main.rs

src/main.rs

@@ -1073,14 +1073,14 @@ async fn send_audio(
     let filename = format!("track_{}.{}", q.id, ext);
 
     // Загружаем в Telegram через отдельный клиент.
-    // Для api.telegram.org в некоторых средах HF прямое соединение с no_proxy()
-    // падает на TLS handshake, поэтому здесь даем reqwest использовать env proxy
-    // и принудительно уходим на HTTP/1.1 с короткими ретраями.
+    // Если аплоад виснет по сети, важно быстро вернуть ошибку боту,
+    // чтобы он раньше переключился на fallback по URL.
     let tg_url = format!("https://api.telegram.org/bot{}/sendAudio", bot_token);
     let tg_http = reqwest::Client::builder()
         .https_only(true)
-        .connect_timeout(Duration::from_secs(20))
-        .timeout(Duration::from_secs(180))
+        .http1_only()
+        .connect_timeout(Duration::from_secs(8))
+        .timeout(Duration::from_secs(18))
         .tcp_keepalive(Duration::from_secs(30))
         .build()
         .unwrap();
@@ -1088,7 +1088,7 @@ async fn send_audio(
     let mut tg_json: Option<serde_json::Value> = None;
     let mut last_tg_err: Option<String> = None;
 
-    for attempt in 1..=3u8 {
+    for attempt in 1..=2u8 {
         let part = reqwest::multipart::Part::bytes(dec.clone())
             .file_name(filename.clone())
             .mime_str(mime)
@@ -1129,8 +1129,8 @@ async fn send_audio(
             }
         }
 
-        if attempt < 3 {
-            tokio::time::sleep(Duration::from_secs((attempt as u64) * 2)).await;
+        if attempt < 2 {
+            tokio::time::sleep(Duration::from_secs(1)).await;
         }
     }