#include <functional>
#include <iostream>
#include <fstream>
+#include <boost/algorithm/string/replace.hpp>
namespace caspar { namespace env {
CASPAR_THROW_EXCEPTION(invalid_operation() << msg_info(L"Enviroment properties has not been configured"));
}
+std::wstring clean_path(std::wstring path)
+{
+ boost::replace_all(path, L"\\\\", L"/");
+ boost::replace_all(path, L"\\", L"/");
+
+ return path;
+}
+
+std::wstring ensure_trailing_slash(std::wstring folder)
+{
+ if (folder.at(folder.length() - 1) != L'/')
+ folder.append(L"/");
+
+ return folder;
+}
+
+std::wstring resolve_or_create(const std::wstring& folder)
+{
+ auto found_path = find_case_insensitive(folder);
+
+ if (found_path)
+ return *found_path;
+ else
+ {
+ boost::system::error_code ec;
+ boost::filesystem::create_directories(folder, ec);
+
+ if (ec)
+ CASPAR_THROW_EXCEPTION(user_error() << msg_info("Failed to create directory " + u8(folder) + " (" + ec.message() + ")"));
+
+ return folder;
+ }
+}
+
+void ensure_writable(const std::wstring& folder)
+{
+ static const std::wstring CREATE_FILE_TEST = L"casparcg_test_writable.empty";
+
+ boost::system::error_code ec;
+ boost::filesystem::path test_file(folder + L"/" + CREATE_FILE_TEST);
+ boost::filesystem::ofstream out(folder + L"/" + CREATE_FILE_TEST);
+
+ if (out.fail())
+ {
+ boost::filesystem::remove(test_file, ec);
+ CASPAR_THROW_EXCEPTION(user_error() << msg_info(L"Directory " + folder + L" is not writable."));
+ }
+
+ out.close();
+ boost::filesystem::remove(test_file, ec);
+}
+
void configure(const std::wstring& filename)
{
try
{
- initial = boost::filesystem::initial_path().wstring();
+ initial = clean_path(boost::filesystem::initial_path().wstring());
boost::filesystem::wifstream file(initial + L"/" + filename);
boost::property_tree::read_xml(file, pt, boost::property_tree::xml_parser::trim_whitespace | boost::property_tree::xml_parser::no_comments);
auto paths = pt.get_child(L"configuration.paths");
- media = paths.get(L"media-path", initial + L"/media/");
- log = paths.get(L"log-path", initial + L"/log/");
- ftemplate = boost::filesystem::complete(paths.get(L"template-path", initial + L"/template/")).wstring();
- data = paths.get(L"data-path", initial + L"/data/");
- font = paths.get(L"font-path", initial + L"/font/");
- thumbnails = paths.get(L"thumbnail-path", initial + L"/thumbnail/");
+ media = clean_path(paths.get(L"media-path", initial + L"/media/"));
+ log = clean_path(paths.get(L"log-path", initial + L"/log/"));
+ ftemplate = clean_path(boost::filesystem::complete(paths.get(L"template-path", initial + L"/template/")).wstring());
+ data = clean_path(paths.get(L"data-path", initial + L"/data/"));
+ font = clean_path(paths.get(L"font-path", initial + L"/font/"));
+ thumbnails = clean_path(paths.get(L"thumbnail-path", initial + L"/thumbnail/"));
}
- catch(...)
+ catch (...)
{
CASPAR_LOG(error) << L" ### Invalid configuration file. ###";
throw;
}
- try
- {
- auto found_media_path = find_case_insensitive(media);
- if (found_media_path)
- media = *found_media_path;
- else
- boost::filesystem::create_directories(media);
-
- auto found_template_path = find_case_insensitive(ftemplate);
- if (found_template_path)
- ftemplate = *found_template_path;
- else
- boost::filesystem::create_directories(ftemplate);
-
- auto found_data_path = find_case_insensitive(data);
- if (found_data_path)
- data = *found_data_path;
- else
- boost::filesystem::create_directories(data);
-
- auto found_font_path = find_case_insensitive(font);
- if (found_font_path)
- font = *found_font_path;
- else
- boost::filesystem::create_directories(font);
-
- auto found_thumbnails_path = find_case_insensitive(thumbnails);
- if (found_thumbnails_path)
- thumbnails = *found_thumbnails_path;
- else
- boost::filesystem::create_directories(thumbnails);
-
- auto found_log_path = find_case_insensitive(log);
- if (found_log_path)
- log = *found_log_path;
- else if (!boost::filesystem::create_directories(log))
- log = L"./";
-
- //Make sure that all paths have a trailing slash
- if(media.at(media.length()-1) != L'/')
- media.append(L"/");
- if(log.at(log.length()-1) != L'/')
- log.append(L"/");
- if(ftemplate.at(ftemplate.length()-1) != L'/')
- ftemplate.append(L"/");
- if(data.at(data.length()-1) != L'/')
- data.append(L"/");
- if(font.at(font.length()-1) != L'/')
- font.append(L"/");
- if(thumbnails.at(thumbnails.length()-1) != L'/')
- thumbnails.append(L"/");
- }
- catch(...)
- {
- CASPAR_LOG_CURRENT_EXCEPTION();
- CASPAR_LOG(error) << L"Failed to create configured directories.";
- }
+ media = ensure_trailing_slash(resolve_or_create(media));
+ log = ensure_trailing_slash(resolve_or_create(log));
+ ftemplate = ensure_trailing_slash(resolve_or_create(ftemplate));
+ data = ensure_trailing_slash(resolve_or_create(data));
+ font = ensure_trailing_slash(resolve_or_create(font));
+ thumbnails = ensure_trailing_slash(resolve_or_create(thumbnails));
+
+ ensure_writable(log);
+ ensure_writable(ftemplate);
+ ensure_writable(data);
+ ensure_writable(thumbnails);
}
const std::wstring& initial_folder()
* Author: Robert Nagy, ronag89@gmail.com
*/
-// tbbmalloc_proxy:
-// Replace the standard memory allocation routines in Microsoft* C/C++ RTL
-// (malloc/free, global new/delete, etc.) with the TBB memory allocator.
+// tbbmalloc_proxy:
+// Replace the standard memory allocation routines in Microsoft* C/C++ RTL
+// (malloc/free, global new/delete, etc.) with the TBB memory allocator.
#include "stdafx.h"
#include <clocale>
using namespace caspar;
-
+
void setup_global_locale()
{
boost::locale::generator gen;
while(true)
{
std::getline(std::wcin, wcmd); // TODO: It's blocking...
-
+
//boost::to_upper(wcmd);
if(boost::iequals(wcmd, L"EXIT") || boost::iequals(wcmd, L"Q") || boost::iequals(wcmd, L"QUIT") || boost::iequals(wcmd, L"BYE"))
else if(wcmd.substr(0, 1) == L"5")
{
auto file = wcmd.substr(2, wcmd.length()-1);
- wcmd = L"PLAY 1-1 " + file + L" LOOP\r\n"
- L"PLAY 1-2 " + file + L" LOOP\r\n"
+ wcmd = L"PLAY 1-1 " + file + L" LOOP\r\n"
+ L"PLAY 1-2 " + file + L" LOOP\r\n"
L"PLAY 1-3 " + file + L" LOOP\r\n"
- L"PLAY 2-1 " + file + L" LOOP\r\n"
- L"PLAY 2-2 " + file + L" LOOP\r\n"
+ L"PLAY 2-1 " + file + L" LOOP\r\n"
+ L"PLAY 2-2 " + file + L" LOOP\r\n"
L"PLAY 2-3 " + file + L" LOOP\r\n";
}
else if(wcmd.substr(0, 1) == L"7")
boost::property_tree::xml_writer_settings<std::wstring> w(' ', 3);
boost::property_tree::write_xml(str, env::properties(), w);
CASPAR_LOG(info) << config_file_name << L":\n-----------------------------------------\n" << str.str() << L"-----------------------------------------";
-
+
{
CASPAR_SCOPED_CONTEXT_MSG(config_file_name + L": ")
caspar_server->start();
caspar_server->get_amcp_command_repository())))->create(console_client);
std::weak_ptr<IO::protocol_strategy<wchar_t>> weak_amcp = amcp;
- // Use separate thread for the blocking console input, will be terminated
+ // Use separate thread for the blocking console input, will be terminated
// anyway when the main thread terminates.
boost::thread stdin_thread(std::bind(do_run, weak_amcp, std::ref(shutdown_server_now), std::ref(should_wait_for_keypress))); //compiler didn't like lambda here...
stdin_thread.detach();
setup_global_locale();
std::wcout << L"Type \"q\" to close application." << std::endl;
-
+
// Set debug mode.
auto debugging_environment = setup_debugging_environment();
tbb::task_scheduler_init init;
std::wstring config_file_name(L"casparcg.config");
-
- try
+
+ try
{
// Configure environment properties from configuration.
if (argc >= 2)
log::add_file_sink(env::log_folder() + L"caspar", caspar::log::category != caspar::log::log_category::calltrace);
log::add_file_sink(env::log_folder() + L"calltrace", caspar::log::category == caspar::log::log_category::calltrace);
std::wcout << L"Logging [info] or higher severity to " << env::log_folder() << std::endl << std::endl;
-
+
// Setup console window.
setup_console_window();
if (thread->name != "main thread" && thread->name != "tbb-worker-thread")
CASPAR_LOG(warning) << L"Thread left running: " << thread->name << L" (" << thread->native_id << L")";
}
-
+
CASPAR_LOG(info) << "Successfully shutdown CasparCG Server.";
if (should_wait_for_keypress)
}
catch(const boost::property_tree::file_parser_error& e)
{
- CASPAR_LOG_CURRENT_EXCEPTION();
CASPAR_LOG(fatal) << "At " << u8(config_file_name) << ":" << e.line() << ": " << e.message() << ". Please check the configuration file (" << u8(config_file_name) << ") for errors.";
wait_for_keypress();
}
catch (const user_error& e)
{
- CASPAR_LOG_CURRENT_EXCEPTION_AT_LEVEL(debug);
CASPAR_LOG(fatal) << get_message_and_context(e) << " Please check the configuration file (" << u8(config_file_name) << ") for errors. Turn on log level debug for stacktrace.";
wait_for_keypress();
}
projects / casparcg / commitdiff