From 9599ee669dbf44b41cbe1c1344be907cc15676f9 Mon Sep 17 00:00:00 2001 From: Erica Z Date: Sun, 10 Nov 2024 15:53:23 +0100 Subject: [PATCH] move sanity check here --- src/ui/window.rs | 111 +++++++++++++++++++++++------------------------ 1 file changed, 55 insertions(+), 56 deletions(-) diff --git a/src/ui/window.rs b/src/ui/window.rs index 8cf20ac..4301153 100644 --- a/src/ui/window.rs +++ b/src/ui/window.rs @@ -90,7 +90,6 @@ mod imp { mpv.observe_property(4, "idle-active").unwrap(); mpv.observe_property(6, "playlist-count").unwrap(); mpv.observe_property(7, "duration").unwrap(); - mpv.observe_property(8, "path").unwrap(); // "Useful to drain property changes before a new file is loaded." mpv.add_hook(0, "on_before_start_file", 0).unwrap(); @@ -185,11 +184,13 @@ mod imp { match event { Event::PropertyChange(event) => window.imp().on_property_change(event), - Event::StartFile(_) => window.imp().on_start_file(), Event::Hook(event) => window.imp().on_hook(event), Event::LogMessage(event) => window.imp().on_log_message(event), - Event::Seek => window.imp().on_seek(), + + Event::StartFile(_) => window.imp().on_start_file(), + Event::FileLoaded => window.imp().on_file_loaded(), Event::PlaybackRestart => window.imp().on_playback_restart(), + Event::Seek => window.imp().on_seek(), Event::EndFile(event) => window.imp().on_end_file(event), Event::Unknown(_) => { @@ -454,60 +455,10 @@ mod imp { self.obj().notify("duration"); } - 8 => { - assert_eq!(event.name, "path"); - // sanity check - match self.mpv.get_property::("path") { - Ok(path) => { - assert_eq!(path, self.obj().song().unwrap().stream_url()) - } - Err(err) if err.is_property_unavailable() => {} - Err(err) => panic!("{err:?}"), - } - } - _ => unreachable!(), } } - fn on_start_file(&self) { - event!(Level::INFO, "start file event"); - self.obj().notify("song"); - self.buffering_start(); - - let window = self.obj().clone(); - let song_id = window.song().unwrap().id(); - if let Some(handle) = self - .loading_cover_handle - .replace(Some(glib::spawn_future_local(async move { - let api = window.imp().api.borrow().as_ref().unwrap().clone(); - let bytes = api - .cover_art(&song_id, None) // full size - .await - .expect("could not load cover art for song {song_id}"); - - match window.song() { - Some(song) if song.id() == song_id => { - let texture = gdk::Texture::from_bytes(&glib::Bytes::from_owned(bytes)) - .expect("could not create texture from cover art for {song_id}"); - window.set_playing_cover_art(Some(texture)); - } - _ => { - event!( - Level::WARN, - "was too late to fetch cover for song {song_id}" - ) - } - } - }))) - { - handle.abort(); - } - - // make sure this is reported as 0 - self.obj().notify("time-pos"); - } - fn on_hook(&self, event: crate::mpv::event::HookEvent) { match event.reply_userdata { 0 => { @@ -552,13 +503,61 @@ mod imp { }; } + fn on_start_file(&self) { + event!(Level::INFO, "StartFile"); + self.obj().notify("song"); + self.buffering_start(); + + let window = self.obj().clone(); + let song_id = window.song().unwrap().id(); + if let Some(handle) = self + .loading_cover_handle + .replace(Some(glib::spawn_future_local(async move { + let api = window.imp().api.borrow().as_ref().unwrap().clone(); + let bytes = api + .cover_art(&song_id, None) // full size + .await + .expect("could not load cover art for song {song_id}"); + + match window.song() { + Some(song) if song.id() == song_id => { + let texture = gdk::Texture::from_bytes(&glib::Bytes::from_owned(bytes)) + .expect("could not create texture from cover art for {song_id}"); + window.set_playing_cover_art(Some(texture)); + } + _ => { + event!( + Level::WARN, + "was too late to fetch cover for song {song_id}" + ) + } + } + }))) + { + handle.abort(); + } + + // make sure this is reported as 0 + self.obj().notify("time-pos"); + } + + fn on_file_loaded(&self) { + event!(Level::INFO, "FileLoaded"); + // sanity check + // i think "path" is only available after this event is dispatched + assert_eq!( + self.mpv.get_property::("path").unwrap(), + self.obj().song().unwrap().stream_url() + ); + } + fn on_seek(&self) { - event!(Level::INFO, "seek event"); + event!(Level::INFO, "Seek"); self.buffering_start(); } fn on_playback_restart(&self) { - event!(Level::INFO, "playback restart event"); + event!(Level::INFO, "PlaybackRestart"); self.buffering_end(); self.obj().notify("time-pos"); @@ -570,7 +569,7 @@ mod imp { } fn on_end_file(&self, event: crate::mpv::event::EndFileEvent) { - event!(Level::INFO, "end file event: {event:?}"); + event!(Level::INFO, "EndFile: {event:?}"); self.obj().notify("song"); self.buffering_end();