X-Git-Url: https://git.sesse.net/?a=blobdiff_plain;f=protocol%2Famcp%2FAMCPCommandsImpl.cpp;h=11b6032816fb479fd11aa5c2e8a58fa85bdd5fa1;hb=d100d17e81ed61c7638b681989cfdab5276430db;hp=a412e806f6374eeb44a71ebc2a5688502b9f0120;hpb=ca1389095f5853d240f98ca3babd0c6ae419fd42;p=casparcg

diff --git a/protocol/amcp/AMCPCommandsImpl.cpp b/protocol/amcp/AMCPCommandsImpl.cpp
index a412e806f..11b603281 100644
--- a/protocol/amcp/AMCPCommandsImpl.cpp
+++ b/protocol/amcp/AMCPCommandsImpl.cpp
@@ -23,18 +23,17 @@
 #include "AMCPCommandsImpl.h"
 #include "AMCPProtocolStrategy.h"
 
-#include "../media.h"
-
 #include <common/env.h>
 
 #include <core/producer/frame_producer.h>
 #include <core/video_format.h>
-#include <core/producer/flash/flash_producer.h>
+#include <modules/flash/flash.h>
+#include <modules/flash/producer/flash_producer.h>
+#include <modules/flash/producer/cg_producer.h>
 #include <core/producer/transition/transition_producer.h>
-#include <core/producer/flash/cg_producer.h>
 
-#include <mixer/image/image_transform.h>
-#include <mixer/audio/audio_transform.h>
+#include <core/producer/frame/image_transform.h>
+#include <core/producer/frame/audio_transform.h>
 
 #include <algorithm>
 #include <locale>
@@ -46,6 +45,7 @@
 #include <boost/lexical_cast.hpp>
 #include <boost/algorithm/string.hpp>
 #include <boost/filesystem.hpp>
+#include <boost/regex.hpp>
 
 #if defined(_MSC_VER)
 #pragma warning (push, 1) // TODO: Legacy code, just disable warnings
@@ -164,7 +164,7 @@ void AMCPCommand::SendReply()
 
 void AMCPCommand::Clear() 
 {
-	pChannel_->producer().clear();
+	pChannel_->producer()->clear();
 	pClientInfo_.reset();
 	channelIndex_ = 0;
 	_parameters.clear();
@@ -179,67 +179,155 @@ bool MixerCommand::DoExecute()
 		{
 			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";
+
 				double value = boost::lexical_cast<double>(_parameters.at(2));
-				auto transform = GetChannel()->mixer().get_image_transform(GetLayerIndex());
-				transform.set_opacity(value);
-				GetChannel()->mixer().set_image_transform(GetLayerIndex(), std::move(transform));
+			
+				auto transform = [=](image_transform transform) -> image_transform
+				{
+					transform.set_opacity(value);
+					return transform;					
+				};
+
+				int layer = GetLayerIndex(std::numeric_limits<int>::min());
+				if(layer != std::numeric_limits<int>::min())					
+					GetChannel()->mixer()->apply_image_transform(GetLayerIndex(), transform, duration, tween);
+				else
+					GetChannel()->mixer()->apply_image_transform(transform, duration, tween);
 			}
 			else 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";
 				double value = boost::lexical_cast<double>(_parameters.at(2));
-				auto transform = GetChannel()->mixer().get_image_transform(GetLayerIndex());
-				transform.set_gain(value);
-				GetChannel()->mixer().set_image_transform(GetLayerIndex(), std::move(transform));
+				
+				auto transform = [=](image_transform transform) -> image_transform
+				{
+					transform.set_gain(value);
+					return transform;					
+				};
+
+				int layer = GetLayerIndex(std::numeric_limits<int>::min());
+				if(layer != std::numeric_limits<int>::min())
+					GetChannel()->mixer()->apply_image_transform(GetLayerIndex(), transform, duration, tween);
+				else
+					GetChannel()->mixer()->apply_image_transform(transform, duration, tween);
 			}
-			else if(_parameters[1] == L"FIX_RECT")
+			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";
 				double x	= boost::lexical_cast<double>(_parameters.at(2));
 				double y	= boost::lexical_cast<double>(_parameters.at(3));
 				double x_s	= boost::lexical_cast<double>(_parameters.at(4));
 				double y_s	= boost::lexical_cast<double>(_parameters.at(5));
-				auto transform = GetChannel()->mixer().get_image_transform(GetLayerIndex());
-				transform.set_image_translation(x, y);
-				transform.set_image_scale(x_s, y_s);
-				transform.set_mask_translation(0.0, 0.0);
-				transform.set_mask_scale(1.0, 1.0);
-				GetChannel()->mixer().set_image_transform(GetLayerIndex(), std::move(transform));
+
+				auto transform = [=](image_transform transform) -> image_transform
+				{
+					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);
+					return transform;
+				};
+
+				int layer = GetLayerIndex(std::numeric_limits<int>::min());
+				if(layer != std::numeric_limits<int>::min())
+					GetChannel()->mixer()->apply_image_transform(GetLayerIndex(), transform, duration, tween);
+				else
+					GetChannel()->mixer()->apply_image_transform(transform, duration, tween);
 			}
-			else if(_parameters[1] == L"CLIP_RECT")
+			else if(_parameters[1] == L"KEY_RECT")
 			{
+				int duration = _parameters.size() > 5 ? lexical_cast_or_default(_parameters[6], 0) : 0;
+				std::wstring tween = _parameters.size() > 6 ? _parameters[7] : L"linear";
 				double x	= boost::lexical_cast<double>(_parameters.at(2));
 				double y	= boost::lexical_cast<double>(_parameters.at(3));
 				double x_s	= boost::lexical_cast<double>(_parameters.at(4));
 				double y_s	= boost::lexical_cast<double>(_parameters.at(5));
-				auto transform = GetChannel()->mixer().get_image_transform(GetLayerIndex());
-				transform.set_image_translation(0.0, 0.0);
-				transform.set_image_scale(1.0, 1.0);
-				transform.set_mask_translation(x, y);
-				transform.set_mask_scale(x_s, y_s);
-				GetChannel()->mixer().set_image_transform(GetLayerIndex(), std::move(transform));
+
+				auto transform = [=](image_transform transform) -> image_transform
+				{
+					transform.set_key_translation(x, y);
+					transform.set_key_scale(x_s, y_s);
+					return transform;
+				};
+
+				int layer = GetLayerIndex(std::numeric_limits<int>::min());
+				if(layer != std::numeric_limits<int>::min())
+					GetChannel()->mixer()->apply_image_transform(GetLayerIndex(), transform, duration, tween);
+				else
+					GetChannel()->mixer()->apply_image_transform(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 n = boost::lexical_cast<int>(_parameters.at(2));
+				double delta = 1.0/static_cast<double>(n);
+				for(int x = 0; x < n; ++x)
+				{
+					for(int y = 0; y < n; ++y)
+					{
+						int index = x+y*n+1;
+						auto transform = [=](image_transform transform) -> image_transform
+						{				
+							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);
+							return transform;
+						};
+						GetChannel()->mixer()->apply_image_transform(index, transform, duration, tween);
+					}
+				}
 			}
 			else if(_parameters[1] == L"RESET")
 			{
-				GetChannel()->mixer().set_image_transform(GetLayerIndex(), image_transform());
+				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<int>::min());
+				if(layer != std::numeric_limits<int>::min())
+					GetChannel()->mixer()->reset_image_transform(GetLayerIndex(), duration, tween);
+				else
+					GetChannel()->mixer()->reset_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";
 				double value = boost::lexical_cast<double>(_parameters[2]);
-				auto transform = GetChannel()->mixer().get_audio_transform(GetLayerIndex());
-				transform.set_gain(value);
-				GetChannel()->mixer().set_audio_transform(GetLayerIndex(), std::move(transform));
+
+				auto transform = [=](audio_transform transform) -> audio_transform
+				{
+					transform.set_gain(value);
+					return transform;
+				};
+				
+				int layer = GetLayerIndex(std::numeric_limits<int>::min());
+				if(layer != std::numeric_limits<int>::min())
+					GetChannel()->mixer()->apply_audio_transform(GetLayerIndex(), transform, duration, tween);
+				else
+					GetChannel()->mixer()->apply_audio_transform(transform, duration, tween);
 			}
 			else if(_parameters[1] == L"RESET")
 			{
-				GetChannel()->mixer().set_audio_transform(GetLayerIndex(), audio_transform());
+				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);
 			}
 		}
 		else if(_parameters[0] == L"RESET")
 		{
-			GetChannel()->mixer().set_image_transform(GetLayerIndex(), image_transform());
-			GetChannel()->mixer().set_audio_transform(GetLayerIndex(), audio_transform());
+			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);
 		}
 	
 		SetReplyString(TEXT("202 MIXER OK\r\n"));
@@ -276,13 +364,13 @@ bool SwapCommand::DoExecute()
 			int l1 = GetLayerIndex();
 			int l2 = boost::lexical_cast<int>(strs.at(1));
 
-			ch1->producer().swap_layer(l1, l2, ch2->producer());
+			ch1->producer()->swap_layer(l1, l2, *ch2->producer());
 		}
 		else
 		{
 			auto ch1 = GetChannel();
 			auto ch2 = GetChannels().at(boost::lexical_cast<int>(_parameters[0])-1);
-			ch1->producer().swap_output(ch2->producer());
+			ch1->producer()->swap(*ch2->producer());
 		}
 
 		CASPAR_LOG(info) << "Swapped successfully";
@@ -310,7 +398,7 @@ bool AddCommand::DoExecute()
 	//Perform loading of the clip
 	try
 	{
-		GetChannel()->consumer().add(GetLayerIndex(), create_consumer(_parameters));
+		GetChannel()->consumer()->add(GetLayerIndex(), create_consumer(_parameters));
 	
 		CASPAR_LOG(info) << "Added " <<  _parameters[0] << TEXT(" successfully");
 
@@ -337,9 +425,7 @@ bool RemoveCommand::DoExecute()
 	//Perform loading of the clip
 	try
 	{
-		GetChannel()->consumer().remove(GetLayerIndex());
-	
-		CASPAR_LOG(info) << "Removed " << TEXT(" successfully");
+		GetChannel()->consumer()->remove(GetLayerIndex());
 
 		SetReplyString(TEXT("202 REMOVE OK\r\n"));
 
@@ -365,8 +451,8 @@ bool LoadCommand::DoExecute()
 	try
 	{
 		_parameters[0] = _parameters[0];
-		auto pFP = create_producer(_parameters);		
-		GetChannel()->producer().preview(GetLayerIndex(), pFP);
+		auto pFP = create_producer(GetChannel()->mixer(), _parameters);		
+		GetChannel()->producer()->load(GetLayerIndex(), pFP, true);
 	
 		CASPAR_LOG(info) << "Loaded " <<  _parameters[0] << TEXT(" successfully");
 
@@ -388,65 +474,97 @@ bool LoadCommand::DoExecute()
 	}
 }
 
+
+
+//std::function<std::wstring()> channel_cg_add_command::parse(const std::wstring& message, const std::vector<renderer::render_device_ptr>& channels)
+//{
+//	static boost::wregex expr(L"^CG\\s(?<CHANNEL>\\d+)-?(?<LAYER>\\d+)?\\sADD\\s(?<FLASH_LAYER>\\d+)\\s(?<TEMPLATE>\\S+)\\s?(?<START_LABEL>\\S\\S+)?\\s?(?<PLAY_ON_LOAD>\\d)?\\s?(?<DATA>.*)?");
+//
+//	boost::wsmatch what;
+//	if(!boost::regex_match(message, what, expr))
+//		return nullptr;
+//
+//	auto info = channel_info::parse(what, channels);
+//
+//	int flash_layer_index = boost::lexical_cast<int>(what["FLASH_LAYER"].str());
+//
+//	std::wstring templatename = what["TEMPLATE"].str();
+//	bool play_on_load = what["PLAY_ON_LOAD"].matched ? what["PLAY_ON_LOAD"].str() != L"0" : 0;
+//	std::wstring start_label = what["START_LABEL"].str();	
+//	std::wstring data = get_data(what["DATA"].str());
+//	
+//	boost::replace_all(templatename, "\"", "");
+//
+//	return [=]() -> std::wstring
+//	{	
+//		std::wstring fullFilename = flash::flash_producer::find_template(server::template_folder() + templatename);
+//		if(fullFilename.empty())
+//			BOOST_THROW_EXCEPTION(file_not_found());
+//	
+//		std::wstring extension = boost::filesystem::wpath(fullFilename).extension();
+//		std::wstring filename = templatename;
+//		filename.append(extension);
+//
+//		flash::get_default_cg_producer(info.channel, std::max<int>(DEFAULT_CHANNEL_LAYER+1, info.layer_index))
+//			->add(flash_layer_index, filename, play_on_load, start_label, data);
+//
+//		CASPAR_LOG(info) << L"Executed [amcp_channel_cg_add]";
+//		return L"";
+//	};
+
 bool LoadbgCommand::DoExecute()
 {
 	transition_info transitionInfo;
 	
 	bool bLoop = false;
-	unsigned short transitionParameterIndex = 1;
 
-	if(_parameters.size() > 1 && _parameters[1] == TEXT("LOOP"))
-		++transitionParameterIndex;
+	// TRANSITION
 
-	//Setup transition info
-	if(_parameters.size() > transitionParameterIndex)	//type
+	std::wstring message;
+	for(size_t n = 0; n < _parameters.size(); ++n)
+		message += _parameters[n] + L" ";
+		
+	static const boost::wregex expr(L".*(?<TRANSITION>CUT|PUSH|SLIDE|WIPE)\\s*(?<DURATION>\\d+)\\s*(?<TWEEN>(LINEAR)|(EASE[^\\s]*))?\\s*(?<DIRECTION>FROMLEFT|FROMRIGHT|LEFT|RIGHT)?.*");
+	boost::wsmatch what;
+	if(boost::regex_match(message, what, expr))
 	{
-		std::wstring transitionType = _parameters[transitionParameterIndex];
+		auto transition = what["TRANSITION"].str();
+		transitionInfo.duration = lexical_cast_or_default<size_t>(what["DURATION"].str());
+		auto direction = what["DIRECTION"].matched ? what["DIRECTION"].str() : L"";
+		auto tween = what["TWEEN"].matched ? what["TWEEN"].str() : L"";
+		transitionInfo.tweener = get_tweener(tween);		
 
-		if(transitionType == TEXT("CUT"))
+		if(transition == TEXT("CUT"))
 			transitionInfo.type = transition::cut;
-		else if(transitionType == TEXT("MIX"))
+		else if(transition == TEXT("MIX"))
 			transitionInfo.type = transition::mix;
-		else if(transitionType == TEXT("PUSH"))
+		else if(transition == TEXT("PUSH"))
 			transitionInfo.type = transition::push;
-		else if(transitionType == TEXT("SLIDE"))
+		else if(transition == TEXT("SLIDE"))
 			transitionInfo.type = transition::slide;
-		else if(transitionType == TEXT("WIPE"))
+		else if(transition == TEXT("WIPE"))
 			transitionInfo.type = transition::wipe;
-
-		if(_parameters.size() > static_cast<unsigned short>(transitionParameterIndex+1))	//duration
-		{
-			int duration = _ttoi(_parameters[transitionParameterIndex+1].c_str());
-			if(duration > 0)
-				transitionInfo.duration = duration;
-
-			if(_parameters.size() > static_cast<unsigned short>(transitionParameterIndex+2))	//direction
-			{
-				std::wstring direction = _parameters[transitionParameterIndex+2];
-
-				if(direction == TEXT("FROMLEFT"))
-					transitionInfo.direction = transition_direction::from_left;
-				else if(direction == TEXT("FROMRIGHT"))
-					transitionInfo.direction = transition_direction::from_right;
-				else if(direction == TEXT("LEFT"))
-					transitionInfo.direction = transition_direction::from_right;
-				else if(direction == TEXT("RIGHT"))
-					transitionInfo.direction = transition_direction::from_left;
-			}
-		}
+		
+		if(direction == TEXT("FROMLEFT"))
+			transitionInfo.direction = transition_direction::from_left;
+		else if(direction == TEXT("FROMRIGHT"))
+			transitionInfo.direction = transition_direction::from_right;
+		else if(direction == TEXT("LEFT"))
+			transitionInfo.direction = transition_direction::from_right;
+		else if(direction == TEXT("RIGHT"))
+			transitionInfo.direction = transition_direction::from_left;
 	}
-
+	
 	//Perform loading of the clip
 	try
 	{
 		_parameters[0] = _parameters[0];
-		auto pFP = create_producer(_parameters);
+		auto pFP = create_producer(GetChannel()->mixer(), _parameters);
 		if(pFP == frame_producer::empty())
 			BOOST_THROW_EXCEPTION(file_not_found() << msg_info(_parameters.size() > 0 ? narrow(_parameters[0]) : ""));
 
-		pFP = safe_ptr<core::frame_producer>(transition_producer(pFP, transitionInfo));
-		bool autoPlay = std::find(_parameters.begin(), _parameters.end(), TEXT("AUTOPLAY")) != _parameters.end();
-		GetChannel()->producer().load(GetLayerIndex(), pFP, autoPlay); // TODO: LOOP
+		auto pFP2 = create_transition_producer(GetChannel()->get_video_format_desc().mode, pFP, transitionInfo);
+		GetChannel()->producer()->load(GetLayerIndex(), pFP2); // TODO: LOOP
 	
 		CASPAR_LOG(info) << "Loaded " << _parameters[0] << TEXT(" successfully to background");
 		SetReplyString(TEXT("202 LOADBG OK\r\n"));
@@ -471,7 +589,7 @@ bool PauseCommand::DoExecute()
 {
 	try
 	{
-		GetChannel()->producer().pause(GetLayerIndex());
+		GetChannel()->producer()->pause(GetLayerIndex());
 		SetReplyString(TEXT("202 PAUSE OK\r\n"));
 		return true;
 	}
@@ -487,7 +605,23 @@ bool PlayCommand::DoExecute()
 {
 	try
 	{
-		GetChannel()->producer().play(GetLayerIndex());
+		if(!_parameters.empty())
+		{
+			LoadbgCommand lbg;
+			lbg.SetChannel(GetChannel());
+			lbg.SetChannelIndex(GetChannelIndex());
+			lbg.SetLayerIntex(GetLayerIndex());
+			lbg.SetClientInfo(GetClientInfo());
+			for(auto it = _parameters.begin(); it != _parameters.end(); ++it)
+				lbg.AddParameter(*it);
+			if(!lbg.Execute())
+				CASPAR_LOG(warning) << " Failed to play.";
+
+			CASPAR_LOG(info) << "Playing " << _parameters[0];
+		}
+
+		GetChannel()->producer()->play(GetLayerIndex());
+		
 		SetReplyString(TEXT("202 PLAY OK\r\n"));
 		return true;
 	}
@@ -503,7 +637,7 @@ bool StopCommand::DoExecute()
 {
 	try
 	{
-		GetChannel()->producer().stop(GetLayerIndex());
+		GetChannel()->producer()->stop(GetLayerIndex());
 		SetReplyString(TEXT("202 STOP OK\r\n"));
 		return true;
 	}
@@ -517,7 +651,11 @@ bool StopCommand::DoExecute()
 
 bool ClearCommand::DoExecute()
 {
-	GetChannel()->producer().clear(GetLayerIndex());
+	int index = GetLayerIndex(std::numeric_limits<int>::min());
+	if(index != std::numeric_limits<int>::min())
+		GetChannel()->producer()->clear(index);
+	else
+		GetChannel()->producer()->clear();
 		
 	SetReplyString(TEXT("202 CLEAR OK\r\n"));
 
@@ -638,14 +776,14 @@ bool CGCommand::DoExecuteAdd() {
 		}
 	}
 
-	std::wstring fullFilename = core::flash::flash_producer::find_template(env::template_folder() + _parameters[2]);
+	std::wstring fullFilename = find_flash_template(env::template_folder() + _parameters[2]);
 	if(!fullFilename.empty())
 	{
 		std::wstring extension = boost::filesystem::wpath(fullFilename).extension();
 		std::wstring filename = _parameters[2];
 		filename.append(extension);
 
-		core::flash::get_default_cg_producer(safe_ptr<core::channel>(GetChannel()), GetLayerIndex(core::flash::cg_producer::DEFAULT_LAYER))->add(layer, filename, bDoStart, label, (pDataString!=0) ? pDataString : TEXT(""));
+		get_default_cg_producer(safe_ptr<core::channel>(GetChannel()), GetLayerIndex(cg_producer::DEFAULT_LAYER))->add(layer, filename, bDoStart, label, (pDataString!=0) ? pDataString : TEXT(""));
 		SetReplyString(TEXT("202 CG OK\r\n"));
 	}
 	else
@@ -666,7 +804,7 @@ bool CGCommand::DoExecutePlay()
 			return false;
 		}
 		int layer = _ttoi(_parameters[1].c_str());
-		core::flash::get_default_cg_producer(safe_ptr<core::channel>(GetChannel()), GetLayerIndex(core::flash::cg_producer::DEFAULT_LAYER))->play(layer);
+		get_default_cg_producer(safe_ptr<core::channel>(GetChannel()), GetLayerIndex(cg_producer::DEFAULT_LAYER))->play(layer);
 	}
 	else
 	{
@@ -688,7 +826,7 @@ bool CGCommand::DoExecuteStop()
 			return false;
 		}
 		int layer = _ttoi(_parameters[1].c_str());
-		core::flash::get_default_cg_producer(safe_ptr<core::channel>(GetChannel()), GetLayerIndex(core::flash::cg_producer::DEFAULT_LAYER))->stop(layer, 0);
+		get_default_cg_producer(safe_ptr<core::channel>(GetChannel()), GetLayerIndex(cg_producer::DEFAULT_LAYER))->stop(layer, 0);
 	}
 	else 
 	{
@@ -710,7 +848,7 @@ bool CGCommand::DoExecuteNext()
 			return false;
 		}
 		int layer = _ttoi(_parameters[1].c_str());
-		core::flash::get_default_cg_producer(safe_ptr<core::channel>(GetChannel()), GetLayerIndex(core::flash::cg_producer::DEFAULT_LAYER))->next(layer);
+		get_default_cg_producer(safe_ptr<core::channel>(GetChannel()), GetLayerIndex(cg_producer::DEFAULT_LAYER))->next(layer);
 	}
 	else 
 	{
@@ -732,7 +870,7 @@ bool CGCommand::DoExecuteRemove()
 			return false;
 		}
 		int layer = _ttoi(_parameters[1].c_str());
-		core::flash::get_default_cg_producer(safe_ptr<core::channel>(GetChannel()), GetLayerIndex(core::flash::cg_producer::DEFAULT_LAYER))->remove(layer);
+		get_default_cg_producer(safe_ptr<core::channel>(GetChannel()), GetLayerIndex(cg_producer::DEFAULT_LAYER))->remove(layer);
 	}
 	else 
 	{
@@ -746,7 +884,7 @@ bool CGCommand::DoExecuteRemove()
 
 bool CGCommand::DoExecuteClear() 
 {
-	core::flash::get_default_cg_producer(safe_ptr<core::channel>(GetChannel()), GetLayerIndex(core::flash::cg_producer::DEFAULT_LAYER))->clear();
+	GetChannel()->producer()->clear(GetLayerIndex(cg_producer::DEFAULT_LAYER));
 	SetReplyString(TEXT("202 CG OK\r\n"));
 	return true;
 }
@@ -762,7 +900,7 @@ bool CGCommand::DoExecuteUpdate()
 		}
 		int layer = _ttoi(_parameters[1].c_str());
 		//TODO: Implement indirect data loading from file. Same as in Add
-		core::flash::get_default_cg_producer(safe_ptr<core::channel>(GetChannel()), GetLayerIndex(core::flash::cg_producer::DEFAULT_LAYER))->update(layer, _parameters[2]);
+		get_default_cg_producer(safe_ptr<core::channel>(GetChannel()), GetLayerIndex(cg_producer::DEFAULT_LAYER))->update(layer, _parameters[2]);
 	}
 	else 
 	{
@@ -784,7 +922,7 @@ bool CGCommand::DoExecuteInvoke()
 			return false;
 		}
 		int layer = _ttoi(_parameters[1].c_str());
-		core::flash::get_default_cg_producer(safe_ptr<core::channel>(GetChannel()), GetLayerIndex(core::flash::cg_producer::DEFAULT_LAYER))->invoke(layer, _parameters[2]);
+		get_default_cg_producer(safe_ptr<core::channel>(GetChannel()), GetLayerIndex(cg_producer::DEFAULT_LAYER))->invoke(layer, _parameters[2]);
 	}
 	else 
 	{
@@ -799,7 +937,7 @@ bool CGCommand::DoExecuteInvoke()
 bool CGCommand::DoExecuteInfo() 
 {
 	// TODO
-	//core::flash::get_default_cg_producer(GetChannel())->Info();
+	//get_default_cg_producer(GetChannel())->Info();
 	SetReplyString(TEXT("600 CG FAILED\r\n"));
 	return true;
 }
@@ -925,7 +1063,7 @@ bool CinfCommand::DoExecute()
 
 void GenerateChannelInfo(int index, const safe_ptr<core::channel>& pChannel, std::wstringstream& replyString)
 {
-	replyString << index << TEXT(" ") << pChannel->get_video_format_desc().name  << TEXT("\r\n") << (pChannel->producer().foreground(0).get()->print());
+	replyString << index+1 << TEXT(" ") << pChannel->get_video_format_desc().name << TEXT(" PLAYING") << TEXT("\r\n");
 }
 
 bool InfoCommand::DoExecute()
@@ -991,10 +1129,19 @@ bool TlsCommand::DoExecute()
 
 bool VersionCommand::DoExecute()
 {
-	std::wstringstream replyString;
-	replyString << TEXT("201 VERSION OK\r\n") << env::version() << TEXT("\r\n");
+	std::wstring replyString = TEXT("201 VERSION OK\r\n SERVER: ") + env::version() + TEXT("\r\n");
 
-	SetReplyString(replyString.str());
+	if(_parameters.size() > 0)
+	{
+		if(_parameters[0] == L"FLASH")
+			replyString = TEXT("201 VERSION OK\r\n FLASH: ") + get_flash_version() + TEXT("\r\n");
+		else if(_parameters[0] == L"TEMPLATEHOST")
+			replyString = TEXT("201 VERSION OK\r\n TEMPLATEHOST: ") + get_cg_version() + TEXT("\r\n");
+		else if(_parameters[0] != L"SERVER")
+			replyString = TEXT("403 VERSION ERROR\r\n");
+	}
+
+	SetReplyString(replyString);
 	return true;
 }
 
@@ -1014,10 +1161,14 @@ bool SetCommand::DoExecute()
 
 	if(name == TEXT("MODE"))
 	{
-		//if(this->GetChannel()->producer().SetVideoFormat(value)) TODO
-		//	this->SetReplyString(TEXT("202 SET MODE OK\r\n"));
-		//else
-			this->SetReplyString(TEXT("501 SET MODE FAILED\r\n"));
+		auto format_desc = core::video_format_desc::get(value);
+		if(format_desc.format != core::video_format::invalid)
+		{
+			GetChannel()->set_video_format_desc(format_desc);
+			SetReplyString(TEXT("202 SET MODE OK\r\n"));
+		}
+		else
+			SetReplyString(TEXT("501 SET MODE FAILED\r\n"));
 	}
 	else
 	{