]> git.sesse.net Git - casparcg/blobdiff - protocol/cii/CIICommandsImpl.cpp
Merge branch '2.1.0' of https://github.com/CasparCG/Server into 2.1.0
[casparcg] / protocol / cii / CIICommandsImpl.cpp
index 306e6b60ad5852d3037557f9a1c4ea31531ef548..30f24252bfdee648f067cacd56d62bcb4365efc8 100644 (file)
-/*\r
-* Copyright (c) 2011 Sveriges Television AB <info@casparcg.com>\r
-*\r
-* This file is part of CasparCG (www.casparcg.com).\r
-*\r
-* CasparCG is free software: you can redistribute it and/or modify\r
-* it under the terms of the GNU General Public License as published by\r
-* the Free Software Foundation, either version 3 of the License, or\r
-* (at your option) any later version.\r
-*\r
-* CasparCG is distributed in the hope that it will be useful,\r
-* but WITHOUT ANY WARRANTY; without even the implied warranty of\r
-* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the\r
-* GNU General Public License for more details.\r
-*\r
-* You should have received a copy of the GNU General Public License\r
-* along with CasparCG. If not, see <http://www.gnu.org/licenses/>.\r
-*\r
-* Author: Nicklas P Andersson\r
-*/\r
-\r
\r
-#include "../StdAfx.h"\r
-\r
-#include "CIIProtocolStrategy.h"\r
-#include "CIICommandsImpl.h"\r
-#include <sstream>\r
-#include <algorithm>\r
-#include <modules/flash/producer/cg_producer.h>\r
-\r
-namespace caspar { namespace protocol { namespace cii {\r
-\r
-/////////////////\r
-// MediaCommand\r
-void MediaCommand::Setup(const std::vector<std::wstring>& parameters) \r
-{\r
-       graphicProfile_ = parameters[1].substr(2);\r
-}\r
-\r
-void MediaCommand::Execute() \r
-{\r
-       pCIIStrategy_->SetProfile(graphicProfile_);\r
-}\r
-\r
-\r
-/////////////////\r
-// WriteCommand\r
-void WriteCommand::Setup(const std::vector<std::wstring>& parameters)\r
-{\r
-       try \r
-       {\r
-               if(parameters.size() > 2)\r
-               {\r
-                       targetName_ = parameters[1];\r
-                       templateName_ = parameters[2];\r
-\r
-                       std::wstringstream dataStream;\r
-\r
-                       dataStream << TEXT("<templateData>");\r
-\r
-                       std::vector<std::wstring>::size_type end = parameters.size();\r
-                       for(std::vector<std::wstring>::size_type i = 3; i < end; ++i) \r
-                               dataStream << TEXT("<componentData id=\"field") << i-2 << TEXT("\"><data id=\"text\" value=\"") << parameters[i] << TEXT("\" /></componentData>"); \r
-\r
-                       dataStream << TEXT("</templateData>");\r
-                       xmlData_ = dataStream.str();\r
-               }\r
-       }\r
-       catch(std::exception) {\r
-       }\r
-}\r
-\r
-void WriteCommand::Execute() \r
-{\r
-       pCIIStrategy_->WriteTemplateData(templateName_, targetName_, xmlData_);\r
-}\r
-\r
-\r
-//////////////////////\r
-// ImagestoreCommand\r
-void ImagestoreCommand::Setup(const std::vector<std::wstring>& parameters) \r
-{\r
-       if(parameters[1] == TEXT("7") && parameters.size() > 2) \r
-               titleName_ = parameters[2].substr(0, 4);        \r
-}\r
-\r
-void ImagestoreCommand::Execute()\r
-{\r
-       pCIIStrategy_->DisplayTemplate(titleName_);\r
-}\r
-\r
-\r
-//////////////////////\r
-// MiscellaneousCommand\r
-void MiscellaneousCommand::Setup(const std::vector<std::wstring>& parameters)\r
-{\r
-       //HAWRYS:       V\5\3\1\1\namn.tga\1\r
-       //                      Display still\r
-       if((parameters.size() > 5) && parameters[1] == TEXT("5") && parameters[2] == TEXT("3"))\r
-       {\r
-               filename_ = parameters[5];\r
-               filename_ = filename_.substr(0, filename_.find_last_of(TEXT('.')));\r
-               filename_.append(L".ft");\r
-               state_ = 0;\r
-               return;\r
-       }\r
-       \r
-       //NEPTUNE:      V\5\13\1\X\Template\0\TabField1\TabField2...\r
-       //                      Add Template to layer X in the active templatehost\r
-       if((parameters.size() > 5) && parameters[1] == TEXT("5") && parameters[2] == TEXT("13"))\r
-       {\r
-               layer_ = _ttoi(parameters[4].c_str());\r
-               filename_ = parameters[5];\r
-               state_ = 1;\r
-               if(parameters.size() > 7) {\r
-                       std::wstringstream dataStream;\r
-\r
-                       dataStream << TEXT("<templateData>");\r
-                       std::vector<std::wstring>::size_type end = parameters.size();\r
-                       for(std::vector<std::wstring>::size_type i = 7; i < end; ++i) {\r
-                               dataStream << TEXT("<componentData id=\"f") << i-7 << TEXT("\"><data id=\"text\" value=\"") << parameters[i] << TEXT("\" /></componentData>"); \r
-                       }\r
-                       dataStream << TEXT("</templateData>");\r
-\r
-                       xmlData_ = dataStream.str();\r
-               }\r
-       }\r
-\r
-       // VIDEO MODE V\5\14\MODE\r
-       if((parameters.size() > 3) && parameters[1] == TEXT("5") && parameters[2] == TEXT("14"))\r
-       {\r
-               std::wstring value = parameters[3];\r
-               std::transform(value.begin(), value.end(), value.begin(), toupper);\r
-\r
-               //this->pCIIStrategy_->GetChannel()->SetVideoFormat(value); TODO\r
-       }\r
-}\r
-\r
-void MiscellaneousCommand::Execute() \r
-{\r
-       if(state_ == 0)\r
-               pCIIStrategy_->DisplayMediaFile(filename_);     \r
-\r
-       //TODO: Need to be checked for validity\r
-       else if(state_ == 1)\r
-               flash::get_default_cg_producer(pCIIStrategy_->GetChannel())->add(layer_, filename_, false, TEXT(""), xmlData_);\r
-}\r
-\r
-\r
-///////////////////\r
-// KeydataCommand\r
-void KeydataCommand::Execute() \r
-{\r
-       if(state_ == 0) \r
-               pCIIStrategy_->DisplayTemplate(titleName_);\r
-       \r
-\r
-       //TODO: Need to be checked for validity\r
-       else if(state_ == 1)\r
-               flash::get_default_cg_producer(pCIIStrategy_->GetChannel())->stop(layer_, 0);\r
-       else if(state_ == 2)\r
-               pCIIStrategy_->GetChannel()->stage()->clear(flash::cg_producer::DEFAULT_LAYER);\r
-       else if(state_ == 3)\r
-               flash::get_default_cg_producer(pCIIStrategy_->GetChannel())->play(layer_);\r
-}\r
-\r
-void KeydataCommand::Setup(const std::vector<std::wstring>& parameters) {\r
-       //HAWRYS:       Y\<205><247><202><196><192><192><200><248>\r
-       //parameter[1] looks like this: "=g:XXXXh" where XXXX is the name that we want\r
-       if(parameters[1].size() > 6) \r
-       {\r
-               titleName_.resize(4);\r
-               for(int i=0;i<4;++i)\r
-               {\r
-                       if(parameters[1][i+3] < 176) {\r
-                               titleName_ = TEXT("");\r
-                               break;\r
-                       }\r
-                       titleName_[i] = parameters[1][i+3]-144;\r
-               }\r
-               state_ = 0;\r
-       }\r
-\r
-       if(parameters.size() > 2)       \r
-               layer_ = _ttoi(parameters[2].c_str());  \r
-\r
-       if(parameters[1].at(0) == 27)   //NEPTUNE:      Y\<27>\X                        Stop layer X.\r
-               state_ = 1;\r
-       else if(static_cast<unsigned char>(parameters[1].at(1)) == 190) //NEPTUNE:      Y\<254>                 Clear Canvas. \r
-               state_ = 2;\r
-       else if(static_cast<unsigned char>(parameters[1].at(1)) == 149) //NEPTUNE:      Y\<213><243>\X  Play layer X. \r
-               state_ = 3;                                                                                                     //UPDATE 2011-05-09: These char-codes are aparently not valid after converting to wide-chars\r
-                                                                                                                                       //the correct sequence is <195><149><195><179> \r
-               \r
-}\r
-\r
-}}}
\ No newline at end of file
+/*
+* Copyright (c) 2011 Sveriges Television AB <info@casparcg.com>
+*
+* This file is part of CasparCG (www.casparcg.com).
+*
+* CasparCG is free software: you can redistribute it and/or modify
+* it under the terms of the GNU General Public License as published by
+* the Free Software Foundation, either version 3 of the License, or
+* (at your option) any later version.
+*
+* CasparCG is distributed in the hope that it will be useful,
+* but WITHOUT ANY WARRANTY; without even the implied warranty of
+* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+* GNU General Public License for more details.
+*
+* You should have received a copy of the GNU General Public License
+* along with CasparCG. If not, see <http://www.gnu.org/licenses/>.
+*
+* Author: Nicklas P Andersson
+*/
+
+#include "../StdAfx.h"
+
+#pragma warning (disable: 4244)
+
+#include "CIIProtocolStrategy.h"
+#include "CIICommandsImpl.h"
+
+#include <core/producer/cg_proxy.h>
+
+#include <sstream>
+#include <algorithm>
+
+#include <boost/locale.hpp>
+#include <boost/algorithm/string/trim.hpp>
+#include <boost/algorithm/string/split.hpp>
+#include <boost/lexical_cast.hpp>
+
+namespace caspar { namespace protocol { namespace cii {
+
+////////
+// MediaCommand
+void MediaCommand::Setup(const std::vector<std::wstring>& parameters) 
+{
+       graphicProfile_ = parameters[1].substr(2);
+}
+
+void MediaCommand::Execute() 
+{
+       pCIIStrategy_->SetProfile(graphicProfile_);
+}
+
+
+////////
+// WriteCommand
+void WriteCommand::Setup(const std::vector<std::wstring>& parameters)
+{
+       try 
+       {
+               if(parameters.size() > 2)
+               {
+                       targetName_ = parameters[1];
+                       templateName_ = parameters[2];
+
+                       std::wstringstream dataStream;
+
+                       dataStream << L"<templateData>";
+
+                       std::vector<std::wstring>::size_type end = parameters.size();
+                       for(std::vector<std::wstring>::size_type i = 3; i < end; ++i) 
+                               dataStream << L"<componentData id=\"field" << i-2 << L"\"><data id=\"text\" value=\"" << parameters[i] << L"\" /></componentData>";
+
+                       dataStream << L"</templateData>";
+                       xmlData_ = dataStream.str();
+               }
+       }
+       catch(std::exception) {
+       }
+}
+
+void WriteCommand::Execute() 
+{
+       pCIIStrategy_->WriteTemplateData(templateName_, targetName_, xmlData_);
+}
+
+
+//////////
+// ImagestoreCommand
+void ImagestoreCommand::Setup(const std::vector<std::wstring>& parameters) 
+{
+       if(parameters[1] == L"7" && parameters.size() > 2)
+               titleName_ = parameters[2].substr(0, 4);        
+}
+
+void ImagestoreCommand::Execute()
+{
+       pCIIStrategy_->DisplayTemplate(titleName_);
+}
+
+
+//////////
+// MiscellaneousCommand
+void MiscellaneousCommand::Setup(const std::vector<std::wstring>& parameters)
+{
+       //HAWRYS:       V\5\3\1\1\namn.tga\1
+       //                      Display still
+       if((parameters.size() > 5) && parameters[1] == L"5" && parameters[2] == L"3")
+       {
+               filename_ = parameters[5];
+               filename_ = filename_.substr(0, filename_.find_last_of(L'.'));
+               filename_.append(L".ft");
+               state_ = 0;
+               return;
+       }
+       
+       //NEPTUNE:      V\5\13\1\X\Template\0\TabField1\TabField2...
+       //                      Add Template to layer X in the active templatehost
+       if((parameters.size() > 5) && parameters[1] == L"5" && parameters[2] == L"13")
+       {
+               layer_ = boost::lexical_cast<int>(parameters[4]);
+               filename_ = parameters[5];
+               if(filename_.find(L"PK/") == std::wstring::npos && filename_.find(L"PK\\") == std::wstring::npos)
+                       filename_ = L"PK/" + filename_;
+
+               state_ = 1;
+               if(parameters.size() > 7) {
+                       std::wstringstream dataStream;
+
+                       dataStream << L"<templateData>";
+                       std::vector<std::wstring>::size_type end = parameters.size();
+                       for(std::vector<std::wstring>::size_type i = 7; i < end; ++i) {
+                               dataStream << L"<componentData id=\"f" << i-7 << L"\"><data id=\"text\" value=\"" << parameters[i] << L"\" /></componentData>";
+                       }
+                       dataStream << L"</templateData>";
+
+                       xmlData_ = dataStream.str();
+               }
+       }
+
+       // VIDEO MODE V\5\14\MODE
+       if((parameters.size() > 3) && parameters[1] == L"5" && parameters[2] == L"14")
+       {
+               std::wstring value = parameters[3];
+               std::transform(value.begin(), value.end(), value.begin(), toupper);
+
+               this->pCIIStrategy_->GetChannel()->video_format_desc(core::video_format_desc(value));
+       }
+}
+
+void MiscellaneousCommand::Execute() 
+{
+       if(state_ == 0)
+               pCIIStrategy_->DisplayMediaFile(filename_);     
+
+       //TODO: Need to be checked for validity
+       else if(state_ == 1)            
+       {
+               // HACK fix. The data sent is UTF8, however the protocol is implemented for ISO-8859-1. Instead of doing risky changes we simply convert into proper encoding when leaving protocol code.
+               auto xmlData2 = boost::locale::conv::utf_to_utf<wchar_t, char>(std::string(xmlData_.begin(), xmlData_.end()));
+               auto proxy = pCIIStrategy_->get_cg_registry()->get_or_create_proxy(
+                               pCIIStrategy_->GetChannel(),
+                               pCIIStrategy_->get_dependencies(),
+                               core::cg_proxy::DEFAULT_LAYER,
+                               filename_);
+               proxy->add(layer_, filename_, false, L"", xmlData2);
+       }
+}
+
+
+/////////
+// KeydataCommand
+void KeydataCommand::Execute() 
+{
+       auto proxy = pCIIStrategy_->get_cg_registry()->get_proxy(
+               pCIIStrategy_->GetChannel(), casparLayer_);
+
+       if (state_ == 0)
+               pCIIStrategy_->DisplayTemplate(titleName_);
+
+       //TODO: Need to be checked for validity
+       else if(state_ == 1)
+               proxy->stop(layer_, 0);
+       else if(state_ == 2)
+               pCIIStrategy_->GetChannel()->stage().clear();
+       else if(state_ == 3)
+               proxy->play(layer_);
+}
+
+void KeydataCommand::Setup(const std::vector<std::wstring>& parameters) {
+       //HAWRYS:       Y\<205><247><202><196><192><192><200><248>
+       //parameter[1] looks like this: "=g:XXXXh" where XXXX is the name that we want
+       if(parameters[1].size() > 6) 
+       {
+               titleName_.resize(4);
+               for(int i=0;i<4;++i)
+               {
+                       if(parameters[1][i+3] < 176) {
+                               titleName_ = L"";
+                               break;
+                       }
+                       titleName_[i] = parameters[1][i+3]-144;
+               }
+               state_ = 0;
+       }
+
+       casparLayer_ = core::cg_proxy::DEFAULT_LAYER;
+       if(parameters.size() > 2)
+       {
+               //The layer parameter now supports casparlayers.
+               //the format is [CasparLayer]-[FlashLayer]
+               std::wstring str = boost::trim_copy(parameters[2]);
+               std::vector<std::wstring> split;
+               boost::split(split, str, boost::is_any_of("-"));
+               
+               try
+               {
+                       casparLayer_ = boost::lexical_cast<int>(split[0]);
+
+                       if(split.size() > 1)
+                               layer_ = boost::lexical_cast<int>(split[1]);
+               }
+               catch(...)
+               { 
+                       casparLayer_ = core::cg_proxy::DEFAULT_LAYER;
+                       layer_ = 0;
+               }
+       }
+
+
+       if(parameters[1].at(0) == 27)   //NEPTUNE:      Y\<27>\X                        Stop layer X.
+               state_ = 1;
+       else if(static_cast<unsigned char>(parameters[1].at(1)) == 190) //NEPTUNE:      Y\<254>                 Clear Canvas. 
+               state_ = 2;
+       else if(static_cast<unsigned char>(parameters[1].at(1)) == 149) //NEPTUNE:      Y\<213><243>\X  Play layer X. 
+               state_ = 3;                                                                                                     //UPDATE 2011-05-09: These char-codes are aparently not valid after converting to wide-chars
+                                                                                                                                       //the correct sequence is <195><149><195><179> 
+               
+}
+
+}}}