From dfbac73136a1d805d20e32575d979382f168b515 Mon Sep 17 00:00:00 2001 From: Felix Prillwitz Date: Tue, 17 Dec 2024 21:01:35 +0100 Subject: [PATCH] connect: make `playing_track` optional and handle it correctly --- connect/src/model.rs | 23 ++++++++++++++--------- connect/src/spirc.rs | 24 ++++++++++++++++-------- 2 files changed, 30 insertions(+), 17 deletions(-) diff --git a/connect/src/model.rs b/connect/src/model.rs index 63d48efe..d73cadab 100644 --- a/connect/src/model.rs +++ b/connect/src/model.rs @@ -9,7 +9,11 @@ pub struct SpircLoadCommand { pub shuffle: bool, pub repeat: bool, pub repeat_track: bool, - pub playing_track: PlayingTrack, + /// Decides the starting position in the given context + /// + /// ## Remarks: + /// If none is provided and shuffle true, a random track is played, otherwise the first + pub playing_track: Option, } #[derive(Debug)] @@ -19,19 +23,20 @@ pub enum PlayingTrack { Uid(String), } -impl From for PlayingTrack { - fn from(value: SkipTo) -> Self { +impl TryFrom for PlayingTrack { + type Error = (); + + fn try_from(value: SkipTo) -> Result { // order of checks is important, as the index can be 0, but still has an uid or uri provided, // so we only use the index as last resort if let Some(uri) = value.track_uri { - PlayingTrack::Uri(uri) + Ok(PlayingTrack::Uri(uri)) } else if let Some(uid) = value.track_uid { - PlayingTrack::Uid(uid) + Ok(PlayingTrack::Uid(uid)) + } else if let Some(index) = value.track_index { + Ok(PlayingTrack::Index(index)) } else { - PlayingTrack::Index(value.track_index.unwrap_or_else(|| { - warn!("SkipTo didn't provided any point to skip to, falling back to index 0"); - 0 - })) + Err(()) } } } diff --git a/connect/src/spirc.rs b/connect/src/spirc.rs index 94681c62..5b175e61 100644 --- a/connect/src/spirc.rs +++ b/connect/src/spirc.rs @@ -918,7 +918,7 @@ impl SpircTask { context_uri: play.context.uri.clone(), start_playing: true, seek_to: play.options.seek_to.unwrap_or_default(), - playing_track: play.options.skip_to.into(), + playing_track: play.options.skip_to.try_into().ok(), shuffle, repeat, repeat_track, @@ -1141,16 +1141,21 @@ impl SpircTask { debug!("play track <{:?}>", cmd.playing_track); - let index = match cmd.playing_track { - PlayingTrack::Index(i) => i as usize, + let index = cmd.playing_track.map(|p| match p { + PlayingTrack::Index(i) => Ok(i as usize), PlayingTrack::Uri(uri) => { let ctx = self.connect_state.get_context(ContextType::Default)?; - ConnectState::find_index_in_context(ctx, |t| t.uri == uri)? + ConnectState::find_index_in_context(ctx, |t| t.uri == uri) } PlayingTrack::Uid(uid) => { let ctx = self.connect_state.get_context(ContextType::Default)?; - ConnectState::find_index_in_context(ctx, |t| t.uid == uid)? + ConnectState::find_index_in_context(ctx, |t| t.uid == uid) } + }); + + let index = match index { + Some(value) => Some(value?), + None => None, }; debug!( @@ -1163,7 +1168,9 @@ impl SpircTask { self.connect_state.set_repeat_track(cmd.repeat_track); if cmd.shuffle { - self.connect_state.set_current_track_random()?; + if index.is_none() { + self.connect_state.set_current_track_random()?; + } if self.context_resolver.has_next() { self.connect_state.update_queue_revision() @@ -1172,8 +1179,9 @@ impl SpircTask { self.add_autoplay_resolving_when_required(); } } else { - self.connect_state.set_current_track(index)?; - self.connect_state.reset_playback_to_position(Some(index))?; + self.connect_state + .set_current_track(index.unwrap_or_default())?; + self.connect_state.reset_playback_to_position(index)?; self.add_autoplay_resolving_when_required(); }