X-Git-Url: https://git.sesse.net/?a=blobdiff_plain;f=protocol%2Famcp%2FAMCPCommandsImpl.cpp;h=51a7aadeeaae09feaaa67bb6bcbe18ee194a0d5b;hb=5ba0a0e8202add441bc7b7c16450faf0f7deea08;hp=11b6032816fb479fd11aa5c2e8a58fa85bdd5fa1;hpb=9e37e91c3195f5baaa0c63b5894e9c7b70797b2a;p=casparcg diff --git a/protocol/amcp/AMCPCommandsImpl.cpp b/protocol/amcp/AMCPCommandsImpl.cpp index 11b603281..51a7aadee 100644 --- a/protocol/amcp/AMCPCommandsImpl.cpp +++ b/protocol/amcp/AMCPCommandsImpl.cpp @@ -25,15 +25,21 @@ #include +#include + #include #include -#include -#include -#include #include - #include #include +#include +#include +#include +#include + +#include +#include +#include #include #include @@ -86,10 +92,13 @@ std::wstring ListMedia() { std::wstring clipttype = TEXT(" N/A "); std::wstring extension = boost::to_upper_copy(itr->path().extension()); - if(extension == TEXT(".TGA") || extension == TEXT(".COL")) + if(extension == TEXT(".TGA") || extension == TEXT(".COL") || extension == L".PNG" || extension == L".JPEG" || extension == L".JPG" || + extension == L"GIF" || extension == L"BMP") clipttype = TEXT(" STILL "); else if(extension == TEXT(".SWF") || extension == TEXT(".DV") || extension == TEXT(".MOV") || extension == TEXT(".MPG") || - extension == TEXT(".AVI") || extension == TEXT(".FLV") || extension == TEXT(".F4V") || extension == TEXT(".MP4")) + extension == TEXT(".AVI") || extension == TEXT(".FLV") || extension == TEXT(".F4V") || extension == TEXT(".MP4") || + extension == L".M2V" || extension == L".H264" || extension == L".MKV" || extension == L".WMV" || extension == L".DIVX" || + extension == L".XVID" || extension == L".OGG") clipttype = TEXT(" MOVIE "); else if(extension == TEXT(".WAV") || extension == TEXT(".MP3")) clipttype = TEXT(" STILL "); @@ -107,12 +116,16 @@ std::wstring ListMedia() auto sizeStr = boost::lexical_cast(boost::filesystem::file_size(itr->path())); sizeStr.erase(std::remove_if(sizeStr.begin(), sizeStr.end(), is_not_digit), sizeStr.end()); auto sizeWStr = std::wstring(sizeStr.begin(), sizeStr.end()); + + auto str = relativePath.replace_extension(TEXT("")).external_file_string(); + if(str[0] == '\\' || str[0] == '/') + str = std::wstring(str.begin() + 1, str.end()); - replyString << TEXT("\"") << relativePath.replace_extension(TEXT("")) + replyString << TEXT("\"") << str << TEXT("\" ") << clipttype << TEXT(" ") << sizeStr << TEXT(" ") << writeTimeWStr - << TEXT("\r\n"); + << TEXT("\r\n"); } } } @@ -137,14 +150,22 @@ std::wstring ListTemplates() sizeStr.erase(std::remove_if(sizeStr.begin(), sizeStr.end(), [](char c){ return std::isdigit(c) == 0;}), sizeStr.end()); auto sizeWStr = std::wstring(sizeStr.begin(), sizeStr.end()); - - replyString << TEXT("\"") << relativePath.replace_extension(TEXT("")) + + std::wstring dir = relativePath.parent_path().external_directory_string(); + std::wstring file = boost::to_upper_copy(relativePath.filename()); + relativePath = boost::filesystem::wpath(dir + L"/" + file); + + auto str = relativePath.replace_extension(TEXT("")).external_file_string(); + if(str[0] == '\\' || str[0] == '/') + str = std::wstring(str.begin() + 1, str.end()); + + replyString << TEXT("\"") << str << TEXT("\" ") << sizeWStr << TEXT(" ") << writeTimeWStr << TEXT("\r\n"); } } - return boost::to_upper_copy(replyString.str()); + return replyString.str(); } namespace amcp { @@ -164,12 +185,37 @@ void AMCPCommand::SendReply() void AMCPCommand::Clear() { - pChannel_->producer()->clear(); + pChannel_->stage()->clear(); pClientInfo_.reset(); channelIndex_ = 0; _parameters.clear(); } +bool ParamCommand::DoExecute() +{ + //Perform loading of the clip + try + { + auto what = _parameters.at(2); + if(what == L"B") + GetChannel()->stage()->background(GetLayerIndex()).get()->param(_parameters.at(3)); + else if(what == L"F") + GetChannel()->stage()->foreground(GetLayerIndex()).get()->param(_parameters.at(3)); + + CASPAR_LOG(info) << "Executed param: " << _parameters[0] << TEXT(" successfully"); + + SetReplyString(TEXT("202 PARAM OK\r\n")); + + return true; + } + catch(...) + { + CASPAR_LOG_CURRENT_EXCEPTION(); + SetReplyString(TEXT("502 PARAM FAILED\r\n")); + return false; + } +} + bool MixerCommand::DoExecute() { //Perform loading of the clip @@ -177,47 +223,38 @@ bool MixerCommand::DoExecute() { if(_parameters[0] == L"VIDEO") { - if(_parameters[1] == L"OPACITY") + if(_parameters[1] == L"IS_KEY") { - int duration = _parameters.size() > 2 ? lexical_cast_or_default(_parameters[3], 0) : 0; - std::wstring tween = _parameters.size() > 3 ? _parameters[4] : L"linear"; - - double value = boost::lexical_cast(_parameters.at(2)); - + bool value = lexical_cast_or_default(_parameters.at(2), false); auto transform = [=](image_transform transform) -> image_transform { - transform.set_opacity(value); + transform.set_is_key(value); return transform; }; - int layer = GetLayerIndex(std::numeric_limits::min()); - if(layer != std::numeric_limits::min()) - GetChannel()->mixer()->apply_image_transform(GetLayerIndex(), transform, duration, tween); - else - GetChannel()->mixer()->apply_image_transform(transform, duration, tween); + int layer = GetLayerIndex(); + GetChannel()->mixer()->apply_image_transform(GetLayerIndex(), transform); } - else if(_parameters[1] == L"GAIN") + else if(_parameters[1] == L"OPACITY") { - int duration = _parameters.size() > 2 ? lexical_cast_or_default(_parameters[3], 0) : 0; - std::wstring tween = _parameters.size() > 3 ? _parameters[4] : L"linear"; + int duration = _parameters.size() > 3 ? lexical_cast_or_default(_parameters[3], 0) : 0; + std::wstring tween = _parameters.size() > 4 ? _parameters[4] : L"linear"; + double value = boost::lexical_cast(_parameters.at(2)); - + auto transform = [=](image_transform transform) -> image_transform { - transform.set_gain(value); + transform.set_opacity(value); return transform; }; - int layer = GetLayerIndex(std::numeric_limits::min()); - if(layer != std::numeric_limits::min()) - GetChannel()->mixer()->apply_image_transform(GetLayerIndex(), transform, duration, tween); - else - GetChannel()->mixer()->apply_image_transform(transform, duration, tween); + int layer = GetLayerIndex(); + GetChannel()->mixer()->apply_image_transform(GetLayerIndex(), transform, duration, tween); } else if(_parameters[1] == L"FILL_RECT") { - int duration = _parameters.size() > 5 ? lexical_cast_or_default(_parameters[6], 0) : 0; - std::wstring tween = _parameters.size() > 6 ? _parameters[7] : L"linear"; + int duration = _parameters.size() > 6 ? lexical_cast_or_default(_parameters[6], 0) : 0; + std::wstring tween = _parameters.size() > 7 ? _parameters[7] : L"linear"; double x = boost::lexical_cast(_parameters.at(2)); double y = boost::lexical_cast(_parameters.at(3)); double x_s = boost::lexical_cast(_parameters.at(4)); @@ -227,21 +264,18 @@ bool MixerCommand::DoExecute() { transform.set_fill_translation(x, y); transform.set_fill_scale(x_s, y_s); - transform.set_key_translation(x, y); - transform.set_key_scale(x_s, y_s); + transform.set_clip_translation(x, y); + transform.set_clip_scale(x_s, y_s); return transform; }; - - int layer = GetLayerIndex(std::numeric_limits::min()); - if(layer != std::numeric_limits::min()) - GetChannel()->mixer()->apply_image_transform(GetLayerIndex(), transform, duration, tween); - else - GetChannel()->mixer()->apply_image_transform(transform, duration, tween); + + int layer = GetLayerIndex(); + GetChannel()->mixer()->apply_image_transform(GetLayerIndex(), transform, duration, tween); } - else if(_parameters[1] == L"KEY_RECT") + else if(_parameters[1] == L"CLIP_RECT") { - int duration = _parameters.size() > 5 ? lexical_cast_or_default(_parameters[6], 0) : 0; - std::wstring tween = _parameters.size() > 6 ? _parameters[7] : L"linear"; + int duration = _parameters.size() > 6 ? lexical_cast_or_default(_parameters[6], 0) : 0; + std::wstring tween = _parameters.size() > 7 ? _parameters[7] : L"linear"; double x = boost::lexical_cast(_parameters.at(2)); double y = boost::lexical_cast(_parameters.at(3)); double x_s = boost::lexical_cast(_parameters.at(4)); @@ -249,21 +283,18 @@ bool MixerCommand::DoExecute() auto transform = [=](image_transform transform) -> image_transform { - transform.set_key_translation(x, y); - transform.set_key_scale(x_s, y_s); + transform.set_clip_translation(x, y); + transform.set_clip_scale(x_s, y_s); return transform; }; - - int layer = GetLayerIndex(std::numeric_limits::min()); - if(layer != std::numeric_limits::min()) - GetChannel()->mixer()->apply_image_transform(GetLayerIndex(), transform, duration, tween); - else - GetChannel()->mixer()->apply_image_transform(transform, duration, tween); + + int layer = GetLayerIndex(); + GetChannel()->mixer()->apply_image_transform(GetLayerIndex(), transform, duration, tween); } else if(_parameters[1] == L"GRID") { - int duration = _parameters.size() > 2 ? lexical_cast_or_default(_parameters[3], 0) : 0; - std::wstring tween = _parameters.size() > 3 ? _parameters[4] : L"linear"; + int duration = _parameters.size() > 3 ? lexical_cast_or_default(_parameters[3], 0) : 0; + std::wstring tween = _parameters.size() > 4 ? _parameters[4] : L"linear"; int n = boost::lexical_cast(_parameters.at(2)); double delta = 1.0/static_cast(n); for(int x = 0; x < n; ++x) @@ -275,32 +306,104 @@ bool MixerCommand::DoExecute() { transform.set_fill_translation(x*delta, y*delta); transform.set_fill_scale(delta, delta); - transform.set_key_translation(x*delta, y*delta); - transform.set_key_scale(delta, delta); + transform.set_clip_translation(x*delta, y*delta); + transform.set_clip_scale(delta, delta); return transform; }; GetChannel()->mixer()->apply_image_transform(index, transform, duration, tween); } } } + else if(_parameters[1] == L"BLEND") + { + auto blend_str = _parameters.at(2); + + auto transform = [=](image_transform transform) -> image_transform + { + transform.set_blend_mode(get_blend_mode(blend_str)); + return transform; + }; + + int layer = GetLayerIndex(); + GetChannel()->mixer()->apply_image_transform(GetLayerIndex(), transform); + } + else if(_parameters[1] == L"BRIGHTNESS") + { + auto value = boost::lexical_cast(_parameters.at(2)); + int duration = _parameters.size() > 3 ? lexical_cast_or_default(_parameters[3], 0) : 0; + std::wstring tween = _parameters.size() > 4 ? _parameters[4] : L"linear"; + auto transform = [=](image_transform transform) -> image_transform + { + transform.set_brightness(value); + return transform; + }; + + int layer = GetLayerIndex(); + GetChannel()->mixer()->apply_image_transform(GetLayerIndex(), transform, duration, tween); + } + else if(_parameters[1] == L"SATURATION") + { + auto value = boost::lexical_cast(_parameters.at(2)); + int duration = _parameters.size() > 3 ? lexical_cast_or_default(_parameters[3], 0) : 0; + std::wstring tween = _parameters.size() > 4 ? _parameters[4] : L"linear"; + auto transform = [=](image_transform transform) -> image_transform + { + transform.set_saturation(value); + return transform; + }; + + int layer = GetLayerIndex(); + GetChannel()->mixer()->apply_image_transform(GetLayerIndex(), transform, duration, tween); + } + else if(_parameters[1] == L"CONTRAST") + { + auto value = boost::lexical_cast(_parameters.at(2)); + int duration = _parameters.size() > 3 ? lexical_cast_or_default(_parameters[3], 0) : 0; + std::wstring tween = _parameters.size() > 4 ? _parameters[4] : L"linear"; + auto transform = [=](image_transform transform) -> image_transform + { + transform.set_contrast(value); + return transform; + }; + + int layer = GetLayerIndex(); + GetChannel()->mixer()->apply_image_transform(GetLayerIndex(), transform, duration, tween); + } + else if(_parameters[1] == L"LEVELS") + { + image_transform::levels value; + value.min_input = boost::lexical_cast(_parameters.at(2)); + value.max_input = boost::lexical_cast(_parameters.at(3)); + value.gamma = boost::lexical_cast(_parameters.at(4)); + value.min_output = boost::lexical_cast(_parameters.at(5)); + value.max_output = boost::lexical_cast(_parameters.at(6)); + int duration = _parameters.size() > 7 ? lexical_cast_or_default(_parameters[7], 0) : 0; + std::wstring tween = _parameters.size() > 8 ? _parameters[8] : L"linear"; + + auto transform = [=](image_transform transform) -> image_transform + { + transform.set_levels(value); + return transform; + }; + + int layer = GetLayerIndex(); + GetChannel()->mixer()->apply_image_transform(GetLayerIndex(), transform, duration, tween); + } else if(_parameters[1] == L"RESET") { - int duration = _parameters.size() > 1 ? lexical_cast_or_default(_parameters[2], 0) : 0; - std::wstring tween = _parameters.size() > 2 ? _parameters[3] : L"linear"; - - int layer = GetLayerIndex(std::numeric_limits::min()); - if(layer != std::numeric_limits::min()) - GetChannel()->mixer()->reset_image_transform(GetLayerIndex(), duration, tween); - else - GetChannel()->mixer()->reset_image_transform(duration, tween); + int duration = _parameters.size() > 2 ? lexical_cast_or_default(_parameters[2], 0) : 0; + std::wstring tween = _parameters.size() > 3 ? _parameters[3] : L"linear"; + + int layer = GetLayerIndex(); + GetChannel()->mixer()->set_image_transform(GetLayerIndex(), image_transform(), duration, tween); } } else if(_parameters[0] == L"AUDIO") { if(_parameters[1] == L"GAIN") { - int duration = _parameters.size() > 2 ? lexical_cast_or_default(_parameters[3], 0) : 0; - std::wstring tween = _parameters.size() > 3 ? _parameters[4] : L"linear"; + int duration = _parameters.size() > 3 ? lexical_cast_or_default(_parameters[3], 0) : 0; + std::wstring tween = _parameters.size() > 4 ? _parameters[4] : L"linear"; double value = boost::lexical_cast(_parameters[2]); auto transform = [=](audio_transform transform) -> audio_transform @@ -309,25 +412,21 @@ bool MixerCommand::DoExecute() return transform; }; - int layer = GetLayerIndex(std::numeric_limits::min()); - if(layer != std::numeric_limits::min()) - GetChannel()->mixer()->apply_audio_transform(GetLayerIndex(), transform, duration, tween); - else - GetChannel()->mixer()->apply_audio_transform(transform, duration, tween); + int layer = GetLayerIndex(); + GetChannel()->mixer()->apply_audio_transform(GetLayerIndex(), transform, duration, tween); } else if(_parameters[1] == L"RESET") { - int duration = _parameters.size() > 1 ? lexical_cast_or_default(_parameters[2], 0) : 0; - std::wstring tween = _parameters.size() > 2 ? _parameters[3] : L"linear"; - GetChannel()->mixer()->reset_audio_transform(duration, tween); + int duration = _parameters.size() > 2 ? lexical_cast_or_default(_parameters[2], 0) : 0; + std::wstring tween = _parameters.size() > 3 ? _parameters[3] : L"linear"; + + int layer = GetLayerIndex(); + GetChannel()->mixer()->set_audio_transform(GetLayerIndex(), audio_transform(), duration, tween); } } else if(_parameters[0] == L"RESET") { - int duration = _parameters.size() > 1 ? lexical_cast_or_default(_parameters[2], 0) : 0; - std::wstring tween = _parameters.size() > 2 ? _parameters[3] : L"linear"; - GetChannel()->mixer()->reset_image_transform(duration, tween); - GetChannel()->mixer()->reset_audio_transform(duration, tween); + GetChannel()->mixer()->reset_transforms(); } SetReplyString(TEXT("202 MIXER OK\r\n")); @@ -364,13 +463,13 @@ bool SwapCommand::DoExecute() int l1 = GetLayerIndex(); int l2 = boost::lexical_cast(strs.at(1)); - ch1->producer()->swap_layer(l1, l2, *ch2->producer()); + ch1->stage()->swap_layer(l1, l2, *ch2->stage()); } else { auto ch1 = GetChannel(); auto ch2 = GetChannels().at(boost::lexical_cast(_parameters[0])-1); - ch1->producer()->swap(*ch2->producer()); + ch1->stage()->swap(*ch2->stage()); } CASPAR_LOG(info) << "Swapped successfully"; @@ -398,7 +497,7 @@ bool AddCommand::DoExecute() //Perform loading of the clip try { - GetChannel()->consumer()->add(GetLayerIndex(), create_consumer(_parameters)); + GetChannel()->output()->add(GetLayerIndex(), create_consumer(_parameters)); CASPAR_LOG(info) << "Added " << _parameters[0] << TEXT(" successfully"); @@ -425,7 +524,7 @@ bool RemoveCommand::DoExecute() //Perform loading of the clip try { - GetChannel()->consumer()->remove(GetLayerIndex()); + GetChannel()->output()->remove(GetLayerIndex()); SetReplyString(TEXT("202 REMOVE OK\r\n")); @@ -452,7 +551,7 @@ bool LoadCommand::DoExecute() { _parameters[0] = _parameters[0]; auto pFP = create_producer(GetChannel()->mixer(), _parameters); - GetChannel()->producer()->load(GetLayerIndex(), pFP, true); + GetChannel()->stage()->load(GetLayerIndex(), pFP, true); CASPAR_LOG(info) << "Loaded " << _parameters[0] << TEXT(" successfully"); @@ -478,7 +577,7 @@ bool LoadCommand::DoExecute() //std::function channel_cg_add_command::parse(const std::wstring& message, const std::vector& channels) //{ -// static boost::wregex expr(L"^CG\\s(?\\d+)-?(?\\d+)?\\sADD\\s(?\\d+)\\s(?