1 files changed, 157 insertions, 0 deletions
diff --git a/src/main.rs b/src/main.rs
new file mode 100644
index 0000000..9285b0b
--- /dev/null
+++ b/src/main.rs
@@ -0,0 +1,157 @@
+use futures::{channel::mpsc, StreamExt};
+use gtk::prelude::*;
+use gtk::{Application, Box, Image, ListBox, Notebook, Orientation};
+use libhandy::prelude::*;
+use libhandy::{ActionRow, ApplicationWindow, HeaderBar};
+use mpd::idle::Idle;
+use mpd::Client;
+
+struct TunesUI {
+    header_bar: HeaderBar,
+    // album_art: Image,
+    // queue_switcher: Notebook,
+}
+
+fn header_title(conn: &mut mpd::client::Client) -> mpd::error::Result<String> {
+    let status = conn.status();
+    let state_descriptor = match status?.state {
+        mpd::status::State::Stop => "[STOPPED]",
+        mpd::status::State::Pause => "[PAUSED]",
+        mpd::status::State::Play => "[PLAYING]",
+    };
+    if let Some(song) = conn.currentsong()? {
+        Ok(format!(
+            "{} {} - {}",
+            state_descriptor,
+            song.title.unwrap_or("Untitled".into()),
+            song.artist.unwrap_or("Untitled".into()),
+        ))
+    } else {
+        Ok("Tunes".into())
+    }
+}
+
+struct SongInfo {
+    album_art: gtk::Image,
+    song_text: gtk::Label,
+}
+
+fn song_info() -> mpd::error::Result<(gtk::Widget, SongInfo)> {
+    let mut conn = Client::connect("127.0.0.1:6600").unwrap();
+    let container = gtk::Box::new(gtk::Orientation::Vertical, 16);
+    let album_art = gtk::Image::new();
+    let song_text = gtk::Label::new(None);
+    song_text.set_justify(gtk::Justification::Center);
+    if let Some(song) = conn.currentsong()? {
+        let image_data = conn.albumart(&song).unwrap();
+        let image_pixbuf = gtk::gdk_pixbuf::Pixbuf::from_stream(
+            &gtk::gio::MemoryInputStream::from_bytes(&gtk::glib::Bytes::from(&image_data)),
+            gtk::gio::Cancellable::NONE,
+        )
+        .ok()
+        .and_then(|x| x.scale_simple(128, 128, gtk::gdk_pixbuf::InterpType::Hyper));
+        album_art.set_pixbuf(image_pixbuf.as_ref());
+
+        let ssdf = "[Unknown]".into();
+        let title = song.title.unwrap_or("[Unknown]".into());
+        let album = song.tags.get("Album").unwrap_or(&ssdf);
+        let artist = song.artist.unwrap_or("[Unknown]".into());
+        let string = format!("{}\n{} - {}", title, artist, album);
+        song_text.set_text(&string);
+
+        let attr_list = gtk::pango::AttrList::new();
+
+        let mut attr = gtk::pango::AttrFloat::new_scale(2.0);
+        attr.set_start_index(0);
+        attr.set_end_index(title.len() as u32);
+        attr_list.insert(attr);
+
+        let mut attr = gtk::pango::AttrFloat::new_scale(1.5);
+        attr.set_start_index(title.len() as u32 + 1);
+        // attr.set_end_index(title.len() as u32 + 1 + album.len() as u32);
+        attr_list.insert(attr);
+
+        song_text.set_attributes(Some(&attr_list));
+    }
+
+    container.add(&album_art);
+    container.add(&song_text);
+
+    Ok((
+        container.upcast(),
+        SongInfo {
+            album_art,
+            song_text,
+        },
+    ))
+}
+
+fn main() {
+    let application = Application::builder()
+        .application_id("space.jakob.Tunes")
+        .build();
+
+    application.connect_activate(|app| {
+        libhandy::init();
+
+        let mut conn = Client::connect("127.0.0.1:6600").unwrap();
+
+        // conn.volume(100).unwrap();
+        // conn.load("My Lounge Playlist", ..).unwrap();
+        // conn.play().unwrap();
+
+        let stack = gtk::Stack::new();
+        let (song_info_view, _song_info_container) = song_info().unwrap();
+        stack.add_named(&song_info_view, "Currently Playing");
+
+        let header_bar = HeaderBar::builder()
+            .show_close_button(true)
+            .title(&header_title(&mut conn).unwrap())
+            .build();
+        let asdf = libhandy::ViewSwitcherTitle::builder()
+            .title("Tunes")
+            .stack(&stack)
+            .build();
+        header_bar.add(&asdf);
+
+        let ui = TunesUI { header_bar };
+
+        // Combine the content in a box
+        let content = Box::new(Orientation::Vertical, 0);
+        // Handy's ApplicationWindow does not include a HeaderBar
+        content.add(&ui.header_bar);
+        content.add(&stack);
+
+        let window = ApplicationWindow::builder()
+            .default_width(350)
+            .default_height(70)
+            // add content to window
+            .child(&content)
+            .build();
+        window.set_application(Some(app));
+        window.show_all();
+
+        let (mut sender, mut receiver) = mpsc::channel(1000);
+        std::thread::spawn(move || loop {
+            let mut conn = Client::connect("127.0.0.1:6600").unwrap();
+            if let Ok(_subsystems) = conn.wait(&[mpd::idle::Subsystem::Player]) {
+                sender.try_send(true);
+            } else {
+                sender.try_send(false);
+                break;
+            }
+        });
+
+        let main_context = gtk::glib::MainContext::default();
+        main_context.spawn_local(async move {
+            let mut conn = Client::connect("127.0.0.1:6600").unwrap();
+            while let Some(item) = receiver.next().await {
+                if let Ok(title) = header_title(&mut conn) {
+                    ui.header_bar.set_title(Some(&title));
+                }
+            }
+        });
+    });
+
+    application.run();
+}