A decentralized music tracking and discovery platform built on AT Protocol 🎵
rocksky.app
spotify
atproto
lastfm
musicbrainz
scrobbling
listenbrainz
Increase Spotify batch size and log token errors
Increase find_spotify_users limit from 100 to 500. Parse token response
as text and use serde_json::from_str to improve error diagnostics; print
raw response on parse failure.
+8
-3
+8
-3
crates/spotify/src/lib.rs
+8
-3
crates/spotify/src/lib.rs
···
46
46
let mut sub = nc.subscribe("rocksky.spotify.user".to_string()).await?;
47
47
println!("Subscribed to {}", "rocksky.spotify.user".bright_green());
48
48
49
-
let users = find_spotify_users(&pool, 0, 100).await?;
49
+
let users = find_spotify_users(&pool, 0, 500).await?;
50
50
println!("Found {} users", users.len().bright_green());
51
51
52
52
// Shared HashMap to manage threads and their stop flags
···
262
262
])
263
263
.send()
264
264
.await?;
265
-
let token = response.json::<AccessToken>().await?;
266
-
Ok(token)
265
+
let token = response.text().await?;
266
+
let json_token = serde_json::from_str::<AccessToken>(&token);
267
+
if let Err(e) = json_token {
268
+
println!("Error parsing token: {}", token);
269
+
return Err(Error::from(e));
270
+
}
271
+
Ok(json_token.unwrap())
267
272
}
268
273
269
274
pub async fn get_currently_playing(