johrpan/musicus
1
0
Fork 0
mirror of https://github.com/johrpan/musicus.git synced 2025-10-26 11:47:25 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

search: Order everything by last_played_at

Browse source
This commit is contained in:
Elias Projahn 2025-03-09 14:49:15 +01:00
parent 751dcde351
commit f2dfd4fcd4
1 changed files with 96 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

99
src/library.rs
View file

@ -181,6 +181,7 @@ impl Library {
} }
statement statement
.order_by(persons::last_played_at.desc())
.limit(9) .limit(9)
.select(persons::all_columns) .select(persons::all_columns)
.distinct() .distinct()
@ -223,6 +224,7 @@ impl Library {
} }
statement statement
.order_by(persons::last_played_at.desc())
.limit(9) .limit(9)
.select(persons::all_columns) .select(persons::all_columns)
.distinct() .distinct()
@ -273,6 +275,7 @@ impl Library {
} }
statement statement
.order_by(ensembles::last_played_at.desc())
.limit(9) .limit(9)
.select(ensembles::all_columns) .select(ensembles::all_columns)
.distinct() .distinct()
@ -313,6 +316,7 @@ impl Library {
} }
statement statement
.order_by(instruments::last_played_at.desc())
.limit(9) .limit(9)
.select(instruments::all_columns) .select(instruments::all_columns)
.distinct() .distinct()
@ -362,6 +366,7 @@ impl Library {
} }
statement statement
.order_by(works::last_played_at.desc())
.limit(9) .limit(9)
.select(works::all_columns) .select(works::all_columns)
.distinct() .distinct()
@ -418,6 +423,7 @@ impl Library {
} }
statement statement
.order_by(recordings::last_played_at.desc())
.limit(9) .limit(9)
.select(recordings::all_columns) .select(recordings::all_columns)
.distinct() .distinct()
@ -474,6 +480,7 @@ impl Library {
} }
let albums = statement let albums = statement
.order_by(albums::last_played_at.desc())
.limit(9) .limit(9)
.select(albums::all_columns) .select(albums::all_columns)
.distinct() .distinct()
@ -498,6 +505,7 @@ impl Library {
} => { } => {
let recordings = recordings::table let recordings = recordings::table
.filter(recordings::work_id.eq(&work.work_id)) .filter(recordings::work_id.eq(&work.work_id))
.order_by(recordings::last_played_at.desc())
.load::<tables::Recording>(connection)? .load::<tables::Recording>(connection)?
.into_iter() .into_iter()
.map(|r| Recording::from_table(r, connection)) .map(|r| Recording::from_table(r, connection))
@ -601,6 +609,11 @@ impl Library {
let now = Local::now().naive_local(); let now = Local::now().naive_local();
diesel::update(tracks::table)
.filter(tracks::track_id.eq(track_id))
.set(tracks::last_played_at.eq(now))
.execute(connection)?;
diesel::update(recordings::table) diesel::update(recordings::table)
.filter(exists( .filter(exists(
tracks::table.filter( tracks::table.filter(
@ -612,9 +625,89 @@ impl Library {
.set(recordings::last_played_at.eq(now)) .set(recordings::last_played_at.eq(now))
.execute(connection)?; .execute(connection)?;
diesel::update(tracks::table) diesel::update(works::table)
.filter(tracks::track_id.eq(track_id)) .filter(exists(
.set(tracks::last_played_at.eq(now)) recordings::table.inner_join(tracks::table).filter(
tracks::track_id
.eq(track_id)
.and(recordings::work_id.eq(works::work_id)),
),
))
.set(works::last_played_at.eq(now))
.execute(connection)?;
diesel::update(persons::table)
.filter(
exists(
work_persons::table
.inner_join(
works::table.inner_join(recordings::table.inner_join(tracks::table)),
)
.filter(
tracks::track_id
.eq(track_id)
.and(work_persons::person_id.eq(persons::person_id)),
),
)
.or(exists(
recording_persons::table
.inner_join(recordings::table.inner_join(tracks::table))
.filter(
tracks::track_id
.eq(track_id)
.and(recording_persons::person_id.eq(persons::person_id)),
),
)),
)
.set(persons::last_played_at.eq(now))
.execute(connection)?;
diesel::update(ensembles::table)
.filter(exists(
recording_ensembles::table
.inner_join(recordings::table.inner_join(tracks::table))
.filter(
tracks::track_id
.eq(track_id)
.and(recording_ensembles::ensemble_id.eq(ensembles::ensemble_id)),
),
))
.set(ensembles::last_played_at.eq(now))
.execute(connection)?;
diesel::update(mediums::table)
.filter(exists(
tracks::table.filter(
tracks::track_id
.eq(track_id)
.and(tracks::medium_id.eq(mediums::medium_id.nullable())),
),
))
.set(mediums::last_played_at.eq(now))
.execute(connection)?;
diesel::update(albums::table)
.filter(
exists(
album_recordings::table
.inner_join(recordings::table.inner_join(tracks::table))
.filter(
tracks::track_id
.eq(track_id)
.and(album_recordings::album_id.eq(albums::album_id)),
),
)
.or(exists(
album_mediums::table
.inner_join(mediums::table.inner_join(tracks::table))
.filter(
tracks::track_id
.eq(track_id)
.and(album_mediums::album_id.eq(albums::album_id)),
),
)),
)
.set(albums::last_played_at.eq(now))
.execute(connection)?; .execute(connection)?;
Ok(()) Ok(())