Upload main.rs

src/main.rs

@@ -910,6 +910,12 @@ async fn inject_audio_metadata(mut bytes: Vec<u8>, ext: &str, meta: &AudioTagMet
         return bytes;
     }
 
+    // Временно отключаем добавление метаданных для FLAC - возможно lofty ломает файл
+    if ext.eq_ignore_ascii_case("flac") {
+        tracing::warn!("Skipping metadata injection for FLAC to avoid corruption");
+        return bytes;
+    }
+
     let tag_type = if ext.eq_ignore_ascii_case("flac") {
         TagType::VorbisComments
     } else {
@@ -1073,21 +1079,21 @@ async fn send_audio(
     let filename = format!("track_{}.{}", q.id, ext);
 
     // Загружаем в Telegram через отдельный клиент.
-    // Если аплоад виснет по сети, важно быстро вернуть ошибку боту,
-    // чтобы он раньше переключился на 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(8))
-        .timeout(Duration::from_secs(18))
-        .tcp_keepalive(Duration::from_secs(30))
+        .connect_timeout(Duration::from_secs(10))
+        .timeout(Duration::from_secs(30))
+        .tcp_keepalive(Duration::from_secs(20))
         .build()
         .unwrap();
 
     let mut tg_json: Option<serde_json::Value> = None;
     let mut last_tg_err: Option<String> = None;
 
-    for attempt in 1..=2u8 {
+    for attempt in 1..=3u8 {
+        tracing::info!("Telegram sendAudio attempt {} for track {} ({} bytes)", attempt, q.id, dec.len());
+        
         let part = reqwest::multipart::Part::bytes(dec.clone())
             .file_name(filename.clone())
             .mime_str(mime)
@@ -1106,6 +1112,7 @@ async fn send_audio(
                     Ok(j) => {
                         if status.is_success() && j.get("ok").and_then(|v| v.as_bool()) == Some(true) {
                             tg_json = Some(j);
+                            tracing::info!("Telegram sendAudio success on attempt {}", attempt);
                             break;
                         }
                         let desc = j
@@ -1128,8 +1135,8 @@ async fn send_audio(
             }
         }
 
-        if attempt < 2 {
-            tokio::time::sleep(Duration::from_secs(1)).await;
+        if attempt < 3 {
+            tokio::time::sleep(Duration::from_secs(3)).await;
         }
     }