X-Git-Url: https://main.carlh.net/gitweb/?p=dcpomatic.git;a=blobdiff_plain;f=src%2Fwx%2Fswaroop_controls.cc;h=5ce6c45fc7a637f6e6c1e99124d596f7698cb422;hp=fafac55d61010922e7257856b4ad7cb4b2edc57b;hb=2ecead272e146c78850e333fa408395d51fdd132;hpb=fd3ba4d4bccbddaf626271d0743a6a9845b351f0 diff --git a/src/wx/swaroop_controls.cc b/src/wx/swaroop_controls.cc index fafac55d6..5ce6c45fc 100644 --- a/src/wx/swaroop_controls.cc +++ b/src/wx/swaroop_controls.cc @@ -1,5 +1,5 @@ /* - Copyright (C) 2018 Carl Hetherington + Copyright (C) 2018-2019 Carl Hetherington This file is part of DCP-o-matic. @@ -22,27 +22,44 @@ #include "film_viewer.h" #include "wx_util.h" #include "content_view.h" +#include "dcpomatic_button.h" +#include "static_text.h" #include "lib/player_video.h" #include "lib/dcp_content.h" +#include "lib/cross.h" +#include "lib/scoped_temporary.h" +#include "lib/internet.h" +#include "lib/ffmpeg_content.h" +#include "lib/compose.hpp" +#include +#include #include +#include using std::string; using std::cout; using std::exception; +using std::sort; using boost::shared_ptr; using boost::dynamic_pointer_cast; using boost::optional; +using namespace dcpomatic; SwaroopControls::SwaroopControls (wxWindow* parent, shared_ptr viewer) : Controls (parent, viewer, false) - , _play_button (new wxButton(this, wxID_ANY, _("Play"))) - , _pause_button (new wxButton(this, wxID_ANY, _("Pause"))) - , _stop_button (new wxButton(this, wxID_ANY, _("Stop"))) + , _play_button (new Button(this, _("Play"))) + , _pause_button (new Button(this, _("Pause"))) + , _stop_button (new Button(this, _("Stop"))) + , _next_button (new Button(this, "Next")) + , _previous_button (new Button(this, "Previous")) , _current_disable_timeline (false) + , _current_disable_next (false) { + _button_sizer->Add (_previous_button, 0, wxEXPAND); _button_sizer->Add (_play_button, 0, wxEXPAND); _button_sizer->Add (_pause_button, 0, wxEXPAND); _button_sizer->Add (_stop_button, 0, wxEXPAND); + _button_sizer->Add (_next_button, 0, wxEXPAND); _spl_view = new wxListCtrl (this, wxID_ANY, wxDefaultPosition, wxDefaultSize, wxLC_REPORT | wxLC_NO_HEADER); _spl_view->AppendColumn (wxT(""), wxLIST_FORMAT_LEFT, 740); @@ -50,31 +67,112 @@ SwaroopControls::SwaroopControls (wxWindow* parent, shared_ptr viewe wxBoxSizer* left_sizer = new wxBoxSizer (wxVERTICAL); wxBoxSizer* e_sizer = new wxBoxSizer (wxHORIZONTAL); - left_sizer->Add (_spl_view, 1, wxALL | wxEXPAND, DCPOMATIC_SIZER_GAP); + wxFont subheading_font (*wxNORMAL_FONT); + subheading_font.SetWeight (wxFONTWEIGHT_BOLD); + + wxBoxSizer* spl_header = new wxBoxSizer (wxHORIZONTAL); + { + wxStaticText* m = new StaticText (this, "Playlists"); + m->SetFont (subheading_font); + spl_header->Add (m, 1, wxALIGN_CENTER_VERTICAL); + } + _refresh_spl_view = new Button (this, "Refresh"); + spl_header->Add (_refresh_spl_view, 0, wxBOTTOM, DCPOMATIC_SIZER_GAP / 2); + + left_sizer->Add (spl_header, 0, wxLEFT | wxRIGHT | wxEXPAND, DCPOMATIC_SIZER_GAP); + left_sizer->Add (_spl_view, 1, wxLEFT | wxRIGHT | wxBOTTOM | wxEXPAND, DCPOMATIC_SIZER_GAP); _content_view = new ContentView (this); - left_sizer->Add (_content_view, 1, wxALL | wxEXPAND, DCPOMATIC_SIZER_GAP); + + wxBoxSizer* content_header = new wxBoxSizer (wxHORIZONTAL); + { + wxStaticText* m = new StaticText (this, "Content"); + m->SetFont (subheading_font); + content_header->Add (m, 1, wxALIGN_CENTER_VERTICAL); + } + _refresh_content_view = new Button (this, "Refresh"); + content_header->Add (_refresh_content_view, 0, wxBOTTOM, DCPOMATIC_SIZER_GAP / 2); + + left_sizer->Add (content_header, 0, wxTOP | wxLEFT | wxRIGHT | wxEXPAND, DCPOMATIC_SIZER_GAP); + left_sizer->Add (_content_view, 1, wxLEFT | wxRIGHT | wxBOTTOM | wxEXPAND, DCPOMATIC_SIZER_GAP); _current_spl_view = new wxListCtrl (this, wxID_ANY, wxDefaultPosition, wxDefaultSize, wxLC_REPORT | wxLC_NO_HEADER); _current_spl_view->AppendColumn (wxT(""), wxLIST_FORMAT_LEFT, 500); _current_spl_view->AppendColumn (wxT(""), wxLIST_FORMAT_LEFT, 80); - e_sizer->Add (left_sizer, 0, wxALL | wxEXPAND, DCPOMATIC_SIZER_GAP); + e_sizer->Add (left_sizer, 1, wxALL | wxEXPAND, DCPOMATIC_SIZER_GAP); e_sizer->Add (_current_spl_view, 1, wxALL | wxEXPAND, DCPOMATIC_SIZER_GAP); _v_sizer->Add (e_sizer, 1, wxEXPAND); - _log = new wxTextCtrl (this, wxID_ANY, wxT(""), wxDefaultPosition, wxSize(-1, 200), wxTE_READONLY | wxTE_MULTILINE); - _v_sizer->Add (_log, 0, wxALL | wxEXPAND, DCPOMATIC_SIZER_GAP); - - _play_button->Bind (wxEVT_BUTTON, boost::bind(&SwaroopControls::play_clicked, this)); - _pause_button->Bind (wxEVT_BUTTON, boost::bind(&SwaroopControls::pause_clicked, this)); - _stop_button->Bind (wxEVT_BUTTON, boost::bind(&SwaroopControls::stop_clicked, this)); - _spl_view->Bind (wxEVT_LIST_ITEM_SELECTED, boost::bind(&SwaroopControls::spl_selection_changed, this)); - _spl_view->Bind (wxEVT_LIST_ITEM_DESELECTED, boost::bind(&SwaroopControls::spl_selection_changed, this)); - _viewer->ImageChanged.connect (boost::bind(&SwaroopControls::image_changed, this, _1)); + _play_button->Bind (wxEVT_BUTTON, boost::bind(&SwaroopControls::play_clicked, this)); + _pause_button->Bind (wxEVT_BUTTON, boost::bind(&SwaroopControls::pause_clicked, this)); + _stop_button->Bind (wxEVT_BUTTON, boost::bind(&SwaroopControls::stop_clicked, this)); + _next_button->Bind (wxEVT_BUTTON, boost::bind(&SwaroopControls::next_clicked, this)); + _previous_button->Bind (wxEVT_BUTTON, boost::bind(&SwaroopControls::previous_clicked, this)); + _spl_view->Bind (wxEVT_LIST_ITEM_SELECTED, boost::bind(&SwaroopControls::spl_selection_changed, this)); + _spl_view->Bind (wxEVT_LIST_ITEM_DESELECTED, boost::bind(&SwaroopControls::spl_selection_changed, this)); + _viewer->Finished.connect (boost::bind(&SwaroopControls::viewer_finished, this)); + _viewer->PositionChanged.connect (boost::bind(&SwaroopControls::viewer_position_changed, this)); + _refresh_spl_view->Bind (wxEVT_BUTTON, boost::bind(&SwaroopControls::update_playlist_directory, this)); + _refresh_content_view->Bind (wxEVT_BUTTON, boost::bind(&ContentView::update, _content_view)); _content_view->update (); update_playlist_directory (); + + _viewer->set_background_image (true); +} + +void +SwaroopControls::check_restart () +{ + cout << "check_restart called\n"; + FILE* f = fopen_boost (Config::path("position"), "r"); + if (!f) { + cout << "could not open position file (" << errno << ")\n"; + return; + } + + char id[64]; + int index; + int64_t time; + fscanf (f, "%63s %d %ld", id, &index, &time); + + cout << "Looking for playlist " << id << " to restart.\n"; + + for (size_t i = 0; i < _playlists.size(); ++i) { + if (_playlists[i].id() == id) { + cout << "Found playlist " << id << "\n"; + select_playlist (i, index); + update_current_content (); + _viewer->seek (DCPTime(time), false); + _viewer->start (); + } + } + + fclose (f); +} + +void +SwaroopControls::viewer_position_changed () +{ + /* Write position every two minutes if we're playing */ + if (!_selected_playlist || !_viewer->playing() || _viewer->position().get() % (2 * 60 * DCPTime::HZ)) { + return; + } + + FILE* f = fopen_boost (Config::path("position"), "w"); + if (f) { + string const p = _playlists[*_selected_playlist].id() + + " " + dcp::raw_convert(_selected_playlist_position) + + " " + dcp::raw_convert(_viewer->position().get()); + + checked_fwrite (p.c_str(), p.length(), f, Config::path("position")); +#ifdef DCPOMATIC_LINUX + fflush (f); + fsync (fileno(f)); +#endif + fclose (f); + } } void @@ -83,8 +181,10 @@ SwaroopControls::started () Controls::started (); _play_button->Enable (false); _pause_button->Enable (true); + _viewer->set_background_image (false); } +/** Called when the viewer finishes a single piece of content, or it is explicitly stopped */ void SwaroopControls::stopped () { @@ -93,6 +193,29 @@ SwaroopControls::stopped () _pause_button->Enable (false); } +void +SwaroopControls::deselect_playlist () +{ + long int const selected = _spl_view->GetNextItem (-1, wxLIST_NEXT_ALL, wxLIST_STATE_SELECTED); + if (selected != -1) { + _selected_playlist = boost::none; + _spl_view->SetItemState (selected, 0, wxLIST_STATE_SELECTED); + } + ResetFilm (shared_ptr(new Film(optional()))); +} + +void +SwaroopControls::decrement_allowed_shows () +{ + if (_selected_playlist) { + SPL& spl = _playlists[*_selected_playlist]; + spl.decrement_allowed_shows(); + if (spl.path()) { + spl.write (*spl.path()); + } + } +} + void SwaroopControls::play_clicked () { @@ -106,9 +229,11 @@ SwaroopControls::setup_sensitivity () bool const active_job = _active_job && *_active_job != "examine_content"; bool const c = _film && !_film->content().empty() && !active_job; _play_button->Enable (c && !_viewer->playing()); - _pause_button->Enable (c && (!_current_kind || _current_kind != dcp::ADVERTISEMENT) && _viewer->playing()); - _stop_button->Enable (c && (!_current_kind || _current_kind != dcp::ADVERTISEMENT)); - _slider->Enable (c && (!_current_kind || _current_kind != dcp::ADVERTISEMENT) && !_current_disable_timeline); + _pause_button->Enable (_viewer->playing()); + _slider->Enable (!_current_disable_timeline); + _spl_view->Enable (!_viewer->playing()); + _next_button->Enable (!_current_disable_next && can_do_next()); + _previous_button->Enable (can_do_previous()); } void @@ -122,59 +247,70 @@ SwaroopControls::stop_clicked () { _viewer->stop (); _viewer->seek (DCPTime(), true); + if (_selected_playlist) { + _selected_playlist_position = 0; + update_current_content (); + } + _viewer->set_background_image (true); + decrement_allowed_shows (); + deselect_playlist (); } -void -SwaroopControls::log (wxString s) +bool +SwaroopControls::can_do_previous () { - struct timeval time; - gettimeofday (&time, 0); - char buffer[64]; - time_t const sec = time.tv_sec; - struct tm* t = localtime (&sec); - strftime (buffer, 64, "%c", t); - wxString ts = std_to_wx(string(buffer)) + N_(": "); - _log->SetValue(_log->GetValue() + ts + s + "\n"); + return _selected_playlist && (_selected_playlist_position - 1) >= 0; } void -SwaroopControls::image_changed (boost::weak_ptr weak_pv) +SwaroopControls::previous_clicked () { - shared_ptr pv = weak_pv.lock (); - if (!pv) { + if (!can_do_previous ()) { return; } - shared_ptr c = pv->content().lock(); - if (!c) { - return; - } + _selected_playlist_position--; + update_current_content (); +} - if (c == _current_content.lock()) { +bool +SwaroopControls::can_do_next () +{ + return _selected_playlist && (_selected_playlist_position + 1) < int(_playlists[*_selected_playlist].get().size()); +} + +void +SwaroopControls::next_clicked () +{ + if (!can_do_next ()) { return; } - _current_content = c; - - long int selected = _spl_view->GetNextItem (-1, wxLIST_NEXT_ALL, wxLIST_STATE_SELECTED); - if (_selected_playlist) { - BOOST_FOREACH (SPLEntry i, _playlists[*_selected_playlist].get()) { - if (i.content == c) { - _current_disable_timeline = i.disable_timeline; - setup_sensitivity (); - } - } - } + _selected_playlist_position++; + update_current_content (); +} - shared_ptr dc = dynamic_pointer_cast (c); - if (!dc) { +void +SwaroopControls::log (wxString s) +{ + optional log = Config::instance()->player_activity_log_file(); + if (!log) { return; } - if (!_current_kind || *_current_kind != dc->content_kind()) { - _current_kind = dc->content_kind (); - setup_sensitivity (); + struct timeval time; + gettimeofday (&time, 0); + char buffer[64]; + time_t const sec = time.tv_sec; + struct tm* t = localtime (&sec); + strftime (buffer, 64, "%c", t); + wxString ts = std_to_wx(string(buffer)) + N_(": "); + FILE* f = fopen_boost (*log, "a"); + if (!f) { + return; } + fprintf (f, "%s%s\n", wx_to_std(ts).c_str(), wx_to_std(s).c_str()); + fclose (f); } void @@ -185,10 +321,21 @@ SwaroopControls::add_playlist_to_list (SPL spl) wxListItem it; it.SetId(N); it.SetColumn(0); - it.SetText (std_to_wx(spl.name())); + string t = spl.name(); + if (spl.missing()) { + t += " (content missing)"; + } + it.SetText (std_to_wx(t)); _spl_view->InsertItem (it); } +struct SPLComparator +{ + bool operator() (SPL const & a, SPL const & b) { + return a.name() < b.name(); + } +}; + void SwaroopControls::update_playlist_directory () { @@ -208,28 +355,166 @@ SwaroopControls::update_playlist_directory () SPL spl; spl.read (i->path(), _content_view); _playlists.push_back (spl); - add_playlist_to_list (spl); } } catch (exception& e) { /* Never mind */ } } + + sort (_playlists.begin(), _playlists.end(), SPLComparator()); + BOOST_FOREACH (SPL i, _playlists) { + add_playlist_to_list (i); + } + + _selected_playlist = boost::none; +} + +optional +SwaroopControls::get_kdm_from_url (shared_ptr dcp) +{ + ScopedTemporary temp; + string url = Config::instance()->kdm_server_url(); + boost::algorithm::replace_all (url, "{CPL}", *dcp->cpl()); + optional kdm; + if (dcp->cpl() && !get_from_url(url, false, false, temp)) { + try { + kdm = dcp::EncryptedKDM (dcp::file_to_string(temp.file())); + if (kdm->cpl_id() != dcp->cpl()) { + kdm = boost::none; + } + } catch (std::exception& e) { + /* Hey well */ + } + } + return kdm; +} + +optional +SwaroopControls::get_kdm_from_directory (shared_ptr dcp) +{ + using namespace boost::filesystem; + optional kdm_dir = Config::instance()->player_kdm_directory(); + if (!kdm_dir) { + return optional(); + } + for (directory_iterator i = directory_iterator(*kdm_dir); i != directory_iterator(); ++i) { + try { + if (file_size(i->path()) < MAX_KDM_SIZE) { + dcp::EncryptedKDM kdm (dcp::file_to_string(i->path())); + if (kdm.cpl_id() == dcp->cpl()) { + return kdm; + } + } + } catch (std::exception& e) { + /* Hey well */ + } + } + return optional(); } +optional +SwaroopControls::get_kdm_from_directory (shared_ptr ffmpeg) +{ + using namespace boost::filesystem; + optional kdm_dir = Config::instance()->player_kdm_directory(); + if (!kdm_dir) { + return optional(); + } + for (directory_iterator i = directory_iterator(*kdm_dir); i != directory_iterator(); ++i) { + try { + if (file_size(i->path()) < MAX_KDM_SIZE) { + EncryptedECinemaKDM kdm (dcp::file_to_string(i->path())); + if (kdm.id() == ffmpeg->id().get_value_or("")) { + return kdm; + } + } + } catch (std::exception& e) { + /* Hey well */ + } + } + return optional(); +} void SwaroopControls::spl_selection_changed () { - _current_spl_view->DeleteAllItems (); - long int selected = _spl_view->GetNextItem (-1, wxLIST_NEXT_ALL, wxLIST_STATE_SELECTED); if (selected == -1) { + _current_spl_view->DeleteAllItems (); _selected_playlist = boost::none; return; } - _selected_playlist = selected; + if (_playlists[selected].missing()) { + error_dialog (this, "This playlist cannot be loaded as some content is missing."); + deselect_playlist (); + return; + } - shared_ptr film (new Film(optional())); + if (_playlists[selected].get().empty()) { + error_dialog (this, "This playlist is empty."); + return; + } + + if (!_playlists[selected].have_allowed_shows()) { + error_dialog (this, "There are no more allowed shows of this playlist."); + return; + } + + select_playlist (selected, 0); +} + +void +SwaroopControls::select_playlist (int selected, int position) +{ + log (wxString::Format("load-playlist %s", std_to_wx(_playlists[selected].name()).data())); + + wxProgressDialog dialog (_("DCP-o-matic"), "Loading playlist and KDMs"); + + BOOST_FOREACH (SPLEntry const & i, _playlists[selected].get()) { + dialog.Pulse (); + shared_ptr dcp = dynamic_pointer_cast (i.content); + if (dcp && dcp->needs_kdm()) { + optional kdm; + kdm = get_kdm_from_url (dcp); + if (!kdm) { + kdm = get_kdm_from_directory (dcp); + } + if (kdm) { + try { + dcp->add_kdm (*kdm); + dcp->examine (_film, shared_ptr()); + } catch (KDMError& e) { + error_dialog (this, "Could not load KDM."); + } + } + if (dcp->needs_kdm()) { + /* We didn't get a KDM for this */ + error_dialog (this, "This playlist cannot be loaded as a KDM is missing or incorrect."); + deselect_playlist (); + return; + } + } + shared_ptr ffmpeg = dynamic_pointer_cast (i.content); + if (ffmpeg && ffmpeg->encrypted()) { + optional kdm = get_kdm_from_directory (ffmpeg); + if (kdm) { + try { + ffmpeg->add_kdm (*kdm); + ffmpeg->examine (_film, shared_ptr()); + } catch (KDMError& e) { + error_dialog (this, "This playlist cannot be loaded as a KDM is missing or incorrect."); + deselect_playlist (); + return; + } + } else { + error_dialog (this, "This playlist cannot be loaded as a KDM is missing or incorrect."); + deselect_playlist (); + return; + } + } + } + + _current_spl_view->DeleteAllItems (); int N = 0; BOOST_FOREACH (SPLEntry i, _playlists[selected].get()) { @@ -238,10 +523,23 @@ SwaroopControls::spl_selection_changed () it.SetColumn (0); it.SetText (std_to_wx(i.name)); _current_spl_view->InsertItem (it); - film->add_content (i.content); ++N; } + _selected_playlist = selected; + _selected_playlist_position = position; + dialog.Pulse (); + reset_film (); + dialog.Pulse (); + update_current_content (); +} + +void +SwaroopControls::reset_film () +{ + DCPOMATIC_ASSERT (_selected_playlist); + shared_ptr film (new Film(optional())); + film->add_content (_playlists[*_selected_playlist].get()[_selected_playlist_position].content); ResetFilm (film); } @@ -261,6 +559,49 @@ void SwaroopControls::set_film (shared_ptr film) { Controls::set_film (film); - update_playlist_directory (); setup_sensitivity (); } + +void +SwaroopControls::update_current_content () +{ + DCPOMATIC_ASSERT (_selected_playlist); + + wxProgressDialog dialog (_("DCP-o-matic"), "Loading content"); + + SPLEntry const & e = _playlists[*_selected_playlist].get()[_selected_playlist_position]; + _current_disable_timeline = e.disable_timeline; + _current_disable_next = !e.skippable; + + setup_sensitivity (); + dialog.Pulse (); + reset_film (); +} + +/** One piece of content in our SPL has finished playing */ +void +SwaroopControls::viewer_finished () +{ + if (!_selected_playlist) { + return; + } + + bool const stop = _playlists[*_selected_playlist].get()[_selected_playlist_position].stop_after_play; + + _selected_playlist_position++; + if (_selected_playlist_position < int(_playlists[*_selected_playlist].get().size())) { + /* Next piece of content on the SPL */ + update_current_content (); + if (!stop) { + _viewer->start (); + } + } else { + /* Finished the whole SPL */ + _selected_playlist_position = 0; + _viewer->set_background_image (true); + ResetFilm (shared_ptr(new Film(optional()))); + decrement_allowed_shows (); + _play_button->Enable (true); + _pause_button->Enable (false); + } +}