Merge 1.0 in.
[dcpomatic.git] / src / lib / film.cc
index 172fd20abaf4ea561d9379fb168ad009a47bde2f..e885fe5fd350f804fb8e0e8ec489005da6b4501d 100644 (file)
@@ -31,6 +31,8 @@
 #include <boost/date_time.hpp>
 #include <libxml++/libxml++.h>
 #include <libcxml/cxml.h>
+#include <libdcp/crypt_chain.h>
+#include <libdcp/cpl.h>
 #include "film.h"
 #include "job.h"
 #include "util.h"
@@ -49,6 +51,7 @@
 #include "dcp_content_type.h"
 #include "ratio.h"
 #include "cross.h"
+#include "cinema.h"
 
 #include "i18n.h"
 
@@ -80,10 +83,10 @@ int const Film::state_version = 4;
 
 /** Construct a Film object in a given directory.
  *
- *  @param d Film directory.
+ *  @param dir Film directory.
  */
 
-Film::Film (string d)
+Film::Film (boost::filesystem::path dir)
        : _playlist (new Playlist)
        , _use_dci_name (true)
        , _dcp_content_type (Config::instance()->default_dcp_content_type ())
@@ -91,10 +94,14 @@ Film::Film (string d)
        , _resolution (RESOLUTION_2K)
        , _scaler (Scaler::from_id ("bicubic"))
        , _with_subtitles (false)
+       , _encrypted (false)
        , _j2k_bandwidth (Config::instance()->default_j2k_bandwidth ())
        , _dci_metadata (Config::instance()->default_dci_metadata ())
-       , _dcp_video_frame_rate (24)
-       , _dcp_audio_channels (MAX_AUDIO_CHANNELS)
+       , _video_frame_rate (24)
+       , _audio_channels (MAX_AUDIO_CHANNELS)
+       , _three_d (false)
+       , _sequence_video (true)
+       , _interop (false)
        , _dirty (false)
 {
        set_dci_date_today ();
@@ -106,7 +113,7 @@ Film::Film (string d)
           (Code swiped from Adam Bowen on stackoverflow)
        */
        
-       boost::filesystem::path p (boost::filesystem::system_complete (d));
+       boost::filesystem::path p (boost::filesystem::system_complete (dir));
        boost::filesystem::path result;
        for (boost::filesystem::path::iterator i = p.begin(); i != p.end(); ++i) {
                if (*i == "..") {
@@ -121,7 +128,9 @@ Film::Film (string d)
        }
 
        set_directory (result.string ());
-       _log.reset (new FileLog ("log"));
+       _log.reset (new FileLog (file ("log")));
+
+       _playlist->set_sequence_video (_sequence_video);
 }
 
 string
@@ -134,10 +143,20 @@ Film::video_identifier () const
        s << container()->id()
          << "_" << resolution_to_string (_resolution)
          << "_" << _playlist->video_identifier()
-         << "_" << _dcp_video_frame_rate
+         << "_" << _video_frame_rate
          << "_" << scaler()->id()
          << "_" << j2k_bandwidth();
 
+       if (_interop) {
+               s << "_I";
+       } else {
+               s << "_S";
+       }
+
+       if (_three_d) {
+               s << "_3D";
+       }
+
        return s.str ();
 }
          
@@ -164,13 +183,13 @@ Film::internal_video_mxf_filename () const
 }
 
 string
-Film::dcp_video_mxf_filename () const
+Film::video_mxf_filename () const
 {
        return filename_safe_name() + "_video.mxf";
 }
 
 string
-Film::dcp_audio_mxf_filename () const
+Film::audio_mxf_filename () const
 {
        return filename_safe_name() + "_audio.mxf";
 }
@@ -216,13 +235,12 @@ Film::make_dcp ()
                gethostname (buffer, sizeof (buffer));
                log()->log (String::compose ("Starting to make DCP on %1", buffer));
        }
-       
-//     log()->log (String::compose ("Content is %1; type %2", content_path(), (content_type() == STILL ? _("still") : _("video"))));
-//     if (length()) {
-//             log()->log (String::compose ("Content length %1", length().get()));
-//     }
-//     log()->log (String::compose ("Content digest %1", content_digest()));
-//     log()->log (String::compose ("Content at %1 fps, DCP at %2 fps", source_frame_rate(), dcp_frame_rate()));
+
+       ContentList cl = content ();
+       for (ContentList::const_iterator i = cl.begin(); i != cl.end(); ++i) {
+               log()->log (String::compose ("Content: %1", (*i)->technical_summary()));
+       }
+       log()->log (String::compose ("DCP video rate %1 fps", video_frame_rate()));
        log()->log (String::compose ("%1 threads", Config::instance()->num_local_encoding_threads()));
        log()->log (String::compose ("J2K bandwidth %1", j2k_bandwidth()));
 #ifdef DCPOMATIC_DEBUG
@@ -235,8 +253,7 @@ Film::make_dcp ()
 #else
        log()->log ("libdcp built in optimised mode.");
 #endif
-       pair<string, int> const c = cpu_info ();
-       log()->log (String::compose ("CPU: %1, %2 processors", c.first, c.second));
+       log()->log (String::compose ("CPU: %1, %2 processors", cpu_info(), boost::thread::hardware_concurrency ()));
        list<pair<string, string> > const m = mount_info ();
        for (list<pair<string, string> >::const_iterator i = m.begin(); i != m.end(); ++i) {
                log()->log (String::compose ("Mount: %1 %2", i->first, i->second));
@@ -296,7 +313,6 @@ Film::write_metadata () const
                boost::filesystem::create_directory (directory());
        }
        
-       boost::mutex::scoped_lock lm (_state_mutex);
        LocaleGuard lg;
 
        boost::filesystem::create_directories (directory());
@@ -321,9 +337,13 @@ Film::write_metadata () const
        root->add_child("WithSubtitles")->add_child_text (_with_subtitles ? "1" : "0");
        root->add_child("J2KBandwidth")->add_child_text (lexical_cast<string> (_j2k_bandwidth));
        _dci_metadata.as_xml (root->add_child ("DCIMetadata"));
-       root->add_child("DCPVideoFrameRate")->add_child_text (lexical_cast<string> (_dcp_video_frame_rate));
+       root->add_child("VideoFrameRate")->add_child_text (lexical_cast<string> (_video_frame_rate));
        root->add_child("DCIDate")->add_child_text (boost::gregorian::to_iso_string (_dci_date));
-       root->add_child("DCPAudioChannels")->add_child_text (lexical_cast<string> (_dcp_audio_channels));
+       root->add_child("AudioChannels")->add_child_text (lexical_cast<string> (_audio_channels));
+       root->add_child("ThreeD")->add_child_text (_three_d ? "1" : "0");
+       root->add_child("SequenceVideo")->add_child_text (_sequence_video ? "1" : "0");
+       root->add_child("Interop")->add_child_text (_interop ? "1" : "0");
+       root->add_child("Encrypted")->add_child_text (_encrypted ? "1" : "0");
        _playlist->as_xml (root->add_child ("Playlist"));
 
        doc.write_to_file_formatted (file ("metadata.xml"));
@@ -335,14 +355,14 @@ Film::write_metadata () const
 void
 Film::read_metadata ()
 {
-       boost::mutex::scoped_lock lm (_state_mutex);
        LocaleGuard lg;
 
        if (boost::filesystem::exists (file ("metadata")) && !boost::filesystem::exists (file ("metadata.xml"))) {
                throw StringError (_("This film was created with an older version of DCP-o-matic, and unfortunately it cannot be loaded into this version.  You will need to create a new Film, re-add your content and set it up again.  Sorry!"));
        }
 
-       cxml::File f (file ("metadata.xml"), "Metadata");
+       cxml::Document f ("Metadata");
+       f.read_file (file ("metadata.xml"));
        
        _name = f.string_child ("Name");
        _use_dci_name = f.bool_child ("UseDCIName");
@@ -366,9 +386,12 @@ Film::read_metadata ()
        _with_subtitles = f.bool_child ("WithSubtitles");
        _j2k_bandwidth = f.number_child<int> ("J2KBandwidth");
        _dci_metadata = DCIMetadata (f.node_child ("DCIMetadata"));
-       _dcp_video_frame_rate = f.number_child<int> ("DCPVideoFrameRate");
+       _video_frame_rate = f.number_child<int> ("VideoFrameRate");
        _dci_date = boost::gregorian::from_undelimited_string (f.string_child ("DCIDate"));
-       _dcp_audio_channels = f.number_child<int> ("DCPAudioChannels");
+       _audio_channels = f.number_child<int> ("AudioChannels");
+       _sequence_video = f.bool_child ("SequenceVideo");
+       _three_d = f.bool_child ("ThreeD");
+       _interop = f.bool_child ("Interop");
 
        _playlist->set_from_xml (shared_from_this(), f.node_child ("Playlist"));
 
@@ -381,8 +404,6 @@ Film::read_metadata ()
 string
 Film::dir (string d) const
 {
-       boost::mutex::scoped_lock lm (_directory_mutex);
-       
        boost::filesystem::path p;
        p /= _directory;
        p /= d;
@@ -393,14 +414,11 @@ Film::dir (string d) const
 }
 
 /** Given a file or directory name, return its full path within the Film's directory.
- *  _directory_mutex must not be locked on entry.
  *  Any required parent directories will be created.
  */
 string
 Film::file (string f) const
 {
-       boost::mutex::scoped_lock lm (_directory_mutex);
-
        boost::filesystem::path p;
        p /= _directory;
        p /= f;
@@ -432,6 +450,15 @@ Film::dci_name (bool if_created_now) const
 
        if (dcp_content_type()) {
                d << "_" << dcp_content_type()->dci_name();
+               d << "-" << dci_metadata().content_version;
+       }
+
+       if (three_d ()) {
+               d << "-3D";
+       }
+
+       if (video_frame_rate() != 24) {
+               d << "-" << video_frame_rate();
        }
 
        if (container()) {
@@ -456,7 +483,7 @@ Film::dci_name (bool if_created_now) const
                }
        }
 
-       switch (dcp_audio_channels ()) {
+       switch (audio_channels ()) {
        case 1:
                d << "_10";
                break;
@@ -515,7 +542,6 @@ Film::dcp_name (bool if_created_now) const
 void
 Film::set_directory (string d)
 {
-       boost::mutex::scoped_lock lm (_state_mutex);
        _directory = d;
        _dirty = true;
 }
@@ -523,126 +549,105 @@ Film::set_directory (string d)
 void
 Film::set_name (string n)
 {
-       {
-               boost::mutex::scoped_lock lm (_state_mutex);
-               _name = n;
-       }
+       _name = n;
        signal_changed (NAME);
 }
 
 void
 Film::set_use_dci_name (bool u)
 {
-       {
-               boost::mutex::scoped_lock lm (_state_mutex);
-               _use_dci_name = u;
-       }
+       _use_dci_name = u;
        signal_changed (USE_DCI_NAME);
 }
 
 void
 Film::set_dcp_content_type (DCPContentType const * t)
 {
-       {
-               boost::mutex::scoped_lock lm (_state_mutex);
-               _dcp_content_type = t;
-       }
+       _dcp_content_type = t;
        signal_changed (DCP_CONTENT_TYPE);
 }
 
 void
 Film::set_container (Ratio const * c)
 {
-       {
-               boost::mutex::scoped_lock lm (_state_mutex);
-               _container = c;
-       }
+       _container = c;
        signal_changed (CONTAINER);
 }
 
 void
 Film::set_resolution (Resolution r)
 {
-       {
-               boost::mutex::scoped_lock lm (_state_mutex);
-               _resolution = r;
-       }
+       _resolution = r;
        signal_changed (RESOLUTION);
 }
 
 void
 Film::set_scaler (Scaler const * s)
 {
-       {
-               boost::mutex::scoped_lock lm (_state_mutex);
-               _scaler = s;
-       }
+       _scaler = s;
        signal_changed (SCALER);
 }
 
 void
 Film::set_with_subtitles (bool w)
 {
-       {
-               boost::mutex::scoped_lock lm (_state_mutex);
-               _with_subtitles = w;
-       }
+       _with_subtitles = w;
        signal_changed (WITH_SUBTITLES);
 }
 
 void
 Film::set_j2k_bandwidth (int b)
 {
-       {
-               boost::mutex::scoped_lock lm (_state_mutex);
-               _j2k_bandwidth = b;
-       }
+       _j2k_bandwidth = b;
        signal_changed (J2K_BANDWIDTH);
 }
 
 void
 Film::set_dci_metadata (DCIMetadata m)
 {
-       {
-               boost::mutex::scoped_lock lm (_state_mutex);
-               _dci_metadata = m;
-       }
+       _dci_metadata = m;
        signal_changed (DCI_METADATA);
 }
 
 void
-Film::set_dcp_video_frame_rate (int f)
+Film::set_video_frame_rate (int f)
 {
-       {
-               boost::mutex::scoped_lock lm (_state_mutex);
-               _dcp_video_frame_rate = f;
-       }
-       signal_changed (DCP_VIDEO_FRAME_RATE);
+       _video_frame_rate = f;
+       signal_changed (VIDEO_FRAME_RATE);
 }
 
 void
-Film::set_dcp_audio_channels (int c)
+Film::set_audio_channels (int c)
 {
-       {
-               boost::mutex::scoped_lock lm (_state_mutex);
-               _dcp_audio_channels = c;
-       }
-       signal_changed (DCP_AUDIO_CHANNELS);
+       _audio_channels = c;
+       signal_changed (AUDIO_CHANNELS);
+}
+
+void
+Film::set_three_d (bool t)
+{
+       _three_d = t;
+       signal_changed (THREE_D);
+}
+
+void
+Film::set_interop (bool i)
+{
+       _interop = i;
+       signal_changed (INTEROP);
 }
 
 void
 Film::signal_changed (Property p)
 {
-       {
-               boost::mutex::scoped_lock lm (_state_mutex);
-               _dirty = true;
-       }
+       _dirty = true;
 
        switch (p) {
        case Film::CONTENT:
-               set_dcp_video_frame_rate (_playlist->best_dcp_frame_rate ());
+               set_video_frame_rate (_playlist->best_dcp_frame_rate ());
                break;
-       case Film::DCP_VIDEO_FRAME_RATE:
+       case Film::VIDEO_FRAME_RATE:
+       case Film::SEQUENCE_VIDEO:
                _playlist->maybe_sequence_video ();
                break;
        default:
@@ -661,15 +666,23 @@ Film::set_dci_date_today ()
 }
 
 string
-Film::info_path (int f) const
+Film::info_path (int f, Eyes e) const
 {
        boost::filesystem::path p;
        p /= info_dir ();
 
        stringstream s;
        s.width (8);
-       s << setfill('0') << f << ".md5";
+       s << setfill('0') << f;
+
+       if (e == EYES_LEFT) {
+               s << ".L";
+       } else if (e == EYES_RIGHT) {
+               s << ".R";
+       }
 
+       s << ".md5";
+       
        p /= s.str();
 
        /* info_dir() will already have added any initial bit of the path,
@@ -679,7 +692,7 @@ Film::info_path (int f) const
 }
 
 string
-Film::j2c_path (int f, bool t) const
+Film::j2c_path (int f, Eyes e, bool t) const
 {
        boost::filesystem::path p;
        p /= "j2c";
@@ -687,7 +700,15 @@ Film::j2c_path (int f, bool t) const
 
        stringstream s;
        s.width (8);
-       s << setfill('0') << f << ".j2c";
+       s << setfill('0') << f;
+
+       if (e == EYES_LEFT) {
+               s << ".L";
+       } else if (e == EYES_RIGHT) {
+               s << ".R";
+       }
+       
+       s << ".j2c";
 
        if (t) {
                s << ".tmp";
@@ -721,14 +742,20 @@ Film::make_player () const
        return shared_ptr<Player> (new Player (shared_from_this (), _playlist));
 }
 
+void
+Film::set_encrypted (bool e)
+{
+       _encrypted = e;
+       signal_changed (ENCRYPTED);
+}
+
 shared_ptr<Playlist>
 Film::playlist () const
 {
-       boost::mutex::scoped_lock lm (_state_mutex);
        return _playlist;
 }
 
-Playlist::ContentList
+ContentList
 Film::content () const
 {
        return _playlist->content ();
@@ -738,13 +765,18 @@ void
 Film::examine_and_add_content (shared_ptr<Content> c)
 {
        shared_ptr<Job> j (new ExamineContentJob (shared_from_this(), c));
-       j->Finished.connect (bind (&Film::add_content_weak, this, boost::weak_ptr<Content> (c)));
+       j->Finished.connect (bind (&Film::maybe_add_content, this, boost::weak_ptr<Job> (j), boost::weak_ptr<Content> (c)));
        JobManager::instance()->add (j);
 }
 
 void
-Film::add_content_weak (weak_ptr<Content> c)
+Film::maybe_add_content (weak_ptr<Job> j, weak_ptr<Content> c)
 {
+       shared_ptr<Job> job = j.lock ();
+       if (!job || !job->finished_ok ()) {
+               return;
+       }
+       
        shared_ptr<Content> content = c.lock ();
        if (content) {
                add_content (content);
@@ -756,7 +788,7 @@ Film::add_content (shared_ptr<Content> c)
 {
        /* Add video content after any existing content */
        if (dynamic_pointer_cast<VideoContent> (c)) {
-               c->set_start (_playlist->video_end ());
+               c->set_position (_playlist->video_end ());
        }
 
        _playlist->add (c);
@@ -781,7 +813,7 @@ Film::has_subtitles () const
 }
 
 OutputVideoFrame
-Film::best_dcp_video_frame_rate () const
+Film::best_video_frame_rate () const
 {
        return _playlist->best_dcp_frame_rate ();
 }
@@ -790,7 +822,7 @@ void
 Film::playlist_content_changed (boost::weak_ptr<Content> c, int p)
 {
        if (p == VideoContentProperty::VIDEO_FRAME_RATE) {
-               set_dcp_video_frame_rate (_playlist->best_dcp_frame_rate ());
+               set_video_frame_rate (_playlist->best_dcp_frame_rate ());
        } 
 
        if (ui_signaller) {
@@ -807,29 +839,29 @@ Film::playlist_changed ()
 OutputAudioFrame
 Film::time_to_audio_frames (Time t) const
 {
-       return t * dcp_audio_frame_rate () / TIME_HZ;
+       return t * audio_frame_rate () / TIME_HZ;
 }
 
 OutputVideoFrame
 Film::time_to_video_frames (Time t) const
 {
-       return t * dcp_video_frame_rate () / TIME_HZ;
+       return t * video_frame_rate () / TIME_HZ;
 }
 
 Time
 Film::audio_frames_to_time (OutputAudioFrame f) const
 {
-       return f * TIME_HZ / dcp_audio_frame_rate ();
+       return f * TIME_HZ / audio_frame_rate ();
 }
 
 Time
 Film::video_frames_to_time (OutputVideoFrame f) const
 {
-       return f * TIME_HZ / dcp_video_frame_rate ();
+       return f * TIME_HZ / video_frame_rate ();
 }
 
 OutputAudioFrame
-Film::dcp_audio_frame_rate () const
+Film::audio_frame_rate () const
 {
        /* XXX */
        return 48000;
@@ -838,7 +870,9 @@ Film::dcp_audio_frame_rate () const
 void
 Film::set_sequence_video (bool s)
 {
+       _sequence_video = s;
        _playlist->set_sequence_video (s);
+       signal_changed (SEQUENCE_VIDEO);
 }
 
 libdcp::Size
@@ -854,3 +888,71 @@ Film::full_frame () const
        assert (false);
        return libdcp::Size ();
 }
+
+void
+Film::make_kdms (
+       list<shared_ptr<Screen> > screens,
+       boost::posix_time::ptime from,
+       boost::posix_time::ptime until,
+       string directory
+       ) const
+{
+       string const cd = Config::instance()->crypt_chain_directory ();
+       if (boost::filesystem::is_empty (cd)) {
+               libdcp::make_crypt_chain (cd);
+       }
+
+       libdcp::CertificateChain chain;
+
+       {
+               boost::filesystem::path p (cd);
+               p /= "ca.self-signed.pem";
+               chain.add (shared_ptr<libdcp::Certificate> (new libdcp::Certificate (p.string ())));
+       }
+
+       {
+               boost::filesystem::path p (cd);
+               p /= "intermediate.signed.pem";
+               chain.add (shared_ptr<libdcp::Certificate> (new libdcp::Certificate (p.string ())));
+       }
+
+       {
+               boost::filesystem::path p (cd);
+               p /= "leaf.signed.pem";
+               chain.add (shared_ptr<libdcp::Certificate> (new libdcp::Certificate (p.string ())));
+       }
+
+       boost::filesystem::path signer_key (cd);
+       signer_key /= "leaf.key";
+
+       /* Find the DCP to make the KDM for */
+       string const dir = this->directory ();
+       list<string> dcps;
+       for (boost::filesystem::directory_iterator i = boost::filesystem::directory_iterator(dir); i != boost::filesystem::directory_iterator(); ++i) {
+               if (boost::filesystem::is_directory (*i) && i->path().leaf() != "j2c" && i->path().leaf() != "wavs") {
+                       dcps.push_back (i->path().string());
+               }
+       }
+
+       if (dcps.empty()) {
+               throw KDMError ("Could not find DCP to make KDM for");
+       } else if (dcps.size() > 1) {
+               throw KDMError ("More than one possible DCP to make KDM for");
+       }
+
+       for (list<shared_ptr<Screen> >::iterator i = screens.begin(); i != screens.end(); ++i) {
+
+               libdcp::DCP dcp (dcps.front ());
+               dcp.read ();
+               
+               /* XXX: single CPL only */
+               shared_ptr<xmlpp::Document> kdm = dcp.cpls().front()->make_kdm (
+                       chain, signer_key.string(), (*i)->certificate, from, until, _interop, libdcp::MXFMetadata (), Config::instance()->dcp_metadata ()
+                       );
+
+               boost::filesystem::path out = directory;
+               out /= "kdm.xml";
+               kdm->write_to_file_formatted (out.string());
+       }
+}
+