Upload main.rs

src/main.rs

@@ -1744,6 +1744,40 @@ async fn oauth_arl(Json(req): Json<OauthArlReq>) -> impl IntoResponse {
     (StatusCode::OK, Json(json!({ "arl": arl }))).into_response()
 }
 
+#[derive(Debug, Deserialize)]
+struct OauthFlowReq {
+    access_token: String,
+    limit: Option<u32>,
+}
+
+async fn oauth_flow(Json(req): Json<OauthFlowReq>) -> impl IntoResponse {
+    let token = req.access_token.trim().to_string();
+    if token.is_empty() {
+        return json_error(StatusCode::BAD_REQUEST, "access_token required");
+    }
+    let limit = req.limit.unwrap_or(40).clamp(1, 100).to_string();
+    let client = reqwest::Client::builder()
+        .timeout(std::time::Duration::from_secs(15))
+        .build()
+        .unwrap();
+
+    let me = match api_deezer_get(&client, "/user/me", &token, &[]).await {
+        Ok(v) => v,
+        Err(e) => return json_error(StatusCode::SERVICE_UNAVAILABLE, e),
+    };
+    let uid = me.get("id").and_then(|x| x.as_i64()).unwrap_or(0);
+    if uid <= 0 {
+        return json_error(StatusCode::SERVICE_UNAVAILABLE, "api:no_user_id");
+    }
+
+    let path = format!("/user/{uid}/flow");
+    let extra = [("limit", limit)];
+    match api_deezer_get(&client, &path, &token, &extra).await {
+        Ok(v) => (StatusCode::OK, Json(v)).into_response(),
+        Err(e) => json_error(StatusCode::SERVICE_UNAVAILABLE, e),
+    }
+}
+
 #[tokio::main]
 async fn main() {
     let bind_addr = std::env::var("BIND_ADDR").unwrap_or("[::]".to_string());
@@ -1782,6 +1816,7 @@ async fn main() {
         .route("/oauth/playlists", post(oauth_playlists))
         .route("/oauth/playlist_tracks", post(oauth_playlist_tracks))
         .route("/oauth/arl", post(oauth_arl))
+        .route("/oauth/flow", post(oauth_flow))
         .with_state(state)
         .layer(cors)
         .layer(CompressionLayer::new())