Use navigator for main window

crates/musicus_backend/Cargo.toml

@@ -5,6 +5,7 @@ edition = "2018"
 
 [dependencies]
 fragile = "1.0.0"
+futures = "0.3.6"
 futures-channel = "0.3.5"
 gio = "0.9.1"
 glib = "0.10.3"

crates/musicus_backend/src/lib.rs

@@ -1,3 +1,4 @@
+use futures::prelude::*;
 use futures_channel::mpsc;
 use gio::prelude::*;
 use log::warn;
@@ -40,7 +41,7 @@ pub enum BackendState {
 pub struct Backend {
     /// A future resolving to the next state of the backend. Initially, this should be assumed to
     /// be BackendState::Loading. Changes should be awaited before calling init().
-    pub state_stream: RefCell<mpsc::Receiver<BackendState>>,
+    state_stream: RefCell<mpsc::Receiver<BackendState>>,
 
     /// The internal sender to publish the state via state_stream.
     state_sender: RefCell<mpsc::Sender<BackendState>>,
@@ -80,8 +81,14 @@ impl Backend {
         }
     }
 
+    /// Wait for the next state change. Initially, the state should be assumed to be
+    /// BackendState::Loading. Changes should be awaited before calling init().
+    pub async fn next_state(&self) -> Option<BackendState> {
+        self.state_stream.borrow_mut().next().await
+    }
+
     /// Initialize the backend updating the state accordingly.
-    pub async fn init(self: Rc<Backend>) -> Result<()> {
+    pub async fn init(&self) -> Result<()> {
         self.init_library().await?;
 
         if let Some(url) = self.settings.get_string("server-url") {
@@ -97,6 +104,12 @@ impl Backend {
             _ => (),
         }
 
+        if self.get_music_library_path().is_none() {
+            self.set_state(BackendState::NoMusicLibrary);
+        } else {
+            self.set_state(BackendState::Ready);
+        }
+
         Ok(())
     }
 

crates/musicus_backend/src/player.rs

@@ -353,6 +353,24 @@ impl Player {
         Ok(())
     }
 
+    pub fn send_data(&self) {
+        for cb in &*self.playlist_cbs.borrow() {
+            cb(self.playlist.borrow().clone());
+        }
+
+        for cb in &*self.track_cbs.borrow() {
+            cb(self.current_item.get().unwrap(), self.current_track.get().unwrap());
+        }
+
+        for cb in &*self.duration_cbs.borrow() {
+            cb(self.player.get_duration().mseconds().unwrap());
+        }
+
+        for cb in &*self.playing_cbs.borrow() {
+            cb(self.is_playing());
+        }
+    }
+
     pub fn clear(&self) {
         self.player.stop();
         self.playing.set(false);