#![allow(new_without_default)] use gio::{ApplicationExt, ApplicationExtManual, ApplicationFlags, Settings, SettingsExt, SimpleAction, SimpleActionExt, ActionMapExt}; use glib; use gtk; use gtk::prelude::*; use gtk::SettingsExt as GtkSettingsExt; use hammond_data::Podcast; use hammond_data::{opml}; use appnotif::{InAppNotification, UndoState}; use headerbar::Header; use settings::{self, WindowGeometry}; use stacks::{Content, PopulatedState}; use utils; use widgets::{mark_all_notif, remove_show_notif}; use std::rc::Rc; use std::sync::mpsc::{channel, Sender}; use std::sync::Arc; use rayon; use std::cell::RefCell; #[derive(Debug, Clone)] pub enum Action { RefreshAllViews, RefreshEpisodesView, RefreshEpisodesViewBGR, RefreshShowsView, ReplaceWidget(Arc), RefreshWidgetIfSame(i32), ShowWidgetAnimated, ShowShowsAnimated, HeaderBarShowTile(String), HeaderBarNormal, HeaderBarShowUpdateIndicator, HeaderBarHideUpdateIndicator, MarkAllPlayerNotification(Arc), RemoveShow(Arc), ErrorNotification(String), } #[derive(Debug)] pub struct App { app_instance: gtk::Application, settings: Settings, } impl App { pub fn new() -> App { let settings = Settings::new("org.gnome.Hammond"); let application = gtk::Application::new("org.gnome.Hammond", ApplicationFlags::empty()) .expect("Application Initialization failed..."); // Weird magic I copy-pasted that sets the Application Name in the Shell. glib::set_application_name("Hammond"); glib::set_prgname(Some("Hammond")); let cleanup_date = settings::get_cleanup_date(&settings); utils::cleanup(cleanup_date); application.connect_startup(clone!(settings => move |app| { let (sender, receiver) = channel(); let receiver = Rc::new(RefCell::new(receiver)); let refresh = SimpleAction::new("refresh", None); refresh.connect_activate(clone!(sender => move |_, _| { gtk::idle_add(clone!(sender => move || { let s: Option> = None; utils::refresh(s, sender.clone()); glib::Continue(false) })); })); app.add_action(&refresh); let import = SimpleAction::new("import", None); import.connect_activate(clone!(sender, app => move |_, _| { let window = app.get_active_window().expect("Failed to get active window"); on_import_clicked(&window, &sender); })); app.add_action(&import); let about = SimpleAction::new("about", None); about.connect_activate(clone!(app => move |_, _| { let window = app.get_active_window().expect("Failed to get active window"); about_dialog(&window); })); app.add_action(&about); let quit = SimpleAction::new("quit", None); quit.connect_activate(clone!(app => move |_, _| app.quit())); app.add_action(&quit); app.connect_activate(clone!(sender, settings, receiver => move |app| { // Get the current window (if any) if let Some(window) = app.get_active_window() { // Already open, just raise the window window.present(); } else { // Time to open one! // Create the main window let window = gtk::ApplicationWindow::new(&app); window.set_title("Hammond"); window.connect_delete_event(clone!(app, settings => move |window, _| { WindowGeometry::from_window(&window).write(&settings); app.quit(); Inhibit(false) })); // Create a content instance let content = Rc::new(Content::new(sender.clone()).expect( "Content Initialization failed.")); // Create the headerbar let header = Rc::new(Header::new(&content, &window, &sender)); // Add the content main stack to the overlay. let overlay = gtk::Overlay::new(); overlay.add(&content.get_stack()); // Add the overlay to the main window window.add(&overlay); WindowGeometry::from_settings(&settings).apply(&window); App::setup_timed_callbacks(&sender, &settings); window.show_all(); window.activate(); gtk::timeout_add(50, clone!(sender, receiver => move || { // Uses receiver, content, header, sender, overlay let act = receiver.borrow().try_recv(); //let act: Result = Ok(Action::RefreshAllViews); match act { Ok(Action::RefreshAllViews) => content.update(), Ok(Action::RefreshShowsView) => content.update_shows_view(), Ok(Action::RefreshWidgetIfSame(id)) => content.update_widget_if_same(id), Ok(Action::RefreshEpisodesView) => content.update_home(), Ok(Action::RefreshEpisodesViewBGR) => content.update_home_if_background(), Ok(Action::ReplaceWidget(pd)) => { let shows = content.get_shows(); let mut pop = shows.borrow().populated(); pop.borrow_mut() .replace_widget(pd.clone()) .map_err(|err| error!("Failed to update ShowWidget: {}", err)) .map_err(|_| error!("Failed ot update ShowWidget {}", pd.title())) .ok(); } Ok(Action::ShowWidgetAnimated) => { let shows = content.get_shows(); let mut pop = shows.borrow().populated(); pop.borrow_mut().switch_visible( PopulatedState::Widget, gtk::StackTransitionType::SlideLeft, ); } Ok(Action::ShowShowsAnimated) => { let shows = content.get_shows(); let mut pop = shows.borrow().populated(); pop.borrow_mut() .switch_visible(PopulatedState::View, gtk::StackTransitionType::SlideRight); } Ok(Action::HeaderBarShowTile(title)) => header.switch_to_back(&title), Ok(Action::HeaderBarNormal) => header.switch_to_normal(), Ok(Action::HeaderBarShowUpdateIndicator) => header.show_update_notification(), Ok(Action::HeaderBarHideUpdateIndicator) => header.hide_update_notification(), Ok(Action::MarkAllPlayerNotification(pd)) => { let notif = mark_all_notif(pd, &sender); notif.show(&overlay); } Ok(Action::RemoveShow(pd)) => { let notif = remove_show_notif(pd, sender.clone()); notif.show(&overlay); } Ok(Action::ErrorNotification(err)) => { error!("An error notification was triggered: {}", err); let callback = || glib::Continue(false); let notif = InAppNotification::new(&err, callback, || {}, UndoState::Hidden); notif.show(&overlay); } Err(_) => (), } Continue(true) })); } })); })); App { app_instance: application, settings, } } fn setup_timed_callbacks(sender: &Sender, settings: &Settings) { App::setup_dark_theme(&sender, settings); App::setup_refresh_on_startup(&sender, settings); App::setup_auto_refresh(&sender, settings); } fn setup_dark_theme(_sender: &Sender, settings: &Settings) { let gtk_settings = gtk::Settings::get_default().unwrap(); let enabled = settings.get_boolean("dark-theme"); gtk_settings.set_property_gtk_application_prefer_dark_theme(enabled); } fn setup_refresh_on_startup(sender: &Sender, settings: &Settings) { // Update the feeds right after the Application is initialized. let sender = sender.clone(); if settings.get_boolean("refresh-on-startup") { info!("Refresh on startup."); // The ui loads async, after initialization // so we need to delay this a bit so it won't block // requests that will come from loading the gui on startup. gtk::timeout_add(1500, move || { let s: Option> = None; utils::refresh(s, sender.clone()); glib::Continue(false) }); } } fn setup_auto_refresh(sender: &Sender, settings: &Settings) { let refresh_interval = settings::get_refresh_interval(&settings).num_seconds() as u32; info!("Auto-refresh every {:?} seconds.", refresh_interval); let sender = sender.clone(); gtk::timeout_add_seconds(refresh_interval, move || { let s: Option> = None; utils::refresh(s, sender.clone()); glib::Continue(true) }); } pub fn run(self) { ApplicationExtManual::run(&self.app_instance, &[]); } } // Totally copied it from fractal. // https://gitlab.gnome.org/danigm/fractal/blob/503e311e22b9d7540089d735b92af8e8f93560c5/fractal-gtk/src/app.rs#L1883-1912 fn about_dialog(window: >k::Window) { // Feel free to add yourself if you contribured. let authors = &[ "Constantin Nickel", "Gabriele Musco", "James Wykeham-Martin", "Jordan Petridis", "Julian Sparber", "Rowan Lewis", "Zander Brown", ]; let dialog = gtk::AboutDialog::new(); // Waiting for a logo. // dialog.set_logo_icon_name("org.gnome.Hammond"); dialog.set_logo_icon_name("multimedia-player"); dialog.set_comments("Podcast Client for the GNOME Desktop."); dialog.set_copyright("© 2017, 2018 Jordan Petridis"); dialog.set_license_type(gtk::License::Gpl30); dialog.set_modal(true); // TODO: make it show it fetches the commit hash from which it was built // and the version number is kept in sync automaticly dialog.set_version("0.3.3"); dialog.set_program_name("Hammond"); // TODO: Need a wiki page first. // dialog.set_website("https://wiki.gnome.org/Design/Apps/Potential/Podcasts"); // dialog.set_website_label("Learn more about Hammond"); dialog.set_transient_for(window); dialog.set_artists(&["Tobias Bernard"]); dialog.set_authors(authors); dialog.show(); } fn on_import_clicked(window: >k::Window, sender: &Sender) { use glib::translate::ToGlib; use gtk::{FileChooserAction, FileChooserNative, FileFilter, ResponseType}; // let dialog = FileChooserDialog::new(title, Some(&window), FileChooserAction::Open); // TODO: It might be better to use a FileChooserNative widget. // Create the FileChooser Dialog let dialog = FileChooserNative::new( Some("Select the file from which to you want to Import Shows."), Some(window), FileChooserAction::Open, Some("_Import"), None, ); // Do not show hidden(.thing) files dialog.set_show_hidden(false); // Set a filter to show only xml files let filter = FileFilter::new(); FileFilterExt::set_name(&filter, Some("OPML file")); filter.add_mime_type("application/xml"); filter.add_mime_type("text/xml"); dialog.add_filter(&filter); dialog.connect_response(clone!(sender => move |dialog, resp| { debug!("Dialong Response {}", resp); if resp == ResponseType::Accept.to_glib() { // TODO: Show an in-app notifictaion if the file can not be accessed if let Some(filename) = dialog.get_filename() { debug!("File selected: {:?}", filename); rayon::spawn(clone!(sender => move || { // Parse the file and import the feeds if let Ok(sources) = opml::import_from_file(filename) { // Refresh the succesfully parsed feeds to index them utils::refresh(Some(sources), sender) } else { let text = String::from("Failed to parse the Imported file"); sender.send(Action::ErrorNotification(text)) .map_err(|err| error!("Action Sender: {}", err)) .ok(); } })) } else { let text = String::from("Selected File could not be accessed."); sender.send(Action::ErrorNotification(text)) .map_err(|err| error!("Action Sender: {}", err)) .ok(); } } dialog.destroy(); })); dialog.run(); }