A decentralized music tracking and discovery platform built on AT Protocol 🎵
rocksky.app
spotify
atproto
lastfm
musicbrainz
scrobbling
listenbrainz
refactor: remove unused 'did' parameter from save_album, save_track, and save_user functions
+2
-22
+2
-22
crates/jetstream/src/repo.rs
+2
-22
crates/jetstream/src/repo.rs
···
44
44
let scrobble_record: ScrobbleRecord =
45
45
serde_json::from_value(commit.record.clone())?;
46
46
47
-
let album_id = save_album(&mut tx, scrobble_record.clone(), did).await?;
47
+
let album_id = save_album(&mut tx, scrobble_record.clone()).await?;
48
48
let artist_id = save_artist(&mut tx, scrobble_record.clone()).await?;
49
-
let track_id = save_track(&mut tx, scrobble_record.clone(), did).await?;
49
+
let track_id = save_track(&mut tx, scrobble_record.clone()).await?;
50
50
51
51
save_album_track(&mut tx, &album_id, &track_id).await?;
52
52
save_artist_track(&mut tx, &artist_id, &track_id).await?;
···
224
224
pub async fn save_track(
225
225
tx: &mut sqlx::Transaction<'_, Postgres>,
226
226
scrobble_record: ScrobbleRecord,
227
-
did: &str,
228
227
) -> Result<String, Error> {
229
228
let uri: Option<String> = None;
230
229
let hash = sha256::digest(
···
304
303
pub async fn save_album(
305
304
tx: &mut sqlx::Transaction<'_, Postgres>,
306
305
scrobble_record: ScrobbleRecord,
307
-
did: &str,
308
306
) -> Result<String, Error> {
309
307
let hash = sha256::digest(
310
308
format!(
···
532
530
.fetch_all(&mut **tx)
533
531
.await?;
534
532
535
-
let users: Vec<User> = sqlx::query_as("SELECT * FROM users WHERE xata_id = $1")
536
-
.bind(user_id)
537
-
.fetch_all(&mut **tx)
538
-
.await?;
539
-
540
533
let artist_id: &str;
541
534
542
535
match artists.is_empty() {
543
536
true => {
544
537
tracing::info!(name = %record.name, "Artist not found in database, inserting new artist");
545
-
let did = users[0].did.clone();
546
538
sqlx::query(
547
539
r#"
548
540
INSERT INTO artists (
···
627
619
record: AlbumRecord,
628
620
uri: &str,
629
621
) -> Result<(), Error> {
630
-
let users: Vec<User> = sqlx::query_as("SELECT * FROM users WHERE xata_id = $1")
631
-
.bind(user_id)
632
-
.fetch_all(&mut **tx)
633
-
.await?;
634
-
635
622
let hash = sha256::digest(format!("{} - {}", record.title, record.artist).to_lowercase());
636
623
let mut albums: Vec<Album> = sqlx::query_as("SELECT * FROM albums WHERE sha256 = $1")
637
624
.bind(&hash)
···
643
630
match albums.is_empty() {
644
631
true => {
645
632
tracing::info!(title = %record.title, artist = %record.artist, "Album not found in database, inserting new album");
646
-
let did = users[0].did.clone();
647
633
sqlx::query(
648
634
r#"
649
635
INSERT INTO albums (
···
743
729
.fetch_all(&mut **tx)
744
730
.await?;
745
731
746
-
let users: Vec<User> = sqlx::query_as("SELECT * FROM users WHERE xata_id = $1")
747
-
.bind(user_id)
748
-
.fetch_all(&mut **tx)
749
-
.await?;
750
-
751
732
let track_id: &str;
752
733
753
734
match tracks.is_empty() {
754
735
true => {
755
736
tracing::info!(title = %record.title, artist = %record.artist, album = %record.album, "Track not found in database, inserting new track");
756
-
let did = users[0].did.clone();
757
737
sqlx::query(
758
738
r#"
759
739
INSERT INTO tracks (