Upload 3 files

Cargo.toml

@@ -13,7 +13,7 @@ tracing = "0.1"
 tracing-subscriber = "0.3"
 tokio = { version = "1", features = ["rt-multi-thread", "macros", "fs"] }
 serde = { version = "1.0", features = ["derive"] }
-reqwest = { version = "0.11", features = ["json", "rustls-tls", "cookies", "gzip", "stream"], default-features = false }
+reqwest = { version = "0.11", features = ["json", "rustls-tls", "cookies", "gzip", "brotli", "deflate", "stream"], default-features = false }
 serde_json = "1.0"
 thiserror = "1.0"
 bytes = "1"

src/api.rs

@@ -145,9 +145,7 @@ impl APIClient {
 
         let body = serde_json::to_string(params)?;
 
-        let json: DeezerResponse = self
-            .client
-            .post(url)
+        let resp = self.client.post(url)
             .header("Content-Type", "text/plain;charset=UTF-8")
             .body(body)
             .query(&[
@@ -174,10 +172,18 @@ impl APIClient {
                 "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/124.0.0.0 Safari/537.36",
             )
             .send()
-            .await?
-            .json()
             .await?;
 
+        let status = resp.status().as_u16();
+        let text = resp.text().await?;
+        let json: DeezerResponse = serde_json::from_str(&text).map_err(|e| {
+            let snip: String = text.chars().take(200).collect();
+            APIError::DeezerError {
+                code: "bad_json".to_string(),
+                message: format!("status:{status}; {e}; {snip}"),
+            }
+        })?;
+
         if let Some(error) = json.error.as_object() {
             for (code, message) in error {
                 return Err(APIError::DeezerError {
@@ -258,6 +264,14 @@ impl APIClient {
             .header("Content-Type", "application/json")
             .header("Origin", "https://www.deezer.com")
             .header("Referer", "https://www.deezer.com/")
+            .header("Accept-Language", "en-US,en;q=0.9")
+            .header("sec-ch-ua", "\"Chromium\";v=\"124\", \"Google Chrome\";v=\"124\", \"Not-A.Brand\";v=\"99\"")
+            .header("sec-ch-ua-mobile", "?0")
+            .header("sec-ch-ua-platform", "\"Windows\"")
+            .header(
+                "User-Agent",
+                "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/124.0.0.0 Safari/537.36",
+            )
             .json(&req)
             .send()
             .await

src/main.rs

@@ -229,10 +229,15 @@ async fn fetch_media_url(
         .map_err(|e| e.to_string())?;
 
     let status = media_resp.status();
-    let media_json: serde_json::Value = media_resp
-        .json()
+    let media_text = media_resp
+        .text()
         .await
-        .map_err(|_| "Bad media response".to_string())?;
+        .map_err(|_| "media:read".to_string())?;
+
+    let media_json: serde_json::Value = serde_json::from_str(&media_text).map_err(|_| {
+        let snip: String = media_text.chars().take(200).collect();
+        format!("media_bad_json:{}:{}", status.as_u16(), snip)
+    })?;
 
     let url = extract_media_url(&media_json);
     if !url.is_empty() {