Upload 2 files

src/main.rs

@@ -973,6 +973,54 @@ async fn oauth_playlist_tracks(Json(req): Json<OauthPlaylistTracksReq>) -> impl
     }
 }
 
+#[derive(Debug, Deserialize)]
+struct OauthArlReq {
+    access_token: String,
+}
+
+async fn oauth_arl(Json(req): Json<OauthArlReq>) -> impl IntoResponse {
+    let token = req.access_token.trim().to_string();
+    if token.is_empty() {
+        return json_error(StatusCode::BAD_REQUEST, "access_token required");
+    }
+
+    let jar = Arc::new(Jar::default());
+    let url_deezer = "https://www.deezer.com".parse::<Url>().unwrap();
+    jar.add_cookie_str("comeback=1; Domain=.deezer.com", &url_deezer);
+    let client = reqwest::Client::builder()
+        .cookie_provider(jar)
+        .timeout(std::time::Duration::from_secs(20))
+        .build()
+        .unwrap();
+
+    let _ = client
+        .get("https://api.deezer.com/platform/generic/track/80085")
+        .header("Authorization", format!("Bearer {}", token))
+        .send()
+        .await;
+
+    let ud = match gw_light_call(&client, "deezer.getUserData", "null", json!({})).await {
+        Ok(v) => v,
+        Err(e) => return json_error(StatusCode::BAD_GATEWAY, e),
+    };
+
+    let check_form = ud["checkForm"].as_str().unwrap_or("").to_string();
+    if check_form.is_empty() {
+        return json_error(StatusCode::BAD_GATEWAY, "no checkForm");
+    }
+
+    let arl_v = match gw_light_call(&client, "user.getArl", &check_form, json!({})).await {
+        Ok(v) => v,
+        Err(e) => return json_error(StatusCode::BAD_GATEWAY, e),
+    };
+    let arl = arl_v.as_str().unwrap_or("").to_string();
+    if arl.len() < 20 {
+        return json_error(StatusCode::BAD_GATEWAY, "no arl");
+    }
+
+    (StatusCode::OK, Json(json!({ "arl": arl }))).into_response()
+}
+
 #[tokio::main]
 async fn main() {
     let bind_addr = std::env::var("BIND_ADDR").unwrap_or("[::]".to_string());
@@ -1007,6 +1055,7 @@ async fn main() {
         .route("/oauth/me", post(oauth_me))
         .route("/oauth/playlists", post(oauth_playlists))
         .route("/oauth/playlist_tracks", post(oauth_playlist_tracks))
+        .route("/oauth/arl", post(oauth_arl))
         .with_state(state)
         .layer(cors)
         .layer(CompressionLayer::new())