forked from
rocksky.app/rocksky
A decentralized music tracking and discovery platform built on AT Protocol 🎵
fix: update album and artist queries to join user tables for URI lookups
+6
-4
+3
-2
crates/scrobbler/src/repo/album.rs
+3
-2
crates/scrobbler/src/repo/album.rs
···
21
21
pub async fn get_album_by_uri(pool: &Pool<Postgres>, uri: &str) -> Result<Album, Error> {
22
22
let results: Vec<Album> = sqlx::query_as(
23
23
r#"
24
-
SELECT * FROM albums
25
-
WHERE albums.uri = $1
24
+
SELECT * FROM user_albums
25
+
LEFT JOIN albums ON user_albums.album_id = albums.xata_id
26
+
WHERE user_albums.uri = $1
26
27
"#,
27
28
)
28
29
.bind(uri)
+3
-2
crates/scrobbler/src/repo/artist.rs
+3
-2
crates/scrobbler/src/repo/artist.rs
···
24
24
pub async fn get_artist_by_uri(pool: &Pool<Postgres>, uri: &str) -> Result<Artist, Error> {
25
25
let results: Vec<Artist> = sqlx::query_as(
26
26
r#"
27
-
SELECT * FROM artists
28
-
WHERE artists.uri = $1
27
+
SELECT * FROM user_artists
28
+
LEFT JOIN artists ON user_artists.artist_id = artists.xata_id
29
+
WHERE user_artists.uri = $1
29
30
"#,
30
31
)
31
32
.bind(uri)