kopuz-components 0.7.0

A modern, lightweight music player built with Rust and Dioxus.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49

use dioxus::prelude::*;
use server::source::TrackFavorite;

pub fn fmt_time(secs: u64) -> String {
    if secs == u64::MAX {
        return "--:--".to_string();
    }
    let m = secs / 60;
    let s = secs % 60;
    format!("{m}:{s:02}")
}

/// Toggle a favorite, offline-capable: the DB records the change as a pending
/// row (`dirty`) and the background reconciler pushes it to the server when one
/// is reachable. No auth required at toggle time — anonymous likes queue up and
/// flush on sign-in.
pub fn toggle_favorite(current_track: Option<reader::models::Track>) {
    let Some(track) = current_track else { return };
    let ref_ = track.id.key().to_string();
    if ref_.trim().is_empty() {
        return;
    }
    let Some(source_sig) = try_consume_context::<Signal<::server::source::ActiveSource>>() else {
        return;
    };
    let gens = try_consume_context::<hooks::db_reactivity::Generations>();
    let source = source_sig.peek().clone();
    spawn(async move {
        let new_fav = !track.is_favorite(&source).await;
        if new_fav {
            // Cache the track so the favorites view (which resolves refs → the
            // `tracks` table) can display it immediately, instead of only after
            // the next sync upserts it. Harmless for a track already cached.
            let _ = source.upsert_tracks(std::slice::from_ref(&track)).await;
        }
        if let Err(e) = track.set_favorite(&source, new_fav).await {
            tracing::warn!(error = %e, "failed to record favorite toggle");
        }
        if let Some(gens) = gens {
            gens.bump(hooks::db_reactivity::Table::Favorites);
            gens.bump(hooks::db_reactivity::Table::Tracks);
        }
        // A like on a syncing source is a pending DB row until the reconciler
        // flushes it — nudge it. (Local has no remote to push to.)
        if source.capabilities().sync {
            hooks::use_sync_task::nudge();
        }
    });
}