5 Commits

Author SHA1 Message Date
Ultradesu 98525718d0 Improved auth stability 2026-06-17 10:34:03 +01:00
Ultradesu cf82b203a9 Improved auth stability 2026-06-16 22:34:01 +01:00
Ultradesu 2da81ecb89 Improved auth stability 2026-06-16 03:55:11 +01:00
Ultradesu 54ba8b4309 Fixed lock 2026-06-15 12:37:27 +01:00
Ultradesu ba5a73816e Added Visual select for multiple tracks, added Queue management. Added info for tracks 2026-06-15 12:28:34 +01:00
16 changed files with 1128 additions and 77 deletions
Generated
+1 -1
View File
@@ -1180,7 +1180,7 @@ checksum = "42703706b716c37f96a77aea830392ad231f44c9e9a67872fa5548707e11b11c"
[[package]]
name = "furumi_tui"
version = "0.1.2"
version = "0.1.4"
dependencies = [
"anyhow",
"arboard",
+1 -1
View File
@@ -1,6 +1,6 @@
[package]
name = "furumi_tui"
version = "0.1.2"
version = "0.1.5"
edition = "2024"
[[bin]]
+7
View File
@@ -58,6 +58,13 @@ pub fn now_epoch_seconds() -> i64 {
.unwrap_or(0)
}
pub fn now_epoch_millis() -> i64 {
SystemTime::now()
.duration_since(UNIX_EPOCH)
.map(|d| d.as_millis() as i64)
.unwrap_or(0)
}
pub fn session_path() -> Option<PathBuf> {
crate::config::project_dirs().map(|dirs| dirs.config_dir().join("credentials.json"))
}
+8
View File
@@ -78,6 +78,8 @@ pub struct TrackItem {
/// Absent in the artist-appearance variant of track payloads.
#[serde(default)]
pub track_number: Option<i32>,
#[serde(default)]
pub disc_number: Option<i32>,
pub duration_seconds: f64,
#[serde(default)]
pub artists: Vec<ArtistRef>,
@@ -95,12 +97,18 @@ pub struct TrackItem {
pub stream_url: String,
#[allow(dead_code, reason = "now-playing artwork in milestone 3")]
pub cover_url: Option<String>,
#[serde(default)]
pub uploader_name: String,
pub audio_format: Option<String>,
pub audio_bitrate: Option<i32>,
pub audio_sample_rate: Option<i32>,
pub audio_bit_depth: Option<i32>,
pub file_size_bytes: Option<i64>,
pub lastfm_listeners: Option<i64>,
#[allow(dead_code, reason = "popularity column later")]
pub lastfm_playcount: Option<i64>,
pub lastfm_rating: Option<f64>,
pub lastfm_updated_at: Option<String>,
}
impl TrackItem {
+10 -1
View File
@@ -28,8 +28,11 @@ pub enum Action {
ToggleShuffle,
CycleRepeat,
ToggleLike,
ToggleTrackSelection,
OpenTrackInfo,
QueueAddNext,
QueueAddLast,
RemoveFromQueue,
ClearQueue,
GoToRelease,
AddToPlaylist,
@@ -86,10 +89,13 @@ impl Action {
| Action::CycleRepeat => Category::Playback,
Action::QueueAddNext
| Action::QueueAddLast
| Action::RemoveFromQueue
| Action::ClearQueue
| Action::AddToPlaylist
| Action::NewPlaylist
| Action::ToggleLike => Category::Queue,
| Action::ToggleLike
| Action::ToggleTrackSelection
| Action::OpenTrackInfo => Category::Queue,
Action::MoveUp
| Action::MoveDown
| Action::MoveLeft
@@ -157,8 +163,11 @@ impl Action {
Action::ToggleShuffle => "Toggle shuffle".into(),
Action::CycleRepeat => "Cycle repeat mode".into(),
Action::ToggleLike => "Like / unlike".into(),
Action::ToggleTrackSelection => "Track line selection".into(),
Action::OpenTrackInfo => "Track info".into(),
Action::QueueAddNext => "Queue: add next".into(),
Action::QueueAddLast => "Queue: add to end".into(),
Action::RemoveFromQueue => "Queue: remove selected".into(),
Action::ClearQueue => "Queue: clear".into(),
Action::GoToRelease => "Open the track's release".into(),
Action::AddToPlaylist => "Add track to a playlist…".into(),
+168 -29
View File
@@ -9,7 +9,7 @@ pub mod state;
pub mod update;
use std::sync::Arc;
use std::time::Duration;
use std::time::{Duration, Instant};
use anyhow::Result;
use crokey::KeyCombination;
@@ -30,6 +30,10 @@ use update::{Effect, update};
const TICK_INTERVAL: Duration = Duration::from_millis(250);
const DEVICE_POLL_INTERVAL: Duration = Duration::from_millis(500);
// A paused StreamDownload can later issue Range requests with the bearer it
// captured at open time. Reopen after idle so resume gets a freshly refreshed
// token instead of reviving a stale HTTP stream.
const STALE_STREAM_PAUSE_REOPEN_AFTER: Duration = Duration::from_secs(30);
/// Handles shared by background tasks; AppState stays pure UI data.
pub struct Runtime {
@@ -42,6 +46,8 @@ pub struct Runtime {
/// Monotonic sequence for live search; stale responses are dropped.
pub search_seq: Arc<std::sync::atomic::AtomicU64>,
pub player: player::Controller,
pub player_start_pending: bool,
pub player_paused_since: Option<Instant>,
pub last_state_push: Option<std::time::Instant>,
pub media_tx: std::sync::mpsc::Sender<crate::media::MediaUpdate>,
pub last_media_push: Option<std::time::Instant>,
@@ -76,6 +82,8 @@ pub async fn run(
player: player::spawn(move |event| {
let _ = player_events.send(AppEvent::Player(event));
}),
player_start_pending: false,
player_paused_since: None,
last_state_push: None,
media_tx,
last_media_push: None,
@@ -110,7 +118,10 @@ pub async fn run(
Some(app_event) = event_rx.recv() => handle_app_event(&mut state, &mut runtime, app_event),
_ = tick.tick() => {
expire_quit_confirmation(&mut state);
if state.player.current.is_some() && state.devices.is_playback_device() {
if state.player.current.is_some()
&& state.devices.is_playback_device()
&& !runtime.player_start_pending
{
state.player.position_secs = runtime.player.shared.position().as_secs_f64();
state.player.paused = runtime.player.shared.paused();
} else if state.player.current.is_some()
@@ -392,7 +403,7 @@ fn device_playback_state(state: &AppState) -> Option<crate::api::models::DeviceP
shuffle: player.shuffle,
repeat_mode: player.repeat.label().to_string(),
volume: f64::from(player.volume) / 100.0,
updated_at_ms: 0,
updated_at_ms: auth::now_epoch_millis(),
})
}
@@ -431,7 +442,7 @@ fn spawn_art_fetch(
/// Execute a side effect requested by update().
fn perform_effect(state: &mut AppState, runtime: &mut Runtime, effect: Effect) {
if perform_remote_effect(state, runtime, effect) {
if perform_remote_effect(state, runtime, &effect) {
return;
}
match effect {
@@ -442,10 +453,16 @@ fn perform_effect(state: &mut AppState, runtime: &mut Runtime, effect: Effect) {
push_media_update(state, runtime, true);
}
Effect::TogglePause => {
runtime.player.toggle_pause();
if state.player.paused {
pause_current_audio(state, runtime);
} else {
resume_current_audio(state, runtime);
}
push_media_update(state, runtime, true);
}
Effect::StopPlayback => {
runtime.player_start_pending = false;
runtime.player_paused_since = None;
runtime.player.stop();
push_media_update(state, runtime, true);
}
@@ -480,27 +497,54 @@ fn perform_effect(state: &mut AppState, runtime: &mut Runtime, effect: Effect) {
}
});
}
Effect::ToggleLike { track_id } => {
Effect::ToggleLikes { track_ids } => {
if track_ids.is_empty() {
return;
}
let Some(api) = runtime.api.clone() else {
return;
};
let tx = runtime.event_tx.clone();
tokio::spawn(async move {
match api.toggle_like(track_id).await {
Ok(liked) => {
let _ = tx.send(AppEvent::LikeToggled { track_id, liked });
}
Err(err) => {
tracing::warn!(%err, track_id, "like toggle failed");
let _ = tx.send(AppEvent::StatusMessage(format!("like failed: {err}")));
for track_id in track_ids {
match api.toggle_like(track_id).await {
Ok(liked) => {
let _ = tx.send(AppEvent::LikeToggled { track_id, liked });
}
Err(err) => {
tracing::warn!(%err, track_id, "like toggle failed");
let _ = tx.send(AppEvent::StatusMessage(format!("like failed: {err}")));
break;
}
}
}
});
}
Effect::RemoveQueueIndices {
restart_paused,
stop,
..
} => {
if stop {
runtime.player_start_pending = false;
runtime.player_paused_since = None;
runtime.player.stop();
push_state_now(state, runtime);
push_media_update(state, runtime, true);
} else if let Some(paused) = restart_paused {
start_current_audio(state, runtime, 0.0, paused);
push_state_now(state, runtime);
push_media_metadata(state, runtime);
push_media_update(state, runtime, true);
} else {
push_state_now(state, runtime);
push_media_update(state, runtime, true);
}
}
}
}
fn perform_remote_effect(state: &mut AppState, runtime: &Runtime, effect: Effect) -> bool {
fn perform_remote_effect(state: &mut AppState, runtime: &Runtime, effect: &Effect) -> bool {
let Some(target) = state.devices.remote_target_id().map(str::to_string) else {
return false;
};
@@ -528,7 +572,7 @@ fn perform_remote_effect(state: &mut AppState, runtime: &Runtime, effect: Effect
true
}
Effect::SeekBy(delta) => {
let target_time = (state.player.position_secs + delta as f64).max(0.0);
let target_time = (state.player.position_secs + *delta as f64).max(0.0);
state.player.position_secs = target_time;
send_device_command(
runtime,
@@ -543,7 +587,7 @@ fn perform_remote_effect(state: &mut AppState, runtime: &Runtime, effect: Effect
runtime,
target,
"set_volume",
serde_json::json!({ "volume": f64::from(volume) / 100.0 }),
serde_json::json!({ "volume": f64::from(*volume) / 100.0 }),
);
true
}
@@ -559,7 +603,20 @@ fn perform_remote_effect(state: &mut AppState, runtime: &Runtime, effect: Effect
);
true
}
Effect::EnqueueRelease { .. } | Effect::ToggleLike { .. } => false,
Effect::RemoveQueueIndices { indices, .. } => {
let mut indices = indices.clone();
indices.sort_unstable_by(|a, b| b.cmp(a));
for index in indices {
send_device_command(
runtime,
target.clone(),
"queue_remove",
serde_json::json!({ "index": index }),
);
}
true
}
Effect::EnqueueRelease { .. } | Effect::ToggleLikes { .. } => false,
}
}
@@ -588,11 +645,16 @@ fn send_device_command(
/// Start streaming `queue[queue_pos]`: open the authenticated HTTP stream in
/// a background task and hand the reader to the audio thread.
fn play_current(state: &mut AppState, runtime: &Runtime) {
fn play_current(state: &mut AppState, runtime: &mut Runtime) {
start_current_audio(state, runtime, 0.0, false);
}
fn start_current_audio(state: &mut AppState, runtime: &Runtime, position_secs: f64, paused: bool) {
fn start_current_audio(
state: &mut AppState,
runtime: &mut Runtime,
position_secs: f64,
paused: bool,
) {
let Some(track) = state.player.queue.get(state.player.queue_pos).cloned() else {
return;
};
@@ -600,7 +662,9 @@ fn start_current_audio(state: &mut AppState, runtime: &Runtime, position_secs: f
return;
};
// The track that was playing until now was cut short by this switch.
if let Some(previous) = state.player.current.take() {
let previous_started_at = state.player.track_started_at;
let same_track_started_at = if let Some(previous) = state.player.current.take() {
let same_track = previous.id == track.id;
if state.player.playing && previous.id != track.id {
report_history(
runtime,
@@ -610,18 +674,28 @@ fn start_current_audio(state: &mut AppState, runtime: &Runtime, position_secs: f
false,
);
}
}
same_track.then_some(previous_started_at).flatten()
} else {
None
};
state.player.current = Some(track.clone());
state.player.playing = true;
state.player.paused = paused;
state.player.position_secs = position_secs.max(0.0);
state.player.track_started_at = Some(auth::now_epoch_seconds());
state.player.track_started_at =
same_track_started_at.or_else(|| Some(auth::now_epoch_seconds()));
state.player.prefetched_pos = None;
state.status_message = Some(format!("{}{}", track.title, track.artist_line()));
if !paused {
report_now_playing(runtime, track.id);
}
runtime.player_start_pending = true;
if paused {
runtime.player_paused_since = Some(Instant::now());
} else {
runtime.player_paused_since = None;
}
let controller = runtime.player.clone();
let volume = player::amplitude(state.player.volume);
let tx = runtime.event_tx.clone();
@@ -645,6 +719,7 @@ fn start_current_audio(state: &mut AppState, runtime: &Runtime, position_secs: f
let _ = tx.send(AppEvent::SessionExpired);
}
Err(err) => {
let message = format!("playback failed: {err}");
tracing::warn!(
track_id = track.id,
title = %track.title,
@@ -652,12 +727,38 @@ fn start_current_audio(state: &mut AppState, runtime: &Runtime, position_secs: f
%err,
"playback stream open failed"
);
let _ = tx.send(AppEvent::StatusMessage(format!("playback failed: {err}")));
let _ = tx.send(AppEvent::Player(player::PlayerEvent::Failed(message)));
}
}
});
}
fn pause_current_audio(state: &mut AppState, runtime: &mut Runtime) {
state.player.paused = true;
runtime.player.pause();
runtime.player_paused_since.get_or_insert_with(Instant::now);
}
fn resume_current_audio(state: &mut AppState, runtime: &mut Runtime) {
state.player.paused = false;
let paused_for = runtime
.player_paused_since
.take()
.map(|elapsed| elapsed.elapsed());
if paused_for.is_some_and(|elapsed| elapsed >= STALE_STREAM_PAUSE_REOPEN_AFTER) {
let position_secs = state.player.position_secs;
tracing::info!(
paused_for_seconds = paused_for.map_or(0.0, |elapsed| elapsed.as_secs_f64()),
position_secs,
"reopening playback stream after a long pause"
);
runtime.player.stop();
start_current_audio(state, runtime, position_secs, false);
} else {
runtime.player.resume();
}
}
/// Start streaming the next queue item ~30s before the current track ends
/// and append it in the audio thread, so rodio switches sources without a
/// device gap.
@@ -945,6 +1046,8 @@ fn apply_devices_response(
let is_playback_device = state.devices.is_playback_device();
if was_playback_device && !is_playback_device {
runtime.player_start_pending = false;
runtime.player_paused_since = None;
runtime.player.stop();
}
@@ -952,6 +1055,8 @@ fn apply_devices_response(
if let Some(playback_state) = &response.playback_state {
apply_device_playback_state(state, runtime, playback_state, false);
} else {
runtime.player_start_pending = false;
runtime.player_paused_since = None;
runtime.player.stop();
}
} else if from_activation {
@@ -1025,6 +1130,8 @@ fn apply_device_playback_state(
push_media_metadata(state, runtime);
push_media_update(state, runtime, true);
} else {
runtime.player_start_pending = false;
runtime.player_paused_since = None;
runtime.player.stop();
}
}
@@ -1094,13 +1201,11 @@ fn execute_device_command(
apply_device_playback_state(state, runtime, &playback_state, start_audio);
}
"pause" => {
state.player.paused = true;
runtime.player.pause();
pause_current_audio(state, runtime);
push_media_update(state, runtime, true);
}
"resume" | "play" => {
state.player.paused = false;
runtime.player.resume();
resume_current_audio(state, runtime);
push_media_update(state, runtime, true);
}
"seek" => {
@@ -1181,15 +1286,28 @@ fn apply_options_payload(state: &mut AppState, payload: &serde_json::Value) {
}
}
fn remove_queue_index(state: &mut AppState, runtime: &Runtime, index: usize) {
fn remove_queue_index(state: &mut AppState, runtime: &mut Runtime, index: usize) {
if index >= state.player.queue.len() {
return;
}
let current_id = state.player.current.as_ref().map(|track| track.id);
let removed_current = state
.player
.queue
.get(index)
.is_some_and(|track| Some(track.id) == current_id);
let was_loaded = state.player.playing;
let was_paused = state.player.paused;
state.player.queue.remove(index);
state.player.prefetched_pos = None;
state.track_selection.clear();
if state.player.queue.is_empty() {
state.player = state::PlayerBar::default();
runtime.player_start_pending = false;
runtime.player_paused_since = None;
runtime.player.stop();
push_state_now(state, runtime);
push_media_update(state, runtime, true);
return;
}
state.player.queue_pos = current_id
@@ -1197,6 +1315,12 @@ fn remove_queue_index(state: &mut AppState, runtime: &Runtime, index: usize) {
.unwrap_or_else(|| state.player.queue_pos.min(state.player.queue.len() - 1));
state.player.current = state.player.queue.get(state.player.queue_pos).cloned();
state.queue_tab.cursor = state.queue_tab.cursor.min(state.player.queue.len() - 1);
if removed_current && was_loaded {
start_current_audio(state, runtime, 0.0, was_paused);
push_media_metadata(state, runtime);
push_media_update(state, runtime, true);
}
push_state_now(state, runtime);
}
fn move_queue_index(state: &mut AppState, from: usize, to: usize) {
@@ -1248,6 +1372,8 @@ fn handle_app_event(state: &mut AppState, runtime: &mut Runtime, event: AppEvent
}
}
AppEvent::SessionExpired => {
runtime.player_start_pending = false;
runtime.player_paused_since = None;
runtime.device_poll_in_flight = false;
state.user = None;
state.login = state::LoginForm::default();
@@ -1331,6 +1457,9 @@ fn handle_app_event(state: &mut AppState, runtime: &mut Runtime, event: AppEvent
};
state.art.insert(key, entry);
}
AppEvent::Player(player::PlayerEvent::Started) => {
runtime.player_start_pending = false;
}
AppEvent::Player(player::PlayerEvent::TrackFinished { has_next }) => {
// The finished track gets a full-duration, completed entry.
if let Some(finished) = state.player.current.clone() {
@@ -1368,6 +1497,8 @@ fn handle_app_event(state: &mut AppState, runtime: &mut Runtime, event: AppEvent
push_state_now(state, runtime);
}
AppEvent::Player(player::PlayerEvent::Failed(message)) => {
runtime.player_start_pending = false;
runtime.player_paused_since = None;
tracing::error!(%message, "playback failed");
state.player.playing = false;
state.player.paused = false;
@@ -1518,12 +1649,20 @@ fn handle_app_event(state: &mut AppState, runtime: &mut Runtime, event: AppEvent
use crate::media::MediaCommand;
tracing::debug!(?command, "media key");
let action = match command {
MediaCommand::TogglePause | MediaCommand::Play | MediaCommand::Pause => {
MediaCommand::TogglePause => action::Action::PlayPause,
MediaCommand::Play if state.player.paused || state.player.current.is_none() => {
action::Action::PlayPause
}
MediaCommand::Play => return,
MediaCommand::Pause if state.player.current.is_some() && !state.player.paused => {
action::Action::PlayPause
}
MediaCommand::Pause => return,
MediaCommand::Next => action::Action::NextTrack,
MediaCommand::Previous => action::Action::PrevTrack,
MediaCommand::Stop => {
runtime.player_start_pending = false;
runtime.player_paused_since = None;
state.player.playing = false;
state.player.paused = false;
state.player.current = None;
+57
View File
@@ -23,6 +23,11 @@ pub fn handle_key(state: &mut AppState, runtime: &Runtime, key: KeyEvent) {
busy,
} => handle_name_entry(state, runtime, for_track, input, busy, key),
Popup::Devices { cursor } => handle_devices(state, runtime, cursor, key),
Popup::TrackInfo {
tracks,
cursor,
scroll,
} => handle_track_info(state, tracks, cursor, scroll, key),
Popup::LogDetail(entry) => match key.code {
KeyCode::Esc | KeyCode::Enter | KeyCode::Char('q') => {}
_ => state.popup = Some(Popup::LogDetail(entry)),
@@ -75,6 +80,58 @@ fn handle_devices(state: &mut AppState, runtime: &Runtime, cursor: usize, key: K
}
}
fn handle_track_info(
state: &mut AppState,
tracks: Vec<TrackItem>,
cursor: usize,
scroll: usize,
key: KeyEvent,
) {
let len = tracks.len();
match key.code {
KeyCode::Esc | KeyCode::Enter | KeyCode::Char('q') => {}
KeyCode::Up | KeyCode::Char('k') => {
state.popup = Some(Popup::TrackInfo {
tracks,
cursor,
scroll: scroll.saturating_sub(1),
});
}
KeyCode::Down | KeyCode::Char('j') => {
state.popup = Some(Popup::TrackInfo {
tracks,
cursor,
scroll: scroll + 1,
});
}
KeyCode::Left | KeyCode::Char('h') => {
state.popup = Some(Popup::TrackInfo {
tracks,
cursor: cursor.saturating_sub(1),
scroll: 0,
});
}
KeyCode::Right | KeyCode::Char('l') => {
state.popup = Some(Popup::TrackInfo {
tracks,
cursor: if len == 0 {
0
} else {
(cursor + 1).min(len - 1)
},
scroll: 0,
});
}
_ => {
state.popup = Some(Popup::TrackInfo {
tracks,
cursor: cursor.min(len.saturating_sub(1)),
scroll,
});
}
}
}
fn handle_picker(
state: &mut AppState,
runtime: &Runtime,
+72
View File
@@ -186,6 +186,71 @@ pub struct QueueTab {
pub cursor: usize,
}
#[derive(Debug, Clone, PartialEq, Eq)]
pub enum TrackSelectionScope {
ArtistTop(i64),
ArtistFeatured(i64),
Release(i64),
Playlist(i64),
Queue,
}
/// Vim-like Shift-V selection for line-oriented track lists. The selected
/// range is always contiguous: anchor is where visual mode started, cursor is
/// extended by normal navigation.
#[derive(Debug, Clone, Default)]
pub struct TrackSelection {
pub scope: Option<TrackSelectionScope>,
pub anchor: usize,
pub cursor: usize,
}
impl TrackSelection {
pub fn is_active(&self) -> bool {
self.scope.is_some()
}
pub fn is_active_for(&self, scope: &TrackSelectionScope) -> bool {
self.scope.as_ref() == Some(scope)
}
pub fn start(&mut self, scope: TrackSelectionScope, cursor: usize) {
self.scope = Some(scope);
self.anchor = cursor;
self.cursor = cursor;
}
pub fn clear(&mut self) {
self.scope = None;
self.anchor = 0;
self.cursor = 0;
}
pub fn set_cursor(&mut self, scope: TrackSelectionScope, cursor: usize) {
if self.scope.as_ref() == Some(&scope) {
self.cursor = cursor;
}
}
pub fn contains(&self, scope: &TrackSelectionScope, index: usize) -> bool {
if self.scope.as_ref() != Some(scope) {
return false;
}
let start = self.anchor.min(self.cursor);
let end = self.anchor.max(self.cursor);
(start..=end).contains(&index)
}
pub fn indices(&self, scope: &TrackSelectionScope, len: usize) -> Option<Vec<usize>> {
if len == 0 || self.scope.as_ref() != Some(scope) {
return None;
}
let start = self.anchor.min(self.cursor).min(len - 1);
let end = self.anchor.max(self.cursor).min(len - 1);
Some((start..=end).collect())
}
}
/// Severity steps for the Logs tab filter, cycled with the view-toggle key.
pub const LOG_LEVELS: [tracing::Level; 5] = [
tracing::Level::ERROR,
@@ -263,6 +328,12 @@ pub enum Popup {
},
/// Connected devices list; Enter transfers active playback to the row.
Devices { cursor: usize },
/// Track metadata viewer; left/right switch between selected tracks.
TrackInfo {
tracks: Vec<TrackItem>,
cursor: usize,
scroll: usize,
},
/// Full, wrapped view of one log entry (Enter on the Logs tab).
LogDetail(crate::config::logging::LogEntry),
}
@@ -519,6 +590,7 @@ pub struct AppState {
pub logs: LogsTab,
pub devices: DevicesState,
pub queue_tab: QueueTab,
pub track_selection: TrackSelection,
/// Shift-J jump in flight: focus this (release, track) once the release
/// view finishes loading.
pub pending_release_focus: Option<(i64, i64)>,
+573 -20
View File
@@ -5,7 +5,7 @@ use crate::api::models::TrackItem;
use super::state::{
AppState, GlobalView, Loadable, OpenedPlaylist, SearchState, TILE_HEIGHT, TILE_WIDTH, Tab,
ViewMode, release_display_order, release_rows,
TrackSelectionScope, ViewMode, release_display_order, release_rows,
};
pub const QUIT_CONFIRM_WINDOW: Duration = Duration::from_millis(1500);
@@ -13,7 +13,7 @@ pub const QUIT_CONFIRM_HINT: &str = "press quit again to exit";
/// Side effects requested by `update()`; executed by the app loop, which
/// owns the Runtime (audio controller, API client). Keeps update() pure.
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
#[derive(Debug, Clone, PartialEq, Eq)]
pub enum Effect {
/// (Re)start playback of `queue[queue_pos]`.
PlayCurrent,
@@ -28,8 +28,13 @@ pub enum Effect {
id: i64,
next: bool,
},
ToggleLike {
track_id: i64,
ToggleLikes {
track_ids: Vec<i64>,
},
RemoveQueueIndices {
indices: Vec<usize>,
restart_paused: Option<bool>,
stop: bool,
},
}
@@ -203,23 +208,62 @@ pub fn update(state: &mut AppState, action: Action) -> Option<Effect> {
None
}
Action::Select => select_current(state),
Action::Back if state.track_selection.is_active() => {
state.track_selection.clear();
state.status_message = Some("selection cleared".into());
None
}
Action::Back => {
go_back(state);
None
}
Action::ToggleLike => {
let target =
selected_track(state)
.map(|t| t.id)
.or(state.player.current.as_ref().map(|t| t.id));
match target {
Some(track_id) => Some(Effect::ToggleLike { track_id }),
None => {
state.status_message = Some("no track selected".into());
None
}
let tracks = selected_tracks(state);
let track_ids: Vec<i64> = if tracks.is_empty() {
state
.player
.current
.as_ref()
.map(|track| vec![track.id])
.unwrap_or_default()
} else {
tracks.into_iter().map(|track| track.id).collect()
};
if track_ids.is_empty() {
state.status_message = Some("no track selected".into());
None
} else {
let should_like = track_ids.iter().any(|id| !state.likes.contains(id));
let toggles: Vec<i64> = track_ids
.into_iter()
.filter(|id| state.likes.contains(id) != should_like)
.collect();
state.status_message = Some(if should_like {
format!("liking {} track(s)", toggles.len())
} else {
format!("removing like from {} track(s)", toggles.len())
});
Some(Effect::ToggleLikes { track_ids: toggles })
}
}
Action::ToggleTrackSelection => {
toggle_track_selection(state);
None
}
Action::OpenTrackInfo => {
let tracks = selected_tracks(state);
if tracks.is_empty() {
state.status_message = Some("no track selected".into());
} else {
state.popup = Some(super::state::Popup::TrackInfo {
tracks,
cursor: 0,
scroll: 0,
});
}
None
}
Action::RemoveFromQueue => remove_selected_from_queue(state),
Action::QueueAddNext => queue_add(state, true),
Action::QueueAddLast => queue_add(state, false),
Action::GoToRelease => {
@@ -258,6 +302,7 @@ pub fn update(state: &mut AppState, action: Action) -> Option<Effect> {
state.player.prefetched_pos = None;
state.player.original_order = None;
state.queue_tab.cursor = 0;
state.track_selection.clear();
if had_tracks {
state.status_message = Some("queue cleared".into());
Some(Effect::StopPlayback)
@@ -271,6 +316,309 @@ pub fn update(state: &mut AppState, action: Action) -> Option<Effect> {
}
}
fn toggle_track_selection(state: &mut AppState) {
let Some((scope, cursor, len)) = current_track_list_context(state) else {
state.status_message = Some("track selection is unavailable here".into());
return;
};
if len == 0 {
state.status_message = Some("no tracks here".into());
return;
}
if state.track_selection.is_active_for(&scope) {
state.track_selection.clear();
state.status_message = Some("selection cleared".into());
} else {
state.track_selection.start(scope, cursor);
visual_selection_status(state);
}
}
fn visual_selection_status(state: &mut AppState) {
let Some((scope, _, len)) = current_track_list_context(state) else {
return;
};
if let Some(indices) = state.track_selection.indices(&scope, len) {
state.status_message = Some(format!("-- VISUAL LINE -- {} track(s)", indices.len()));
}
}
fn refresh_track_selection_cursor(state: &mut AppState) {
let Some((scope, cursor, _)) = current_track_list_context(state) else {
state.track_selection.clear();
return;
};
state.track_selection.set_cursor(scope, cursor);
if state.track_selection.is_active() {
visual_selection_status(state);
}
}
fn set_track_scope_cursor(state: &mut AppState, scope: &TrackSelectionScope, value: usize) {
match scope {
TrackSelectionScope::ArtistTop(id) => {
if matches!(
state.global.stack.last(),
Some(GlobalView::Artist { id: current, .. }) if current == id
) {
set_view_cursor(state, value);
}
}
TrackSelectionScope::ArtistFeatured(id) => {
let Some(GlobalView::Artist { id: current, .. }) = state.global.stack.last() else {
return;
};
if current != id {
return;
}
let Some(Loadable::Ready(detail)) = state.artist_views.get(id) else {
return;
};
let flat = detail.top_tracks.len() + detail.releases.len() + value;
set_view_cursor(state, flat);
}
TrackSelectionScope::Release(id) => {
if matches!(
state.global.stack.last(),
Some(GlobalView::Release { id: current, .. }) if current == id
) {
set_view_cursor(state, value);
}
}
TrackSelectionScope::Playlist(id) => {
if let Some(opened) = &mut state.playlists.opened {
if opened.id == *id {
opened.cursor = value;
}
}
}
TrackSelectionScope::Queue => {
state.queue_tab.cursor = value;
}
}
}
fn current_track_list_context(state: &AppState) -> Option<(TrackSelectionScope, usize, usize)> {
match state.active_tab {
Tab::Global => match state.global.stack.last()? {
GlobalView::Artist { id, cursor } => match state.artist_views.get(id)? {
Loadable::Ready(detail) => {
let tracks = detail.top_tracks.len();
let releases = detail.releases.len();
if *cursor < tracks {
Some((TrackSelectionScope::ArtistTop(*id), *cursor, tracks))
} else {
let featured = cursor.checked_sub(tracks + releases)?;
(featured < detail.featured_tracks.len()).then_some((
TrackSelectionScope::ArtistFeatured(*id),
featured,
detail.featured_tracks.len(),
))
}
}
_ => None,
},
GlobalView::Release { id, cursor } => match state.release_views.get(id)? {
Loadable::Ready(detail) => Some((
TrackSelectionScope::Release(*id),
*cursor,
detail.tracks.len(),
)),
_ => None,
},
_ => None,
},
Tab::Playlists => {
let opened = state.playlists.opened.as_ref()?;
let len = playlist_tracks(state, opened.id)?.len();
Some((TrackSelectionScope::Playlist(opened.id), opened.cursor, len))
}
Tab::Queue => Some((
TrackSelectionScope::Queue,
state.queue_tab.cursor,
state.player.queue.len(),
)),
Tab::Logs => None,
}
}
fn current_track_list(state: &AppState) -> Option<(TrackSelectionScope, usize, &[TrackItem])> {
match state.active_tab {
Tab::Global => match state.global.stack.last()? {
GlobalView::Artist { id, cursor } => match state.artist_views.get(id)? {
Loadable::Ready(detail) => {
let tracks = detail.top_tracks.len();
let releases = detail.releases.len();
if *cursor < tracks {
Some((
TrackSelectionScope::ArtistTop(*id),
*cursor,
&detail.top_tracks,
))
} else {
let featured = cursor.checked_sub(tracks + releases)?;
(featured < detail.featured_tracks.len()).then_some((
TrackSelectionScope::ArtistFeatured(*id),
featured,
&detail.featured_tracks,
))
}
}
_ => None,
},
GlobalView::Release { id, cursor } => match state.release_views.get(id)? {
Loadable::Ready(detail) => {
Some((TrackSelectionScope::Release(*id), *cursor, &detail.tracks))
}
_ => None,
},
_ => None,
},
Tab::Playlists => {
let opened = state.playlists.opened.as_ref()?;
Some((
TrackSelectionScope::Playlist(opened.id),
opened.cursor,
playlist_tracks(state, opened.id)?,
))
}
Tab::Queue => Some((
TrackSelectionScope::Queue,
state.queue_tab.cursor,
&state.player.queue,
)),
Tab::Logs => None,
}
}
pub fn selected_tracks(state: &AppState) -> Vec<TrackItem> {
let Some((scope, cursor, tracks)) = current_track_list(state) else {
return selected_track(state).into_iter().collect();
};
let indices = state
.track_selection
.indices(&scope, tracks.len())
.unwrap_or_else(|| vec![cursor.min(tracks.len().saturating_sub(1))]);
indices
.into_iter()
.filter_map(|index| tracks.get(index).cloned())
.collect()
}
fn selected_queue_indices(state: &AppState) -> Vec<usize> {
if state.active_tab != Tab::Queue || state.player.queue.is_empty() {
return Vec::new();
}
state
.track_selection
.indices(&TrackSelectionScope::Queue, state.player.queue.len())
.unwrap_or_else(|| vec![state.queue_tab.cursor.min(state.player.queue.len() - 1)])
}
fn remove_selected_from_queue(state: &mut AppState) -> Option<Effect> {
let indices = selected_queue_indices(state);
if indices.is_empty() {
state.status_message = Some("queue is empty".into());
return None;
}
let outcome = remove_queue_indices(state, &indices);
state.status_message = Some(format!("removed {} track(s) from queue", indices.len()));
Some(Effect::RemoveQueueIndices {
indices,
restart_paused: outcome.restart_paused,
stop: outcome.stop,
})
}
struct QueueRemovalOutcome {
restart_paused: Option<bool>,
stop: bool,
}
fn remove_queue_indices(state: &mut AppState, indices: &[usize]) -> QueueRemovalOutcome {
let len = state.player.queue.len();
let mut unique: Vec<usize> = indices
.iter()
.copied()
.filter(|index| *index < len)
.collect();
unique.sort_unstable();
unique.dedup();
if unique.is_empty() {
return QueueRemovalOutcome {
restart_paused: None,
stop: false,
};
}
let old_queue_pos = state.player.queue_pos;
let current_id = state.player.current.as_ref().map(|track| track.id);
let current_removed = current_id.is_some_and(|id| {
unique.iter().any(|index| {
state
.player
.queue
.get(*index)
.is_some_and(|track| track.id == id)
})
});
let removed_before_current = unique
.iter()
.filter(|index| **index < old_queue_pos)
.count();
let was_loaded = state.player.playing;
let was_paused = state.player.paused;
for index in unique.iter().rev() {
state.player.queue.remove(*index);
}
state.player.prefetched_pos = None;
state.track_selection.clear();
if state.player.queue.is_empty() {
state.player = super::state::PlayerBar::default();
state.queue_tab.cursor = 0;
return QueueRemovalOutcome {
restart_paused: None,
stop: true,
};
}
if current_removed {
let desired = old_queue_pos.saturating_sub(removed_before_current);
state.player.queue_pos = desired.min(state.player.queue.len() - 1);
state.player.current = state.player.queue.get(state.player.queue_pos).cloned();
state.player.position_secs = 0.0;
state.player.track_started_at = None;
state.queue_tab.cursor = state.queue_tab.cursor.min(state.player.queue.len() - 1);
return QueueRemovalOutcome {
restart_paused: was_loaded.then_some(was_paused),
stop: false,
};
}
if let Some(id) = current_id {
if let Some(position) = state.player.queue.iter().position(|track| track.id == id) {
state.player.queue_pos = position;
}
} else {
state.player.queue_pos = state.player.queue_pos.min(state.player.queue.len() - 1);
}
state.player.current = current_id.and_then(|id| {
state
.player
.queue
.iter()
.find(|track| track.id == id)
.cloned()
});
state.queue_tab.cursor = state.queue_tab.cursor.min(state.player.queue.len() - 1);
QueueRemovalOutcome {
restart_paused: None,
stop: false,
}
}
/// The track under the cursor in whatever view is showing tracks.
pub fn selected_track(state: &AppState) -> Option<TrackItem> {
match state.active_tab {
@@ -343,13 +691,19 @@ fn selected_release_id(state: &AppState) -> Option<i64> {
/// a / shift-a: queue the selection — a single track directly, a release via
/// an async fetch effect.
fn queue_add(state: &mut AppState, next: bool) -> Option<Effect> {
if let Some(track) = selected_track(state) {
let title = track.title.clone();
enqueue_tracks(state, vec![track], next);
state.status_message = Some(if next {
let tracks = selected_tracks(state);
if !tracks.is_empty() {
let count = tracks.len();
let title = tracks[0].title.clone();
enqueue_tracks(state, tracks, next);
state.status_message = Some(if count == 1 && next {
format!("queued next: {title}")
} else {
} else if count == 1 {
format!("queued: {title}")
} else if next {
format!("queued next: {count} tracks")
} else {
format!("queued: {count} tracks")
});
return None;
}
@@ -620,6 +974,18 @@ fn move_selection(state: &mut AppState, dx: isize, dy: isize) {
}
return;
}
if state.track_selection.is_active()
&& dx == 0
&& let Some((scope, cursor, len)) = current_track_list_context(state)
{
if len == 0 {
return;
}
let next = (cursor as isize + dy).clamp(0, len as isize - 1) as usize;
set_track_scope_cursor(state, &scope, next);
refresh_track_selection_cursor(state);
return;
}
if state.active_tab == Tab::Playlists {
let len = playlists_view_len(state);
if len == 0 {
@@ -629,10 +995,12 @@ fn move_selection(state: &mut AppState, dx: isize, dy: isize) {
match &mut state.playlists.opened {
Some(opened) => {
opened.cursor = (opened.cursor as isize + dy).clamp(0, last) as usize;
refresh_track_selection_cursor(state);
}
None => {
state.playlists.selected =
(state.playlists.selected as isize + dy).clamp(0, last) as usize;
state.track_selection.clear();
}
}
return;
@@ -644,6 +1012,7 @@ fn move_selection(state: &mut AppState, dx: isize, dy: isize) {
}
state.queue_tab.cursor =
(state.queue_tab.cursor as isize + dy).clamp(0, len as isize - 1) as usize;
refresh_track_selection_cursor(state);
return;
}
if state.active_tab != Tab::Global {
@@ -661,6 +1030,7 @@ fn move_selection(state: &mut AppState, dx: isize, dy: isize) {
};
let last = global.artists.len() as isize - 1;
global.selected = (global.selected as isize + step).clamp(0, last) as usize;
state.track_selection.clear();
}
Some(GlobalView::Artist { id, cursor }) => {
let Some(Loadable::Ready(detail)) = state.artist_views.get(&id) else {
@@ -714,6 +1084,7 @@ fn move_selection(state: &mut AppState, dx: isize, dy: isize) {
}
};
set_view_cursor(state, next);
state.track_selection.clear();
}
Some(GlobalView::Release { id, cursor }) => {
let Some(Loadable::Ready(detail)) = state.release_views.get(&id) else {
@@ -725,6 +1096,7 @@ fn move_selection(state: &mut AppState, dx: isize, dy: isize) {
}
let next = (cursor as isize + dy).clamp(0, total - 1);
set_view_cursor(state, next as usize);
refresh_track_selection_cursor(state);
}
Some(GlobalView::Search { cursor }) => {
let total = state.search.results.as_ref().map_or(0, |r| r.len()) as isize;
@@ -733,6 +1105,7 @@ fn move_selection(state: &mut AppState, dx: isize, dy: isize) {
}
let next = (cursor as isize + dy).clamp(0, total - 1);
set_view_cursor(state, next as usize);
state.track_selection.clear();
}
}
}
@@ -782,10 +1155,21 @@ fn current_view_len(state: &AppState) -> usize {
}
fn jump_selection(state: &mut AppState, first: bool) {
if state.track_selection.is_active()
&& let Some((scope, _, len)) = current_track_list_context(state)
{
if len > 0 {
let target = if first { 0 } else { len - 1 };
set_track_scope_cursor(state, &scope, target);
refresh_track_selection_cursor(state);
}
return;
}
if state.active_tab == Tab::Queue {
let len = state.player.queue.len();
if len > 0 {
state.queue_tab.cursor = if first { 0 } else { len - 1 };
refresh_track_selection_cursor(state);
}
return;
}
@@ -817,10 +1201,13 @@ fn jump_selection(state: &mut AppState, first: bool) {
Some(opened) => opened.cursor = target,
None => state.playlists.selected = target,
}
refresh_track_selection_cursor(state);
} else if state.global.stack.is_empty() {
state.global.selected = target;
state.track_selection.clear();
} else {
set_view_cursor(state, target);
refresh_track_selection_cursor(state);
}
}
@@ -1014,6 +1401,7 @@ fn shuffle_range(player: &mut super::state::PlayerBar, start: usize) {
/// Esc/Backspace: pop the navigation stack; leaving a search view resets the
/// search so the next `:/` starts clean.
fn go_back(state: &mut AppState) {
state.track_selection.clear();
match state.active_tab {
Tab::Playlists => {
state.playlists.opened = None;
@@ -1042,11 +1430,13 @@ fn go_back(state: &mut AppState) {
fn switch_tab(state: &mut AppState, tab: Tab) {
state.active_tab = tab;
state.help_visible = false;
state.track_selection.clear();
// Manually leaving a view cancels any pending Shift-J return path.
state.jump_origin = None;
}
fn reset_tab(state: &mut AppState, tab: Tab) {
state.track_selection.clear();
match tab {
Tab::Global => {
if state
@@ -1075,7 +1465,7 @@ fn not_yet(state: &mut AppState, what: &str) {
#[cfg(test)]
mod tests {
use super::*;
use crate::api::models::ArtistCard;
use crate::api::models::{ArtistCard, ArtistDetail, TrackItem};
fn with_artists(n: usize) -> AppState {
let mut state = AppState::default();
@@ -1091,6 +1481,33 @@ mod tests {
state
}
fn test_track(id: i64) -> TrackItem {
TrackItem {
id,
title: format!("t{id}"),
track_number: None,
disc_number: None,
duration_seconds: 1.0,
artists: vec![],
featured_artists: vec![],
release_id: 1,
release_title: "r".into(),
release_year: None,
cover_url: None,
stream_url: format!("/s/{id}"),
uploader_name: String::new(),
audio_format: None,
audio_bitrate: None,
audio_sample_rate: None,
audio_bit_depth: None,
file_size_bytes: None,
lastfm_listeners: None,
lastfm_playcount: None,
lastfm_rating: None,
lastfm_updated_at: None,
}
}
#[test]
fn quit_needs_double_press() {
let mut state = AppState::default();
@@ -1297,6 +1714,7 @@ mod tests {
id,
title: format!("t{id}"),
track_number: None,
disc_number: None,
duration_seconds: 1.0,
artists: vec![],
featured_artists: vec![],
@@ -1305,11 +1723,16 @@ mod tests {
release_year: None,
cover_url: None,
stream_url: format!("/api/player/stream/{id}"),
uploader_name: String::new(),
audio_format: None,
audio_bitrate: None,
audio_sample_rate: None,
audio_bit_depth: None,
file_size_bytes: None,
lastfm_listeners: None,
lastfm_playcount: None,
lastfm_rating: None,
lastfm_updated_at: None,
};
let mut state = AppState::default();
state.player.queue = vec![track(1), track(2)];
@@ -1358,6 +1781,7 @@ mod tests {
id,
title: format!("t{id}"),
track_number: None,
disc_number: None,
duration_seconds: 1.0,
artists: vec![],
featured_artists: vec![],
@@ -1366,11 +1790,16 @@ mod tests {
release_year: None,
cover_url: None,
stream_url: format!("/s/{id}"),
uploader_name: String::new(),
audio_format: None,
audio_bitrate: None,
audio_sample_rate: None,
audio_bit_depth: None,
file_size_bytes: None,
lastfm_listeners: None,
lastfm_playcount: None,
lastfm_rating: None,
lastfm_updated_at: None,
};
let mut state = AppState {
active_tab: Tab::Queue,
@@ -1399,6 +1828,118 @@ mod tests {
assert!(!state.player.playing);
}
#[test]
fn visual_selection_removes_queue_range() {
let mut state = AppState {
active_tab: Tab::Queue,
..AppState::default()
};
state.player.queue = (1..=4).map(test_track).collect();
state.queue_tab.cursor = 1;
assert_eq!(update(&mut state, Action::ToggleTrackSelection), None);
update(&mut state, Action::MoveDown);
let selected: Vec<i64> = selected_tracks(&state)
.into_iter()
.map(|track| track.id)
.collect();
assert_eq!(selected, vec![2, 3]);
assert_eq!(
update(&mut state, Action::RemoveFromQueue),
Some(Effect::RemoveQueueIndices {
indices: vec![1, 2],
restart_paused: None,
stop: false,
})
);
let remaining: Vec<i64> = state.player.queue.iter().map(|track| track.id).collect();
assert_eq!(remaining, vec![1, 4]);
assert!(!state.track_selection.is_active());
}
#[test]
fn artist_top_track_selection_queues_all_selected_tracks() {
let mut state = AppState::default();
state
.global
.stack
.push(GlobalView::Artist { id: 9, cursor: 0 });
state.artist_views.insert(
9,
Loadable::Ready(ArtistDetail {
id: 9,
name: "artist".into(),
image_url: None,
total_track_count: 3,
total_play_count: 0,
top_tracks: (1..=3).map(test_track).collect(),
releases: vec![],
featured_tracks: vec![],
}),
);
update(&mut state, Action::ToggleTrackSelection);
update(&mut state, Action::MoveDown);
assert_eq!(update(&mut state, Action::QueueAddLast), None,);
let queued: Vec<i64> = state.player.queue.iter().map(|track| track.id).collect();
assert_eq!(queued, vec![1, 2]);
}
#[test]
fn removing_current_queue_track_requests_paused_restart() {
let mut state = AppState {
active_tab: Tab::Queue,
..AppState::default()
};
state.player.queue = (1..=3).map(test_track).collect();
state.player.queue_pos = 1;
state.queue_tab.cursor = 1;
state.player.current = Some(test_track(2));
state.player.playing = true;
state.player.paused = true;
assert_eq!(
update(&mut state, Action::RemoveFromQueue),
Some(Effect::RemoveQueueIndices {
indices: vec![1],
restart_paused: Some(true),
stop: false,
})
);
let remaining: Vec<i64> = state.player.queue.iter().map(|track| track.id).collect();
assert_eq!(remaining, vec![1, 3]);
assert_eq!(state.player.queue_pos, 1);
assert_eq!(state.player.current.as_ref().map(|track| track.id), Some(3));
}
#[test]
fn bulk_like_targets_only_tracks_that_need_toggle() {
let mut state = AppState {
active_tab: Tab::Queue,
..AppState::default()
};
state.player.queue = (1..=3).map(test_track).collect();
state.likes.insert(1);
update(&mut state, Action::ToggleTrackSelection);
update(&mut state, Action::SelectLast);
assert_eq!(
update(&mut state, Action::ToggleLike),
Some(Effect::ToggleLikes {
track_ids: vec![2, 3],
})
);
state.likes = [1, 2, 3].into_iter().collect();
assert_eq!(
update(&mut state, Action::ToggleLike),
Some(Effect::ToggleLikes {
track_ids: vec![1, 2, 3],
})
);
}
#[test]
fn shuffle_reorders_tail_and_restores() {
use crate::api::models::TrackItem;
@@ -1406,6 +1947,7 @@ mod tests {
id,
title: format!("t{id}"),
track_number: None,
disc_number: None,
duration_seconds: 1.0,
artists: vec![],
featured_artists: vec![],
@@ -1414,11 +1956,16 @@ mod tests {
release_year: None,
cover_url: None,
stream_url: format!("/s/{id}"),
uploader_name: String::new(),
audio_format: None,
audio_bitrate: None,
audio_sample_rate: None,
audio_bit_depth: None,
file_size_bytes: None,
lastfm_listeners: None,
lastfm_playcount: None,
lastfm_rating: None,
lastfm_updated_at: None,
};
let mut state = AppState::default();
state.player.queue = (1..=8).map(track).collect();
@@ -1449,6 +1996,7 @@ mod tests {
id,
title: format!("t{id}"),
track_number: None,
disc_number: None,
duration_seconds: 1.0,
artists: vec![],
featured_artists: vec![],
@@ -1457,11 +2005,16 @@ mod tests {
release_year: None,
cover_url: None,
stream_url: format!("/s/{id}"),
uploader_name: String::new(),
audio_format: None,
audio_bitrate: None,
audio_sample_rate: None,
audio_bit_depth: None,
file_size_bytes: None,
lastfm_listeners: None,
lastfm_playcount: None,
lastfm_rating: None,
lastfm_updated_at: None,
};
let mut state = AppState {
active_tab: Tab::Queue,
+18
View File
@@ -60,6 +60,16 @@ key_sequence = "shift-c"
command = "ClearQueue"
context = "queue"
[[keymaps]]
key_sequence = "d"
command = "RemoveFromQueue"
context = "queue"
[[keymaps]]
key_sequence = "delete"
command = "RemoveFromQueue"
context = "queue"
[[keymaps]]
key_sequence = "shift-j"
command = "GoToRelease"
@@ -185,6 +195,14 @@ command = "CycleRepeat"
key_sequence = "x"
command = "ToggleLike"
[[keymaps]]
key_sequence = "shift-v"
command = "ToggleTrackSelection"
[[keymaps]]
key_sequence = "i"
command = "OpenTrackInfo"
[[keymaps]]
key_sequence = "shift-l"
command = "Logout"
+4 -15
View File
@@ -25,6 +25,8 @@ pub fn amplitude(percent: u8) -> f32 {
#[derive(Debug)]
pub enum PlayerEvent {
/// A newly requested source was decoded and handed to rodio.
Started,
/// A track played to its end. `has_next` is true when a prefetched
/// source was already queued and is now playing gaplessly.
TrackFinished {
@@ -45,7 +47,6 @@ enum Command {
reader: Box<TrackReader>,
byte_len: Option<u64>,
},
TogglePause,
Pause,
Resume,
Stop,
@@ -92,10 +93,6 @@ impl Controller {
});
}
pub fn toggle_pause(&self) {
let _ = self.tx.send(Command::TogglePause);
}
pub fn pause(&self) {
let _ = self.tx.send(Command::Pause);
}
@@ -217,6 +214,7 @@ fn handle(
out.player.append(decoder);
out.player.play();
*track_loaded = true;
on_event(PlayerEvent::Started);
}
Err(err) => {
on_event(PlayerEvent::Failed(format!("cannot decode track: {err}")));
@@ -243,15 +241,6 @@ fn handle(
}
}
}
Command::TogglePause => {
if let Some(out) = output {
if out.player.is_paused() {
out.player.play();
} else {
out.player.pause();
}
}
}
Command::Pause => {
if let Some(out) = output {
out.player.pause();
@@ -263,7 +252,7 @@ fn handle(
}
}
Command::Stop => {
if let Some(out) = output {
if let Some(out) = output.take() {
out.player.stop();
}
*track_loaded = false;
+29 -4
View File
@@ -490,11 +490,25 @@ fn draw_artist(frame: &mut Frame, area: Rect, state: &AppState, id: i64, cursor:
cursor_item,
&mut |frame, rect, item| match item {
PlanItem::Track { cursor_index } => {
let (track, number) = if *cursor_index < tracks {
(&detail.top_tracks[*cursor_index], cursor_index + 1)
let (track, number, visual_selected) = if *cursor_index < tracks {
(
&detail.top_tracks[*cursor_index],
cursor_index + 1,
state.track_selection.contains(
&crate::app::state::TrackSelectionScope::ArtistTop(id),
*cursor_index,
),
)
} else {
let offset = cursor_index - tracks - releases_len;
(&detail.featured_tracks[offset], offset + 1)
(
&detail.featured_tracks[offset],
offset + 1,
state.track_selection.contains(
&crate::app::state::TrackSelectionScope::ArtistFeatured(id),
offset,
),
)
};
super::track_row(
frame,
@@ -503,6 +517,7 @@ fn draw_artist(frame: &mut Frame, area: Rect, state: &AppState, id: i64, cursor:
track,
number.to_string(),
cursor == *cursor_index,
visual_selected,
);
}
PlanItem::TileRow(row) => {
@@ -678,7 +693,17 @@ fn draw_release(frame: &mut Frame, area: Rect, state: &AppState, id: i64, cursor
.track_number
.map(|n| n.to_string())
.unwrap_or_else(|| (offset + 1).to_string());
super::track_row(frame, rect, state, track, number, cursor == offset);
super::track_row(
frame,
rect,
state,
track,
number,
cursor == offset,
state
.track_selection
.contains(&crate::app::state::TrackSelectionScope::Release(id), offset),
);
}
}
+19 -4
View File
@@ -12,7 +12,7 @@ use ratatui::style::{Color, Style};
use ratatui::text::{Line, Span};
use ratatui::widgets::{Block, Clear, Paragraph, Tabs};
use crate::app::state::{AppState, Screen, Tab};
use crate::app::state::{AppState, Screen, Tab, TrackSelectionScope};
use crate::config::keymap::Keymap;
pub fn draw(frame: &mut Frame, state: &AppState, keymap: &Keymap) {
@@ -63,6 +63,7 @@ pub(crate) fn track_row(
track: &crate::api::models::TrackItem,
index_label: String,
selected: bool,
visual_selected: bool,
) {
let heart = if state.likes.contains(&track.id) {
Span::styled("", theme::accent())
@@ -82,6 +83,9 @@ pub(crate) fn track_row(
Paragraph::new(Line::styled(right, theme::dim())).alignment(Alignment::Right),
area,
);
if visual_selected {
frame.buffer_mut().set_style(area, theme::selection());
}
if selected {
frame.buffer_mut().set_style(area, theme::tab_active());
}
@@ -125,7 +129,7 @@ fn draw_queue(frame: &mut Frame, area: Rect, state: &AppState) {
let player = &state.player;
let block = Block::bordered()
.title(format!(
" Queue — {} tracks · enter: play · shift-c: clear ",
" Queue — {} tracks · enter: play · d: remove · shift-v: select · shift-c: clear ",
player.queue.len()
))
.title_style(theme::header())
@@ -168,10 +172,21 @@ fn draw_queue(frame: &mut Frame, area: Rect, state: &AppState) {
} else {
(index + 1).to_string()
};
track_row(frame, row, state, track, label, index == cursor);
let visual_selected = state
.track_selection
.contains(&TrackSelectionScope::Queue, index);
track_row(
frame,
row,
state,
track,
label,
index == cursor,
visual_selected,
);
// Tracks before the playing one are history: greyed out unless the
// cursor is on them.
if index < player.queue_pos && index != cursor {
if index < player.queue_pos && index != cursor && !visual_selected {
frame.buffer_mut().set_style(row, played_style);
}
}
+4 -1
View File
@@ -5,7 +5,7 @@ use ratatui::text::{Line, Span};
use ratatui::widgets::{Block, Paragraph};
use super::{theme, track_row};
use crate::app::state::{AppState, Loadable};
use crate::app::state::{AppState, Loadable, TrackSelectionScope};
use crate::app::update::playlist_tracks;
pub fn draw(frame: &mut Frame, area: Rect, state: &AppState) {
@@ -158,6 +158,9 @@ fn draw_opened(frame: &mut Frame, area: Rect, state: &AppState, id: i64, cursor:
track,
(index + 1).to_string(),
index == cursor,
state
.track_selection
.contains(&TrackSelectionScope::Playlist(id), index),
);
}
}
+153 -1
View File
@@ -1,9 +1,10 @@
use ratatui::Frame;
use ratatui::layout::{Alignment, Constraint, Flex, Layout, Rect};
use ratatui::text::{Line, Span};
use ratatui::widgets::{Block, Clear, Paragraph};
use ratatui::widgets::{Block, Clear, Paragraph, Wrap};
use super::theme;
use crate::api::models::{ArtistRef, TrackItem};
use crate::app::state::{AppState, Loadable, Popup, addable_playlists};
pub fn draw(frame: &mut Frame, state: &AppState) {
@@ -13,6 +14,11 @@ pub fn draw(frame: &mut Frame, state: &AppState) {
}
Some(Popup::NewPlaylist { input, busy, .. }) => draw_name_entry(frame, input, *busy),
Some(Popup::Devices { cursor }) => draw_devices(frame, state, *cursor),
Some(Popup::TrackInfo {
tracks,
cursor,
scroll,
}) => draw_track_info(frame, tracks, *cursor, *scroll),
Some(Popup::LogDetail(entry)) => draw_log_detail(frame, entry),
None => {}
}
@@ -137,6 +143,152 @@ fn draw_log_detail(frame: &mut Frame, entry: &crate::config::logging::LogEntry)
);
}
fn draw_track_info(frame: &mut Frame, tracks: &[TrackItem], cursor: usize, scroll: usize) {
let Some(track) = tracks.get(cursor.min(tracks.len().saturating_sub(1))) else {
return;
};
let width = 92.min(frame.area().width.saturating_sub(4)).max(48);
let height = 24.min(frame.area().height.saturating_sub(2)).max(10);
let area = centered(frame.area(), width, height);
let title = if tracks.len() > 1 {
format!(" Track info — {}/{} ", cursor + 1, tracks.len())
} else {
" Track info ".to_string()
};
let block = Block::bordered()
.title(title)
.title_style(theme::header())
.border_style(theme::accent());
let inner = block.inner(area);
frame.render_widget(Clear, area);
frame.render_widget(block, area);
let [body, footer] = Layout::vertical([Constraint::Min(1), Constraint::Length(1)]).areas(inner);
let lines = track_info_lines(track);
let max_scroll = lines.len().saturating_sub(usize::from(body.height));
frame.render_widget(
Paragraph::new(lines)
.wrap(Wrap { trim: false })
.scroll((scroll.min(max_scroll) as u16, 0)),
body,
);
let hint = if tracks.len() > 1 {
"j/k scroll · h/left previous · l/right next · esc close"
} else {
"j/k scroll · esc close"
};
frame.render_widget(
Paragraph::new(Line::styled(hint, theme::dim())).alignment(Alignment::Center),
footer,
);
}
fn track_info_lines(track: &TrackItem) -> Vec<Line<'static>> {
vec![
field("ID", track.id.to_string()),
field("Title", track.title.clone()),
field("Artists", artist_refs(&track.artists)),
field("Featured artists", artist_refs(&track.featured_artists)),
field("Release", release_label(track)),
field("Release ID", track.release_id.to_string()),
field("Disc", opt_display(track.disc_number)),
field("Track number", opt_display(track.track_number)),
field(
"Duration",
format!(
"{} ({:.2}s)",
track.duration_label(),
track.duration_seconds
),
),
field("Uploader", empty_dash(&track.uploader_name)),
field("Audio format", opt_string(track.audio_format.clone())),
field(
"Bitrate",
opt_map(track.audio_bitrate, |v| format!("{v} kbps")),
),
field(
"Sample rate",
opt_map(track.audio_sample_rate, |v| {
format!("{:.1} kHz", f64::from(v) / 1000.0)
}),
),
field(
"Bit depth",
opt_map(track.audio_bit_depth, |v| format!("{v} bit")),
),
field("File size", file_size(track.file_size_bytes)),
field("Last.fm listeners", opt_display(track.lastfm_listeners)),
field("Last.fm plays", opt_display(track.lastfm_playcount)),
field(
"Last.fm rating",
opt_map(track.lastfm_rating, |v| format!("{v:.3}")),
),
field(
"Last.fm updated",
opt_string(track.lastfm_updated_at.clone()),
),
field("Stream URL", empty_dash(&track.stream_url)),
field("Cover URL", opt_string(track.cover_url.clone())),
]
}
fn field(label: &'static str, value: String) -> Line<'static> {
Line::from(vec![
Span::styled(format!("{label:<18}"), theme::dim()),
Span::raw(value),
])
}
fn artist_refs(items: &[ArtistRef]) -> String {
if items.is_empty() {
return "".to_string();
}
items
.iter()
.map(|artist| format!("{} ({})", artist.name, artist.id))
.collect::<Vec<_>>()
.join(", ")
}
fn release_label(track: &TrackItem) -> String {
let mut label = empty_dash(&track.release_title);
if let Some(year) = track.release_year {
label.push_str(&format!(" ({year})"));
}
label
}
fn empty_dash(value: &str) -> String {
if value.trim().is_empty() {
"".to_string()
} else {
value.to_string()
}
}
fn opt_string(value: Option<String>) -> String {
value
.filter(|value| !value.trim().is_empty())
.unwrap_or_else(|| "".to_string())
}
fn opt_display<T: std::fmt::Display>(value: Option<T>) -> String {
opt_map(value, |value| value.to_string())
}
fn opt_map<T>(value: Option<T>, format: impl FnOnce(T) -> String) -> String {
value.map(format).unwrap_or_else(|| "".to_string())
}
fn file_size(value: Option<i64>) -> String {
value
.map(|bytes| format!("{:.1} MB ({} bytes)", bytes as f64 / 1_048_576.0, bytes))
.unwrap_or_else(|| "".to_string())
}
fn draw_picker(frame: &mut Frame, state: &AppState, track_title: &str, cursor: usize) {
let options = addable_playlists(state);
let loading = !matches!(&state.playlists.list, Some(Loadable::Ready(_)));
+4
View File
@@ -18,6 +18,10 @@ pub fn tab_active() -> Style {
.add_modifier(Modifier::BOLD)
}
pub fn selection() -> Style {
Style::new().fg(Color::White).bg(Color::Rgb(24, 68, 72))
}
pub fn header() -> Style {
Style::new().fg(ACCENT).add_modifier(Modifier::BOLD)
}