musicus/src/screens/ensemble.rs

use super::RecordingScreen;
use crate::backend::Backend;
use crate::database::{Ensemble, Recording};
use crate::editors::EnsembleEditor;
use crate::navigator::{NavigatorWindow, NavigationHandle, Screen};
use crate::widgets;
use crate::widgets::{List, Section, Widget};
use gettextrs::gettext;
use glib::clone;
use gtk::prelude::*;
use libadwaita::prelude::*;
use std::cell::RefCell;
use std::rc::Rc;

/// A screen for showing recordings with a ensemble.
pub struct EnsembleScreen {
    handle: NavigationHandle<()>,
    ensemble: Ensemble,
    widget: widgets::Screen,
    recording_list: Rc<List>,
    recordings: RefCell<Vec<Recording>>,
}

impl Screen<Ensemble, ()> for EnsembleScreen {
    /// Create a new ensemble screen for the specified ensemble and load the
    /// contents asynchronously.
    fn new(ensemble: Ensemble, handle: NavigationHandle<()>) -> Rc<Self> {
        let widget = widgets::Screen::new();
        widget.set_title(&ensemble.name);

        let recording_list = List::new();

        let this = Rc::new(Self {
            handle,
            ensemble,
            widget,
            recording_list,
            recordings: RefCell::new(Vec::new()),
        });

        this.widget.set_back_cb(clone!(@weak this => move || {
            this.handle.pop(None);
        }));


        this.widget.add_action(&gettext("Edit ensemble"), clone!(@weak this => move || {
            spawn!(@clone this, async move {
                let window = NavigatorWindow::new(this.handle.backend.clone());
                replace!(window.navigator, EnsembleEditor, Some(this.ensemble.clone())).await;
            });
        }));

        this.widget.add_action(&gettext("Delete ensemble"), clone!(@weak this => move || {
            spawn!(@clone this, async move {
                this.handle.backend.db().delete_ensemble(&this.ensemble.id).await.unwrap();
                this.handle.backend.library_changed();
            });
        }));

        this.widget.set_search_cb(clone!(@weak this => move || {
            this.recording_list.invalidate_filter();
        }));

        this.recording_list.set_make_widget_cb(clone!(@weak this => move |index| {
            let recording = &this.recordings.borrow()[index];

            let row = libadwaita::ActionRow::new();
            row.set_activatable(true);
            row.set_title(Some(&recording.work.get_title()));
            row.set_subtitle(Some(&recording.get_performers()));

            let recording = recording.to_owned();
            row.connect_activated(clone!(@weak this => move |_| {
                let recording = recording.clone();
                spawn!(@clone this, async move {
                    push!(this.handle, RecordingScreen, recording.clone()).await;
                });
            }));

            row.upcast()
        }));

        this.recording_list.set_filter_cb(clone!(@weak this => move |index| {
            let recording = &this.recordings.borrow()[index];
            let search = this.widget.get_search();
            let text = recording.work.get_title() + &recording.get_performers();
            search.is_empty() || text.to_lowercase().contains(&search)
        }));

        // Load the content asynchronously.

        spawn!(@clone this, async move {
            let recordings = this.handle
                .backend
                .db()
                .get_recordings_for_ensemble(&this.ensemble.id)
                .await
                .unwrap();

            if !recordings.is_empty() {
                let length = recordings.len();
                this.recordings.replace(recordings);
                this.recording_list.update(length);

                let section = Section::new("Recordings", &this.recording_list.widget);
                this.widget.add_content(&section.widget);
            }

            this.widget.ready();
        });

        this
    }
}

impl Widget for EnsembleScreen {
    fn get_widget(&self) -> gtk::Widget {
        self.widget.widget.clone().upcast()
    }
}