Upload soundcloud.rs

src/soundcloud.rs

@@ -133,13 +133,9 @@ pub async fn download(Query(params): Query<DownloadParams>) -> impl IntoResponse
 
     let quality = params.quality.as_deref().unwrap_or("best");
     
-    // Формируем аргументы для yt-dlp
-    // Приоритизируем M4A/AAC (256kbps для Go+), затем MP3
-    let format_arg = match quality {
-        "256" => "bestaudio[ext=m4a]/bestaudio[ext=aac]/bestaudio[abr<=256]/bestaudio",
-        "128" => "bestaudio[abr<=128]/bestaudio",
-        _ => "bestaudio[ext=m4a]/bestaudio[ext=aac]/bestaudio", // Приоритет M4A/AAC
-    };
+    // Скачиваем ТОЛЬКО MP3 в максимальном доступном качестве
+    // SoundCloud обычно отдаёт 128kbps MP3 (стандарт) или 256kbps (Go+, редко)
+    let format_arg = "bestaudio[ext=mp3]/bestaudio";
     
     tracing::info!("Using format selector: {}", format_arg);
 
@@ -225,22 +221,14 @@ pub async fn download(Query(params): Query<DownloadParams>) -> impl IntoResponse
     let actual_file = if tokio::fs::metadata(&temp_file).await.is_ok() {
         temp_file.clone()
     } else {
-        // Пробуем найти с расширением - ВАЖНО: сначала ищем M4A/AAC, потом остальные
-        let mut found = None;
-        for ext in &["m4a", "aac", "opus", "webm", "mp3"] {
-            let path = format!("{}.{}", temp_file, ext);
-            if tokio::fs::metadata(&path).await.is_ok() {
-                tracing::info!("Found downloaded file with extension: {}", ext);
-                found = Some(path);
-                break;
-            }
-        }
-        match found {
-            Some(p) => p,
-            None => {
-                tracing::error!("Could not find downloaded file with any extension");
-                return (StatusCode::INTERNAL_SERVER_ERROR, "File not found").into_response();
-            }
+        // Ищем файл с расширением .mp3
+        let mp3_path = format!("{}.mp3", temp_file);
+        if tokio::fs::metadata(&mp3_path).await.is_ok() {
+            tracing::info!("Found downloaded MP3 file");
+            mp3_path
+        } else {
+            tracing::error!("Could not find downloaded MP3 file");
+            return (StatusCode::INTERNAL_SERVER_ERROR, "File not found").into_response();
         }
     };
 
@@ -254,92 +242,18 @@ pub async fn download(Query(params): Query<DownloadParams>) -> impl IntoResponse
         }
     };
 
-    // Определяем расширение оригинального файла
-    let orig_extension = if actual_file.ends_with(".m4a") {
-        "m4a"
-    } else if actual_file.ends_with(".opus") {
-        "opus"
-    } else if actual_file.ends_with(".webm") {
-        "webm"
-    } else if actual_file.ends_with(".aac") {
-        "aac"
-    } else {
-        "mp3"
-    };
-
-    // Определяем тип контента по расширению
-    let content_type = if actual_file.ends_with(".m4a") || actual_file.ends_with(".aac") {
-        "audio/mp4" // AAC обычно в контейнере M4A
-    } else if actual_file.ends_with(".opus") {
-        "audio/opus"
-    } else if actual_file.ends_with(".webm") {
-        "audio/webm"
-    } else {
-        "audio/mpeg"
-    };
-
-    // Telegram Bot API плохо работает с некоторыми форматами по URL.
-    // Конвертируем OPUS, WEBM и M4A в MP3 для совместимости.
-    let (final_data, final_content_type, final_extension) = 
-        if actual_file.ends_with(".opus") || actual_file.ends_with(".webm") || actual_file.ends_with(".m4a") || actual_file.ends_with(".aac") {
-            let target_format = if actual_file.ends_with(".m4a") || actual_file.ends_with(".aac") {
-                "AAC/M4A"
-            } else if actual_file.ends_with(".opus") {
-                "OPUS"
-            } else {
-                "WEBM"
-            };
-            tracing::info!("Converting {} to MP3 320k for Telegram compatibility", target_format);
-            
-            let mp3_file = format!("{}.mp3", temp_file);
-            let convert_output = Command::new("ffmpeg")
-                .args([
-                    "-i", &actual_file,
-                    "-vn",
-                    "-ar", "44100",
-                    "-ac", "2",
-                    "-b:a", "320k",
-                    &mp3_file,
-                ])
-                .stdout(Stdio::null())
-                .stderr(Stdio::null())
-                .output()
-                .await;
-            
-            match convert_output {
-                Ok(out) if out.status.success() => {
-                    if let Ok(mp3_data) = tokio::fs::read(&mp3_file).await {
-                        let _ = tokio::fs::remove_file(&mp3_file).await;
-                        (mp3_data, "audio/mpeg", "mp3")
-                    } else {
-                        // Если к��нвертация не удалась, отдаём оригинал
-                        (audio_data, content_type, orig_extension)
-                    }
-                }
-                _ => {
-                    // Если конвертация не удалась, отдаём оригинал
-                    (audio_data, content_type, orig_extension)
-                }
-            }
-        } else {
-            (audio_data, content_type, orig_extension)
-        };
-
-    // Определяем расширение для имени файла
-    let extension = final_extension;
-
     // Удаляем временный файл
     let _ = tokio::fs::remove_file(&actual_file).await;
 
     // Формируем имя файла
     let filename = if let Some(ref title) = params.title {
         if let Some(ref performer) = params.performer {
-            format!("{} - {}.{}", performer, title, extension)
+            format!("{} - {}.mp3", performer, title)
         } else {
-            format!("{}.{}", title, extension)
+            format!("{}.mp3", title)
         }
     } else {
-        format!("soundcloud_track.{}", extension)
+        "soundcloud_track.mp3".to_string()
     };
 
     let filename_safe = filename
@@ -348,12 +262,12 @@ pub async fn download(Query(params): Query<DownloadParams>) -> impl IntoResponse
         .take(200)
         .collect::<String>();
 
-    tracing::info!("Sending SoundCloud file: {} ({} bytes, {})", filename_safe, final_data.len(), final_content_type);
+    tracing::info!("Sending SoundCloud file: {} ({} bytes, audio/mpeg)", filename_safe, audio_data.len());
 
     let mut response = axum::response::Response::builder()
         .status(200)
-        .header("Content-Type", final_content_type)
-        .header("Content-Length", final_data.len().to_string())
+        .header("Content-Type", "audio/mpeg")
+        .header("Content-Length", audio_data.len().to_string())
         .header("Content-Disposition", format!("inline; filename=\"{}\"", filename_safe))
         .header("Accept-Ranges", "bytes")
         .header("Access-Control-Allow-Origin", "*")
@@ -365,7 +279,7 @@ pub async fn download(Query(params): Query<DownloadParams>) -> impl IntoResponse
     }
     
     response
-        .body(axum::body::Body::from(final_data))
+        .body(axum::body::Body::from(audio_data))
         .unwrap()
         .into_response()
 }