X-Git-Url: https://git.carlh.net/gitweb/?p=dcpomatic.git;a=blobdiff_plain;f=src%2Flib%2Fkdm_with_metadata.cc;h=bebb5df86d0b44f6af12a2c5f371d2e2620eed6e;hp=fbd2e4bd49e7d417849159c46653a67c978d2416;hb=f1b2884943ab6fd1e3ba37b017d41b65645f49dc;hpb=3339d3bce70afe9ae2ca10e9fcfc4b54b748fbf4 diff --git a/src/lib/kdm_with_metadata.cc b/src/lib/kdm_with_metadata.cc index fbd2e4bd4..bebb5df86 100644 --- a/src/lib/kdm_with_metadata.cc +++ b/src/lib/kdm_with_metadata.cc @@ -19,26 +19,27 @@ */ -#include "kdm_with_metadata.h" #include "cinema.h" -#include "screen.h" -#include "util.h" -#include "zipper.h" #include "config.h" +#include "cross.h" #include "dcpomatic_log.h" #include "emailer.h" -#include -#include +#include "kdm_with_metadata.h" +#include "screen.h" +#include "util.h" +#include "zipper.h" +#include #include "i18n.h" -using std::string; using std::cout; +using std::function; using std::list; using std::shared_ptr; +using std::string; +using std::vector; using boost::optional; -using boost::function; int @@ -46,7 +47,7 @@ write_files ( list kdms, boost::filesystem::path directory, dcp::NameFormat name_format, - boost::function confirm_overwrite + std::function confirm_overwrite ) { int written = 0; @@ -67,7 +68,7 @@ write_files ( /* Write KDMs to the specified directory */ for (auto i: kdms) { - auto out = directory / careful_string_filter(name_format.get(i->name_values(), ".xml")); + auto out = dcp::fix_long_path(directory / careful_string_filter(name_format.get(i->name_values(), ".xml"))); if (!boost::filesystem::exists (out) || confirm_overwrite (out)) { i->kdm_as_xml (out); ++written; @@ -146,14 +147,14 @@ write_directories ( { int written = 0; - for (auto const& i: kdms) { - boost::filesystem::path path = directory; - path /= container_name_format.get(i.front()->name_values(), "", "s"); + for (auto const& kdm: kdms) { + auto path = directory; + path /= container_name_format.get(kdm.front()->name_values(), "", "s"); if (!boost::filesystem::exists (path) || confirm_overwrite (path)) { boost::filesystem::create_directories (path); - write_files (i, path, filename_format, confirm_overwrite); + write_files(kdm, path, filename_format, confirm_overwrite); } - written += i.size(); + written += kdm.size(); } return written; @@ -172,16 +173,16 @@ write_zip_files ( { int written = 0; - for (auto const& i: kdms) { + for (auto const& kdm: kdms) { auto path = directory; - path /= container_name_format.get(i.front()->name_values(), ".zip", "s"); + path /= container_name_format.get(kdm.front()->name_values(), ".zip", "s"); if (!boost::filesystem::exists (path) || confirm_overwrite (path)) { if (boost::filesystem::exists (path)) { /* Creating a new zip file over an existing one is an error */ boost::filesystem::remove (path); } - make_zip_file (i, path, filename_format); - written += i.size(); + make_zip_file(kdm, path, filename_format); + written += kdm.size(); } } @@ -197,11 +198,12 @@ write_zip_files ( * @param cpl_name Name of the CPL that the KDMs are for. */ void -email ( +send_emails ( list> kdms, dcp::NameFormat container_name_format, dcp::NameFormat filename_format, - string cpl_name + string cpl_name, + vector extra_addresses ) { auto config = Config::instance (); @@ -210,65 +212,87 @@ email ( throw NetworkError (_("No mail server configured in preferences")); } - for (auto const& i: kdms) { + if (config->kdm_from().empty()) { + throw NetworkError(_("No KDM from address configured in preferences")); + } + + for (auto const& kdms_for_cinema: kdms) { + + auto first = kdms_for_cinema.front(); - if (i.front()->emails().empty()) { + if (first->emails().empty()) { continue; } auto zip_file = boost::filesystem::temp_directory_path() / boost::filesystem::unique_path(); boost::filesystem::create_directories (zip_file); - zip_file /= container_name_format.get(i.front()->name_values(), ".zip"); - make_zip_file (i, zip_file, filename_format); + zip_file /= container_name_format.get(first->name_values(), ".zip"); + make_zip_file (kdms_for_cinema, zip_file, filename_format); - auto subject = config->kdm_subject(); - boost::algorithm::replace_all (subject, "$CPL_NAME", cpl_name); - boost::algorithm::replace_all (subject, "$START_TIME", i.front()->get('b').get_value_or("")); - boost::algorithm::replace_all (subject, "$END_TIME", i.front()->get('e').get_value_or("")); - boost::algorithm::replace_all (subject, "$CINEMA_NAME", i.front()->get('c').get_value_or("")); + auto substitute_variables = [cpl_name, first](string target) { + boost::algorithm::replace_all(target, "$CPL_NAME", cpl_name); + boost::algorithm::replace_all(target, "$START_TIME", first->get('b').get_value_or("")); + boost::algorithm::replace_all(target, "$END_TIME", first->get('e').get_value_or("")); + boost::algorithm::replace_all(target, "$CINEMA_NAME", first->get('c').get_value_or("")); + boost::algorithm::replace_all(target, "$CINEMA_SHORT_NAME", first->get('c').get_value_or("").substr(0, 14)); + return target; + }; - auto body = config->kdm_email(); - boost::algorithm::replace_all (body, "$CPL_NAME", cpl_name); - boost::algorithm::replace_all (body, "$START_TIME", i.front()->get('b').get_value_or("")); - boost::algorithm::replace_all (body, "$END_TIME", i.front()->get('e').get_value_or("")); - boost::algorithm::replace_all (body, "$CINEMA_NAME", i.front()->get('c').get_value_or("")); + auto subject = substitute_variables(config->kdm_subject()); + auto body = substitute_variables(config->kdm_email()); string screens; - for (auto j: i) { - auto screen_name = j->get('n'); + for (auto kdm: kdms_for_cinema) { + auto screen_name = kdm->get('s'); if (screen_name) { screens += *screen_name + ", "; } } boost::algorithm::replace_all (body, "$SCREENS", screens.substr (0, screens.length() - 2)); - Emailer email (config->kdm_from(), i.front()->emails(), subject, body); + Emailer email (config->kdm_from(), first->emails(), subject, body); - for (auto i: config->kdm_cc()) { - email.add_cc (i); + for (auto cc: config->kdm_cc()) { + email.add_cc (cc); } if (!config->kdm_bcc().empty()) { email.add_bcc (config->kdm_bcc()); } - email.add_attachment (zip_file, container_name_format.get(i.front()->name_values(), ".zip"), "application/zip"); + email.add_attachment (zip_file, container_name_format.get(first->name_values(), ".zip"), "application/zip"); + + auto log_details = [](Emailer& email) { + dcpomatic_log->log("Email content follows", LogEntry::TYPE_DEBUG_EMAIL); + dcpomatic_log->log(email.email(), LogEntry::TYPE_DEBUG_EMAIL); + dcpomatic_log->log("Email session follows", LogEntry::TYPE_DEBUG_EMAIL); + dcpomatic_log->log(email.notes(), LogEntry::TYPE_DEBUG_EMAIL); + }; try { email.send (config->mail_server(), config->mail_port(), config->mail_protocol(), config->mail_user(), config->mail_password()); } catch (...) { boost::filesystem::remove (zip_file); - dcpomatic_log->log ("Email content follows", LogEntry::TYPE_DEBUG_EMAIL); - dcpomatic_log->log (email.email(), LogEntry::TYPE_DEBUG_EMAIL); - dcpomatic_log->log ("Email session follows", LogEntry::TYPE_DEBUG_EMAIL); - dcpomatic_log->log (email.notes(), LogEntry::TYPE_DEBUG_EMAIL); + log_details (email); throw; } - boost::filesystem::remove (zip_file); + log_details (email); + + for (auto extra: extra_addresses) { + Emailer email (config->kdm_from(), { extra }, subject, body); + email.add_attachment (zip_file, container_name_format.get(first->name_values(), ".zip"), "application/zip"); - dcpomatic_log->log ("Email content follows", LogEntry::TYPE_DEBUG_EMAIL); - dcpomatic_log->log (email.email(), LogEntry::TYPE_DEBUG_EMAIL); - dcpomatic_log->log ("Email session follows", LogEntry::TYPE_DEBUG_EMAIL); - dcpomatic_log->log (email.notes(), LogEntry::TYPE_DEBUG_EMAIL); + try { + email.send (config->mail_server(), config->mail_port(), config->mail_protocol(), config->mail_user(), config->mail_password()); + } catch (...) { + boost::filesystem::remove (zip_file); + log_details (email); + throw; + } + + log_details (email); + } + + boost::filesystem::remove (zip_file); } }