rocksky.app
A decentralized music tracking and discovery platform built on AT Protocol 🎵
rocksky.app
spotify
atproto
lastfm
musicbrainz
scrobbling
listenbrainz
fix: improve artist matching logic in scrobble functions to prevent mismatches
tsiry-sandratraina.com
+46
-32
crates/scrobbler/src/scrobbler.rs
+46
-32
crates/scrobbler/src/scrobbler.rs
···
378
.await?;
379
380
if let Some(track) = result.tracks.items.first() {
381
-
tracing::info!(artist = %scrobble.artist, track = %scrobble.track, "Spotify (track)");
382
-
scrobble.album = Some(track.album.name.clone());
383
-
let mut track = track.clone();
384
385
-
if let Some(album) = spotify_client.get_album(&track.album.id).await? {
386
-
track.album = album;
387
-
}
388
389
-
if let Some(artist) = spotify_client
390
-
.get_artist(&track.album.artists[0].id)
391
-
.await?
392
-
{
393
-
track.album.artists[0] = artist;
394
-
}
395
396
-
rocksky::scrobble(cache, &did, track.into(), scrobble.timestamp).await?;
397
-
tokio::time::sleep(std::time::Duration::from_secs(1)).await;
398
-
return Ok(());
399
}
400
401
let query = format!(
···
616
let artists = track
617
.artists
618
.iter()
619
-
.map(|a| a.name.clone())
620
.collect::<Vec<_>>()
621
.join(", ")
622
.to_lowercase();
···
625
if !artists.contains(&scrobble.artist.to_lowercase()) {
626
tracing::warn!(artist = %artist, track = ?track, "Artist mismatch, skipping");
627
return Ok(());
628
-
}
629
630
-
tracing::info!("Spotify (track)");
631
-
scrobble.album = Some(track.album.name.clone());
632
-
let mut track = track.clone();
633
634
-
if let Some(album) = spotify_client.get_album(&track.album.id).await? {
635
-
track.album = album;
636
-
}
637
638
-
if let Some(artist) = spotify_client
639
-
.get_artist(&track.album.artists[0].id)
640
-
.await?
641
-
{
642
-
track.album.artists[0] = artist;
643
}
644
-
645
-
rocksky::scrobble(cache, &did, track.into(), scrobble.timestamp).await?;
646
-
tokio::time::sleep(std::time::Duration::from_secs(1)).await;
647
-
return Ok(());
648
}
649
650
let query = format!(
···
378
.await?;
379
380
if let Some(track) = result.tracks.items.first() {
381
+
let artists = track
382
+
.artists
383
+
.iter()
384
+
.map(|a| a.name.to_lowercase().clone())
385
+
.collect::<Vec<_>>()
386
+
.join(", ")
387
+
.to_lowercase();
388
389
+
// check if artists don't contain the scrobble artist (to avoid wrong matches)
390
+
if !artists.contains(&scrobble.artist.to_lowercase()) {
391
+
tracing::warn!(artist = %artist, track = ?track, "Artist mismatch, skipping");
392
+
return Ok(());
393
+
} else {
394
+
tracing::info!(artist = %scrobble.artist, track = %scrobble.track, "Spotify (track)");
395
+
scrobble.album = Some(track.album.name.clone());
396
+
let mut track = track.clone();
397
398
+
if let Some(album) = spotify_client.get_album(&track.album.id).await? {
399
+
track.album = album;
400
+
}
401
402
+
if let Some(artist) = spotify_client
403
+
.get_artist(&track.album.artists[0].id)
404
+
.await?
405
+
{
406
+
track.album.artists[0] = artist;
407
+
}
408
+
409
+
rocksky::scrobble(cache, &did, track.into(), scrobble.timestamp).await?;
410
+
tokio::time::sleep(std::time::Duration::from_secs(1)).await;
411
+
return Ok(());
412
+
}
413
}
414
415
let query = format!(
···
630
let artists = track
631
.artists
632
.iter()
633
+
.map(|a| a.name.to_lowercase().clone())
634
.collect::<Vec<_>>()
635
.join(", ")
636
.to_lowercase();
···
639
if !artists.contains(&scrobble.artist.to_lowercase()) {
640
tracing::warn!(artist = %artist, track = ?track, "Artist mismatch, skipping");
641
return Ok(());
642
+
} else {
643
+
tracing::info!("Spotify (track)");
644
+
scrobble.album = Some(track.album.name.clone());
645
+
let mut track = track.clone();
646
647
+
if let Some(album) = spotify_client.get_album(&track.album.id).await? {
648
+
track.album = album;
649
+
}
650
651
+
if let Some(artist) = spotify_client
652
+
.get_artist(&track.album.artists[0].id)
653
+
.await?
654
+
{
655
+
track.album.artists[0] = artist;
656
+
}
657
658
+
rocksky::scrobble(cache, &did, track.into(), scrobble.timestamp).await?;
659
+
tokio::time::sleep(std::time::Duration::from_secs(1)).await;
660
+
return Ok(());
661
}
662
}
663
664
let query = format!(
+16
-17
crates/webscrobbler/src/scrobbler.rs
+16
-17
crates/webscrobbler/src/scrobbler.rs
···
131
let artists = track
132
.artists
133
.iter()
134
-
.map(|a| a.name.clone())
135
.collect::<Vec<_>>()
136
.join(", ")
137
.to_lowercase();
···
139
// check if artists don't contain the scrobble artist (to avoid wrong matches)
140
if !artists.contains(&scrobble.data.song.parsed.artist.trim().to_lowercase()) {
141
tracing::warn!(artist = %artist, track = ?track, "Artist mismatch, skipping");
142
-
return Ok(());
143
-
}
144
145
-
tracing::info!("Spotify (track)");
146
-
let mut track = track.clone();
147
148
-
if let Some(album) = spotify_client.get_album(&track.album.id).await? {
149
-
track.album = album;
150
-
}
151
152
-
if let Some(artist) = spotify_client
153
-
.get_artist(&track.album.artists[0].id)
154
-
.await?
155
-
{
156
-
track.album.artists[0] = artist;
157
}
158
-
159
-
rocksky::scrobble(cache, &did, track.into(), scrobble.time).await?;
160
-
tokio::time::sleep(std::time::Duration::from_secs(1)).await;
161
-
return Ok(());
162
}
163
164
let query = format!(
···
131
let artists = track
132
.artists
133
.iter()
134
+
.map(|a| a.name.to_lowercase().clone())
135
.collect::<Vec<_>>()
136
.join(", ")
137
.to_lowercase();
···
139
// check if artists don't contain the scrobble artist (to avoid wrong matches)
140
if !artists.contains(&scrobble.data.song.parsed.artist.trim().to_lowercase()) {
141
tracing::warn!(artist = %artist, track = ?track, "Artist mismatch, skipping");
142
+
} else {
143
+
tracing::info!("Spotify (track)");
144
+
let mut track = track.clone();
145
146
+
if let Some(album) = spotify_client.get_album(&track.album.id).await? {
147
+
track.album = album;
148
+
}
149
150
+
if let Some(artist) = spotify_client
151
+
.get_artist(&track.album.artists[0].id)
152
+
.await?
153
+
{
154
+
track.album.artists[0] = artist;
155
+
}
156
157
+
rocksky::scrobble(cache, &did, track.into(), scrobble.time).await?;
158
+
tokio::time::sleep(std::time::Duration::from_secs(1)).await;
159
+
return Ok(());
160
}
161
}
162
163
let query = format!(