/* 
 * File:   rtpparticipant.cpp
 * Author: Sergio
 * 
 * Created on 19 de enero de 2012, 18:41
 */

#include "rtpparticipant.h"

RTPParticipant::RTPParticipant(DWORD partId,const std::wstring &token,const std::wstring &tag) :
	Participant(Participant::RTP,partId,token),
	audio(NULL),
	video(this),
	text(NULL)
{
	Log("-RTPParticipant [id:%d,token:%ls,tag:%ls]\n",partId,token.c_str(),tag.c_str());
}

RTPParticipant::~RTPParticipant()
{
}

int RTPParticipant::SetVideoCodec(VideoCodec::Type codec,int mode,int fps,int bitrate,int intraPeriod,const Properties& properties)
{
	//Set it
	return video.SetVideoCodec(codec,mode,fps,bitrate,intraPeriod,properties);
}

int RTPParticipant::SetAudioCodec(AudioCodec::Type codec,const Properties& properties)
{
	//Set it
	return audio.SetAudioCodec(codec,properties);
}

int RTPParticipant::SetTextCodec(TextCodec::Type codec)
{
	//Set it
	return text.SetTextCodec(codec);
}

int RTPParticipant::SendVideoFPU()
{
	//Send it
	return video.SendFPU();
}

MediaStatistics RTPParticipant::GetStatistics(MediaFrame::Type type)
{
	//Depending on the type
	switch (type)
	{
		case MediaFrame::Audio:
			return audio.GetStatistics();
		case MediaFrame::Video:
			return video.GetStatistics();
		default:
			return text.GetStatistics();
	}
}

int RTPParticipant::End()
{
	int ret = 1;

	//End all streams
	ret &= video.End();
	ret &= audio.End();
	ret &= text.End();
	//aggregater results
	return ret;
}

int RTPParticipant::Init()
{
	int ret = 1;
	//Init each stream
	ret &= video.Init(videoInput,videoOutput);
	ret &= audio.Init(audioInput,audioOutput);
	ret &= text.Init(textInput,textOutput);
	//aggregater results
	return ret;
}

int RTPParticipant::SetLocalCryptoSDES(MediaFrame::Type media,const char* suite, const char* key)
{
	switch (media)
	{
		case MediaFrame::Audio:
			return audio.SetLocalCryptoSDES(suite,key);
		case MediaFrame::Video:
			return video.SetLocalCryptoSDES(suite,key);
		case MediaFrame::Text:
			return text.SetLocalCryptoSDES(suite,key);
	}

	return 0;
}


int RTPParticipant::SetRemoteCryptoDTLS(MediaFrame::Type media,const char *setup,const char *hash,const char *fingerprint)
{
	switch (media)
	{
		case MediaFrame::Audio:
			return audio.SetRemoteCryptoDTLS(setup,hash,fingerprint);
		case MediaFrame::Video:
			return video.SetRemoteCryptoDTLS(setup,hash,fingerprint);
		case MediaFrame::Text:
			return text.SetRemoteCryptoDTLS(setup,hash,fingerprint);
		default:
			return Error("Unknown media [%d]\n",media);
	}

	//OK
	return 1;
}

int RTPParticipant::SetRemoteCryptoSDES(MediaFrame::Type media,const char* suite, const char* key)
{
	switch (media)
	{
		case MediaFrame::Audio:
			return audio.SetRemoteCryptoSDES(suite,key);
		case MediaFrame::Video:
			return video.SetRemoteCryptoSDES(suite,key);
		case MediaFrame::Text:
			return text.SetRemoteCryptoSDES(suite,key);
	}

	return 0;
}

int RTPParticipant::SetLocalSTUNCredentials(MediaFrame::Type media,const char* username, const char* pwd)
{
	switch (media)
	{
		case MediaFrame::Audio:
			return audio.SetLocalSTUNCredentials(username,pwd);
		case MediaFrame::Video:
			return video.SetLocalSTUNCredentials(username,pwd);
		case MediaFrame::Text:
			return text.SetLocalSTUNCredentials(username,pwd);
	}

	return 0;
}
int RTPParticipant::SetRTPProperties(MediaFrame::Type media,const Properties& properties)
{
	switch (media)
	{
		case MediaFrame::Audio:
			return audio.SetRTPProperties(properties);
		case MediaFrame::Video:
			return video.SetRTPProperties(properties);
		case MediaFrame::Text:
			return text.SetRTPProperties(properties);
	}

	return 0;
}
int RTPParticipant::SetRemoteSTUNCredentials(MediaFrame::Type media,const char* username, const char* pwd)
{
	switch (media)
	{
		case MediaFrame::Audio:
			return audio.SetRemoteSTUNCredentials(username,pwd);
		case MediaFrame::Video:
			return video.SetRemoteSTUNCredentials(username,pwd);
		case MediaFrame::Text:
			return text.SetRemoteSTUNCredentials(username,pwd);
	}

	return 0;
}

int RTPParticipant::StartSending(MediaFrame::Type media,char *ip, int port,const RTPMap& rtpMap,const RTPMap& aptMap)
{
	switch (media)
	{
		case MediaFrame::Audio:
			return audio.StartSending(ip,port,rtpMap,aptMap);
		case MediaFrame::Video:
			return video.StartSending(ip,port,rtpMap,aptMap);
		case MediaFrame::Text:
			return text.StartSending(ip,port,rtpMap,aptMap);
	}

	return 0;
}

int RTPParticipant::StopSending(MediaFrame::Type media)
{
	switch (media)
	{
		case MediaFrame::Audio:
			return audio.StopSending();
		case MediaFrame::Video:
			return video.StopSending();
		case MediaFrame::Text:
			return text.StopSending();
	}

	return 0;

}

int RTPParticipant::StartReceiving(MediaFrame::Type media,const RTPMap& rtpMap,const RTPMap& aptMap)
{
	switch (media)
	{
		case MediaFrame::Audio:
			return audio.StartReceiving(rtpMap,aptMap);
		case MediaFrame::Video:
			return video.StartReceiving(rtpMap,aptMap);
		case MediaFrame::Text:
			return text.StartReceiving(rtpMap,aptMap);
	}

	return 0;
}

int RTPParticipant::StopReceiving(MediaFrame::Type media)
{
	switch (media)
	{
		case MediaFrame::Audio:
			return audio.StopReceiving();
		case MediaFrame::Video:
			return video.StopReceiving();
		case MediaFrame::Text:
			return text.StopReceiving();
	}
	return 0;
}

void RTPParticipant::onFPURequested(RTPSession *session)
{
	//Request it
	video.SendFPU();
}


void RTPParticipant::onReceiverEstimatedMaxBitrate(RTPSession *session,DWORD estimation)
{
	//Limit video taking into count max audio
	video.SetTemporalBitrateLimit(estimation);
}

void RTPParticipant::onTempMaxMediaStreamBitrateRequest(RTPSession *session,DWORD estimation,DWORD overhead)
{
	//Check which session is
	if (session->GetMediaType()==MediaFrame::Video)
		//Limit video
		video.SetTemporalBitrateLimit(estimation);
}

void RTPParticipant::onRequestFPU()
{
	//Check
	if (listener)
		//Call listener
		listener->onRequestFPU(this);
}
int RTPParticipant::SetMute(MediaFrame::Type media, bool isMuted)
{
	//Depending on the type
	switch (media)
	{
		case MediaFrame::Audio:
			// audio
			return audio.SetMute(isMuted);
		case MediaFrame::Video:
			//Attach audio
			return video.SetMute(isMuted);
		case MediaFrame::Text:
			//text
			return text.SetMute(isMuted);
	}
	return 0;
}