#include <sys/socket.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <errno.h>
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <sys/poll.h>
#include <netinet/tcp.h>
#include <netinet/in.h>
#include <fcntl.h>
#include <signal.h>
#include <errno.h>
#include <srtp2/srtp.h>
#include <time.h>
#include "log.h"
#include "assertions.h"
#include "tools.h"
#include "codecs.h"
#include "rtp.h"
#include "rtpsession.h"
#include "stunmessage.h"
#include <openssl/opensslconf.h>
#include <openssl/ossl_typ.h>

/*************************
* RTPSession
* 	Constructro
**************************/
RTPSession::RTPSession(MediaFrame::Type media,Listener *listener) :
	transport(this),
	send(new RTPOutgoingSourceGroup(media, transport.GetTimeService())),
	recv(new RTPIncomingSourceGroup(media, transport.GetTimeService()))
{
	//Store listener
	this->listener = listener;
	//And media
	this->media = media;
	//Init values
	sendType = 0xFF;
	useRTCP = true;
	useAbsTime = false;
	firReqNum = 0;
	requestFPU = false;
	pendingTMBR = false;
	pendingTMBBitrate = 0;
	//Don't use PLI by default
	usePLI = false;
	useRTX = false;
	//Default cname
	cname = strdup("default@localhost");
	
	//Do not deletage packet handling
	delegate = false;
	
	//Empty types by defauilt
	rtpMapIn = NULL;
	rtpMapOut = NULL;
	aptMapIn = NULL;
	aptMapOut = NULL;
	//No reports
	setZeroTime(&lastFPU);
	setZeroTime(&lastReceivedSR);
	rtt = 0;
	
	//NO FEC
	useNACK = false;
	useAbsTime = false;
	isNACKEnabled = false;
	//Reduce jitter buffer to min
	packets.SetMaxWaitTime(60);
}

/*************************
* ~RTPSession
* 	Destructor
**************************/
RTPSession::~RTPSession()
{
	//Reset
	Reset();
}

void RTPSession::Reset()
{
	Log("-RTPSession reset\n");
	
	//Free mem
	if (rtpMapIn)
		delete(rtpMapIn);
	if (rtpMapOut)
		delete(rtpMapOut);
	if (aptMapIn)
		delete(aptMapIn);
	if (aptMapOut)
		delete(aptMapOut);
	if (cname)
		free(cname);
	//Reset group
	recv->ResetPackets();
	//Delete packets
	packets.Clear();
	//Reset transport
	transport.Reset();
	
	//Empty queue
	FlushRTXPackets();
	//Init values
	sendType = 0xFF;
	useAbsTime = false;
	firReqNum = 0;
	requestFPU = false;
	pendingTMBR = false;
	pendingTMBBitrate = 0;
	
	//Empty types by defauilt
	rtpMapIn = NULL;
	rtpMapOut = NULL;
	aptMapIn = NULL;
	aptMapOut = NULL;
	//No reports
	setZeroTime(&lastFPU);
	setZeroTime(&lastReceivedSR);
	rtt = 0;
	
	//NO FEC
	useNACK = false;
	useAbsTime = false;
	isNACKEnabled = false;
	//Reduce jitter buffer to min
	packets.SetMaxWaitTime(60);
	
	//Reset stream soutces
	send->media.Reset();
	recv->media.Reset();
	send->rtx.Reset();
	recv->rtx.Reset();
}

void RTPSession::FlushRTXPackets()
{
	//Lock mutex inside the method
	ScopedLock method(sendMutex);
	
	Debug("-FlushRTXPackets(%s)\n",MediaFrame::TypeToString(media));

	//Clear list
	rtxs.clear();
}

void RTPSession::SetSendingRTPMap(const RTPMap& rtpMap,const RTPMap& aptMap)
{
	//Debug
	Debug("-RTPSession::SetSendingRTPMap\n");
	rtpMap.Dump(media);
	
	//If we already have one
	if (rtpMapOut)
		//Delete it
		delete(rtpMapOut);
	//Clone it
	rtpMapOut = new RTPMap(rtpMap);
	//If we already have one
	if (aptMapOut)
		//Delete it
		delete(aptMapOut);
	//Clone it
	aptMapOut = new RTPMap(aptMap);
}

int RTPSession::SetLocalCryptoSDES(const char* suite, const char* key64)
{
	//Log
	Log("-RTPSession::SetLocalCryptoSDES(%s) | [key:%s,suite:%s]\n",MediaFrame::TypeToString(media),key64,suite);

	//Set it on transport
	int ret = transport.SetLocalCryptoSDES(suite,key64);

	//Request an intra to start clean
	if (listener)
		//Request a I frame
		listener->onFPURequested(this);

	//Evrything ok
	return ret;
}

int RTPSession::SetProperties(const Properties& properties)
{
	//Clean extension map
	extMap.clear();

	//For each property
	for (Properties::const_iterator it=properties.begin();it!=properties.end();++it)
	{
		Log("-RTPSession::SetProperties(%s) | Setting RTP property [%s:%s]\n",MediaFrame::TypeToString(media),it->first.c_str(),it->second.c_str());

		//Check
		if (it->first.compare("rtcp-mux")==0)
		{
			//Set rtcp muxing
			transport.SetMuxRTCP( atoi(it->second.c_str()) );
		} else if (it->first.compare("useRTCP")==0) {
			//Set rtx
			useRTCP = atoi(it->second.c_str());
		} else if (it->first.compare("secure")==0) {
			//Encript and decript
			transport.SetSecure(true);
		} else if (it->first.compare("ssrc")==0) {
			//Set ssrc for sending
			send->media.ssrc = atoi(it->second.c_str());
		} else if (it->first.compare("ssrcRTX")==0) {
			//Set ssrc for sending
			send->rtx.ssrc = atoi(it->second.c_str());	
		} else if (it->first.compare("cname")==0) {
			//Check if already got one
			if (cname)
				//Delete it
				free(cname);
			//Clone
			cname = strdup(it->second.c_str());
		} else if (it->first.compare("useNACK")==0) {
			//Set NACK feedback
			useNACK = atoi(it->second.c_str());
			//Enable NACK until first RTT
			isNACKEnabled = useNACK;
		} else if (it->first.compare("usePLI")==0) {
			//Set rtx
			usePLI = atoi(it->second.c_str());
		} else if (it->first.compare("useRTX")==0) {
			//Set rtx
			useRTX = atoi(it->second.c_str());
		} else if (it->first.compare("urn:ietf:params:rtp-hdrext:ssrc-audio-level")==0) {
			//Set extension
			extMap.SetCodecForType(atoi(it->second.c_str()), RTPHeaderExtension::SSRCAudioLevel);
		} else if (it->first.compare("urn:ietf:params:rtp-hdrext:toffset")==0) {
			//Set extension
			extMap.SetCodecForType(atoi(it->second.c_str()), RTPHeaderExtension::TimeOffset);
		} else if (it->first.compare("http://www.webrtc.org/experiments/rtp-hdrext/abs-send-time")==0) {
			//Set extension
			extMap.SetCodecForType(atoi(it->second.c_str()), RTPHeaderExtension::AbsoluteSendTime);
			//Use timestamsp
			useAbsTime = true;
		} else {
			Error("-RTPSession::SetProperties() | Unknown RTP property [%s]\n",it->first.c_str());
		}
	}

	return 1;
}

int RTPSession::SetLocalSTUNCredentials(const char* username, const char* pwd)
{
	//Set it on transport
	return transport.SetLocalSTUNCredentials(username,pwd);
}


int RTPSession::SetRemoteSTUNCredentials(const char* username, const char* pwd)
{
	//Set it on transport
	return transport.SetRemoteSTUNCredentials(username,pwd);
}

int RTPSession::SetRemoteCryptoDTLS(const char *setup,const char *hash,const char *fingerprint)
{
	//Set it on transport
	return transport.SetRemoteCryptoDTLS(setup,hash,fingerprint);
}

int RTPSession::SetRemoteCryptoSDES(const char* suite, const char* key64)
{
	//Set it on transport
	return transport.SetRemoteCryptoSDES(suite,key64);
}

void RTPSession::SetReceivingRTPMap(const RTPMap& rtpMap,const RTPMap& aptMap)
{
	//Debug
	Debug("-RTPSession::SetReceivingRTPMap\n");
	rtpMap.Dump(media);
	
	//If we already have one
	if (rtpMapIn)
		//Delete it
		delete(rtpMapIn);
	//Clone it
	rtpMapIn = new RTPMap(rtpMap);
	//If we already have one
	if (aptMapIn)
		//Delete it
		delete(aptMapIn);
	//Clone it
	aptMapIn = new RTPMap(aptMap);
}

int RTPSession::SetLocalPort(int recvPort)
{
	//Debug
	Debug("-RTPSession::SetLocalPort [%d]\n",recvPort);
	//Set it on transport
	return transport.SetLocalPort(recvPort);
}

int RTPSession::GetLocalPort()
{
	//Get it from transport
	return transport.GetLocalPort();
}

bool RTPSession::SetSendingCodec(DWORD codec)
{
	//Check rtp map
	if (!rtpMapOut)
		//Error
		return Error("-RTPSession::SetSendingCodec(%s) | error: no out RTP map\n",MediaFrame::TypeToString(media));

	//Try to find it in the map
	DWORD type = rtpMapOut->GetTypeForCodec(codec);
	
	//If not found
	if (type==RTPMap::NotFound)
		//Not found
		return Error("-RTPSession::SetSendingCodec(%s) | error: codec mapping not found [codec:%s]\n",MediaFrame::TypeToString(media),GetNameForCodec(media,codec));
	//Log it
	Log("-RTPSession::SetSendingCodec(%s) | [codec:%s,type:%d]\n",MediaFrame::TypeToString(media),GetNameForCodec(media,codec),type);
	//Set type
	sendType = type;
	//and we are done
	return true;
}

/***********************************
* SetRemotePort
*	Inicia la sesion rtp de video remota
***********************************/
int RTPSession::SetRemotePort(char *ip,int sendPort)
{
	//Debug
	Debug("-RTPSession::SetRemotePort [%s,%d]\n",ip,sendPort);
	//Set it on transport
	return transport.SetRemotePort(ip,sendPort);
}

/********************************
* Init
*	Inicia el control rtcp
********************************/
int RTPSession::Init()
{
	//Start recv
	recv->Start(media==MediaFrame::Video);
	//Override stimator
	recv->remoteRateEstimator.SetListener(this);
	//Start transport
	return transport.Init();
}

/*********************************
* End
*	Termina la todo
*********************************/
int RTPSession::End()
{
	//Stop recv
	recv->Stop();
	//End transport
	if (!transport.End())
		//Error
		return 0;
	
	//OK
	return 1;
}

int RTPSession::SendPacket(const RTCPCompoundPacket::shared &rtcp)
{
	//If not using RTCp
	if (!useRTCP)
		//Do nothing
		return 0;
	
	//Data
	Packet buffer;
	BYTE* data = buffer.GetData();
	size_t size = buffer.GetCapacity();

	//Lock muthed inside  method
	ScopedLock method(sendMutex);

	//Serialize
	size_t len = rtcp->Serialize(data,size);
	//Check result
	if (len<=0 || len>size)
		//Error
		return Error("-RTPSession::SendPacket(%s) | Error serializing RTCP packet [len:%lu]\n",MediaFrame::TypeToString(media),len);

	//Set serialized packet size
	buffer.SetSize(len);
	
	//Send it
	transport.SendRTCPPacket(std::move(buffer));

	//INcrease stats
	send->media.numPackets++;
	send->media.totalRTCPBytes += len;
	//Exit
	return 1;
}

int RTPSession::SendPacket(const RTPPacket::shared &packet)
{
	return SendPacket(packet,packet->GetTimestamp());
}

int RTPSession::SendPacket(const RTPPacket::shared &packet,DWORD timestamp)
{
	//Data
	Packet buffer;
	BYTE* data = buffer.GetData();
	size_t size = buffer.GetCapacity();
	
	//Check if we need to send SR (1 per second
	if (useRTCP && (!send->media.lastSenderReport || getTimeDiff(send->media.lastSenderReport)>1E6))
		//Send it
		SendSenderReport();
	
	//Check if we don't have send type yet
	if (sendType==0xFF)
	{
		//Set it
		if (!SetSendingCodec(packet->GetCodec()))
			//Error
			return Error("-No send type");
	}
	
	//Calculate last timestamp
	send->media.lastTimestamp = send->media.time + timestamp;

	//Init send packet
	packet->SetSSRC(send->media.ssrc);
	packet->SetTimestamp(send->media.lastTimestamp);
	packet->SetPayloadType(sendType);
	packet->SetExtSeqNum(send->media.NextExtSeqNum());

	//If we have are using any sending extensions
	if (useAbsTime)
		//Set abs send time
		packet->SetAbsSentTime(getTimeMS());

	//Serialize packet
	size_t len = packet->Serialize(data,size,extMap);

	//Check
	if (!len)
		//Error
		return Error("-RTPSession::SendPacket() | Error serializing rtp headers\n");

	//Set serialized packet size
	buffer.SetSize(len);
	
	//Block
	sendMutex.Lock();

	//Add it rtx queue before encripting
	if (useNACK)
		//Add it to que
		rtxs[packet->GetExtSeqNum()] = packet;
	
	//No error yet, send packet
	len = transport.SendRTPPacket(std::move(buffer));

	//Inc stats
	send->media.numPackets++;
	send->media.totalBytes += len;


	//Get time for packets to discard, always have at least 200ms, max 500ms
	QWORD until = getTimeMS() - (200+fmin(rtt*2,300));
	//Delete old packets
	RTPOrderedPackets::iterator it = rtxs.begin();
	//Until the end
	while(it!=rtxs.end())
	{
		//Check time
		if (it->second->GetTime()>until)
			//Keep the rest
			break;
		//DElete from queue and move next
		rtxs.erase(it++);
	}

	//Unlock
	sendMutex.Unlock();

	//Exit
	return (len>0);
}

void RTPSession::onRTPPacket(const BYTE* data, DWORD size)
{
	//Check rtp map
	if (!rtpMapIn)
	{
		//Error
		Error("-RTPSession::onRTPPacket(%s) | RTP map not set\n",MediaFrame::TypeToString(media));
		//Exit
		return;
	}
	//Parse rtp packet
	RTPPacket::shared packet = RTPPacket::Parse(data,size,*rtpMapIn,extMap);
	
	//Check
	if (!packet)
	{
		//Debug
		Debug("-RTPSession::onRTPPacket() | Could not parse RTP packet\n");
		//Dump it
		Dump(data,size);
		//Exit
		return;
	}
	
	//Get ssrc
	DWORD ssrc = packet->GetSSRC();
	
	//Get codec and type
	BYTE type   = packet->GetPayloadType();
	DWORD codec = packet->GetCodec();
	
	//Check codec
	if (codec==RTPMap::NotFound)
	{
		//Exit
		Error("-RTPSession::onRTPPacket(%s) | RTP packet type unknown [%d]\n",MediaFrame::TypeToString(media),type);
		//Exit
		return;
	}
	
	//Check if we got a different SSRC
	if (recv->media.ssrc!=ssrc && codec!=VideoCodec::RTX)
	{
		//Log
		Log("-RTPSession::onRTPPacket(%s) | New SSRC [new:%u,old:%u]\n",MediaFrame::TypeToString(media),ssrc,recv->media.ssrc);
		//Send SR to old one
		SendSenderReport();
		//Reset packets
		packets.Reset();
		//Reset cycles
		recv->media.Reset();
		//Update ssrc
		recv->media.ssrc = ssrc;
		//If remote estimator
		recv->remoteRateEstimator.AddStream(recv->media.ssrc);
	} else if (recv->rtx.ssrc!=ssrc && codec==VideoCodec::RTX) {
		//Log
		Log("-RTPSession::onRTPPacket(%s) | New RTX SSRC [new:%u,old:%u]\n",MediaFrame::TypeToString(media),ssrc,recv->rtx.ssrc);
		//Reset cycles
		recv->rtx.Reset();
		//Update ssrc
		recv->rtx.ssrc = ssrc;
	}
	
	//Process packet and get source
	RTPIncomingSource* source = recv->Process(packet);
	
	//Ensure it has a source
	if (!source)
	{
		//error
		Error("-RTPSession::onRTPPacket(%s) | Recv group does not contain ssrc [%u]\n",MediaFrame::TypeToString(media),ssrc);
		//Exit
		return;
	}
	
	//If it was an RTX packet and not a padding only one
	if (codec==VideoCodec::RTX && packet->GetMediaLength()) 
	{
		//Get the associated type
		type = aptMapIn->GetCodecForType(type);
		//Find codec for type
		codec = rtpMapIn->GetCodecForType(type);
		//Check codec
		if (codec==RTPMap::NotFound)
		{
			 //Error
			 Error("-RTPSession::onRTPPacket(%s) | RTP RTX packet apt type unknown [%d]\n",MediaFrame::TypeToString(media),type);
			 //Exi
			 return;
		}

		//Remove OSN and restore seq num
		if (!packet->RecoverOSN())
		{
			//Error
			Error("-RTPSession::onRTPPacket(%s) | RTP Could not recoever OSX\n",MediaFrame::TypeToString(media));
			//Exit
			return;
		}
		//Set original ssrc
		packet->SetSSRC(recv->media.ssrc);
		//Set corrected seq num cycles
		packet->SetSeqCycles(recv->media.RecoverSeqNum(packet->GetSeqNum()));
		//Set corrected timestamp cycles
		packet->SetTimestampCycles(recv->media.RecoverTimestamp(packet->GetTimestamp()));
		//Set codec
		packet->SetCodec(codec);
		packet->SetPayloadType(type);
	}	

	//if (media==MediaFrame::Video && !isRTX && seq % 40 ==0)
	//	return (void)Error("RTX: Drop %d %s packet #%d ts:%u\n",type,VideoCodec::GetNameFor((VideoCodec::Type)codec),packet->GetSeqNum(),packet->GetTimestamp());
	
	//Check if we have receiver already an SR
	if (recv->media.lastReceivedSenderReport)
	{
		//Get ntp and rtp timestamps
		QWORD timestamp = source->lastReceivedSenderRTPTimestampExtender.GetExtSeqNum();
		
		//IF packet is newer than SR (should be)
		if (timestamp<packet->GetExtTimestamp())
		{
			//Calculate sender time 
			QWORD senderTime = source->lastReceivedSenderTime + (packet->GetExtTimestamp()-timestamp)*1000/packet->GetClockRate();
			//Set calculated sender time
			packet->SetSenderTime(senderTime);
		}
	}

	//Get current time
	auto now = getTime();
		
	//Update lost packets
	int lost = recv->AddPacket(packet,size,now/1000);

	//Check if it was rejected
	if (lost<0)
	{
		//Log
		UltraDebug("-RTPSession::onRTPPacket(%s) | Dropped packet [orig:%u,ssrc:%u,seq:%d,rtx:%d]\n",MediaFrame::TypeToString(media),ssrc,packet->GetSSRC(),packet->GetSeqNum(),ssrc==recv->rtx.ssrc);
		//Increase rejected counter
		source->dropPackets++;
	} else if (lost>0) {
		//Log
		UltraDebug("-RTPSession::onRTPPacket(%s) | RTX: Missing %d [nack:%d,diff:%llu,rtt:%u]\n",MediaFrame::TypeToString(media),lost,isNACKEnabled,getDifTime(&lastFPU)/1000,rtt);
	}
	
	//If nack is enable t waiting for a PLI/FIR response (to not oeverflow)
	if (useRTCP && isNACKEnabled && getDifTime(&lastFPU)/1000>rtt/2 && lost>0)
	{
		//Create rtcp sender retpor
		auto rtcp = CreateSenderReport();
		
		//Create NACK
		auto nack = rtcp->CreatePacket<RTCPRTPFeedback>(RTCPRTPFeedback::NACK,send->media.ssrc,recv->media.ssrc);
		
		//Get nacks for lost pacekts
		for (auto field : recv->GetNacks())
			//Add it
			nack->AddField(field);
		
		//Send packet
		SendPacket(rtcp);
		//Update last time nacked
		source->lastNACKed = getTime();
		//Update nacked packets
		source->totalNACKs++;
	//Check if we need to send SR (1 per second
	} else if (useRTCP && (!send->media.lastSenderReport || getTimeDiff(send->media.lastSenderReport)>1E6)) {
		//Send it
		SendSenderReport();
	}
	
	//TODO: remove
	if (!delegate)
		//Append packet
		packets.Add(packet);

	//Check if we need to send RR (1 per second)
	if (useRTCP && now-source->lastReport>1E6)
		//Send it
		SendSenderReport();

	//OK
	return;
}

RTPPacket::shared RTPSession::GetPacket()
{
	//Wait for pacekts
	return packets.Wait();
}

void RTPSession::CancelGetPacket()
{
	//cancel
	packets.Cancel();
}

void RTPSession::onRemotePeer(const char* ip, const short port)
{
	Log("-RTPSession::onRemotePeer(%s) [%s:%hu]\n",MediaFrame::TypeToString(media),ip,port);
	
	if (listener)
		//Request FPU
		listener->onFPURequested(this);
}

void RTPSession::onRTCPPacket(const BYTE* buffer, DWORD size)
{
	//Parse it
	auto rtcp = RTCPCompoundPacket::Parse(buffer,size);
	
	//Check packet
	if (!rtcp)
		//Error
		return;
	
	//Get now
	QWORD now = getTime();
	
	//Increase stats
	recv->media.numRTCPPackets++;
	recv->media.totalRTCPBytes += rtcp->GetSize();

	//For each packet
	for (DWORD i = 0; i<rtcp->GetPacketCount();i++)
	{
		//Get pacekt
		auto packet = rtcp->GetPacket(i);
		//Check packet type
		switch (packet->GetType())
		{
			case RTCPPacket::SenderReport:
			{
				//Cast to sender report
				auto sr = std::static_pointer_cast<RTCPSenderReport>(packet);
				
				//Update source
				recv->media.Process(getTime(),sr);
				
				//Check recievd report
				for (DWORD j=0;j<sr->GetCount();j++)
				{
					//Get report
					auto report = sr->GetReport(j);
					//Check ssrc
					if (report->GetSSRC()==send->media.ssrc)
					{
						//TODO: we need to protect this by having only a single timeservice on transport
						//Proccess it
						if (send->media.ProcessReceiverReport(now/1000, report))
							//We need to update rtt
							SetRTT(send->media.rtt,now);
					}
				}
				break;
			}
			case RTCPPacket::ReceiverReport:
			{
				//Cast to receiver report
				auto rr = std::static_pointer_cast<RTCPReceiverReport>(packet);
				//Check recievd report
				for (DWORD j=0;j<rr->GetCount();j++)
				{
					//Get report
					auto report = rr->GetReport(j);
					//Check ssrc
					if (report->GetSSRC()==send->media.ssrc)
					{
						//TODO: we need to protect this by having only a single timeservice on transport
						//Proccess it
						if (send->media.ProcessReceiverReport(now/1000, report))
							//We need to update rtt
							SetRTT(send->media.rtt,now);
					}
				}
				break;
			}
				break;
			case RTCPPacket::SDES:
				break;
			case RTCPPacket::Bye:
				//Reset media
				recv->media.Reset();
				break;
			case RTCPPacket::App:
				break;
			case RTCPPacket::RTPFeedback:
			{
				//cast to feedback packet
				auto fb = std::static_pointer_cast<RTCPRTPFeedback>(packet);
				//Check feedback type
				switch(fb->GetFeedbackType())
				{
					case RTCPRTPFeedback::NACK:
						for (DWORD i=0;i<fb->GetFieldCount();i++)
						{
							//Get field
							auto field = fb->GetField<RTCPRTPFeedback::NACKField>(i);
							//Resent it
							ReSendPacket(field->pid);
							//Check each bit of the mask
							for (int i=0;i<16;i++)
								//Check it bit is present to rtx the packets
								if ((field->blp >> i) & 1)
									//Resent it
									ReSendPacket(field->pid+i+1);
						}
						break;
					case RTCPRTPFeedback::TempMaxMediaStreamBitrateRequest:
						//Debug("-TempMaxMediaStreamBitrateRequest\n");
						for (DWORD i=0;i<fb->GetFieldCount();i++)
						{
							//Get field
							auto field = fb->GetField<RTCPRTPFeedback::TempMaxMediaStreamBitrateField>(i);
							//Check if it is for us
							if (listener && field->GetSSRC()==send->media.ssrc)
								//call listener
								listener->onTempMaxMediaStreamBitrateRequest(this,field->GetBitrate(),field->GetOverhead());
						}
						break;
					case RTCPRTPFeedback::TempMaxMediaStreamBitrateNotification:
						//Debug("-RTPSession::ProcessRTCPPacket() | TempMaxMediaStreamBitrateNotification\n");
						pendingTMBR = false;
						if (requestFPU)
						{
							requestFPU = false;
							SendFIR();
						}
						/*
						for (DWORD i=0;i<fb->GetFieldCount();i++)
						{
							//Get field
							const RTCPRTPFeedback::TempMaxMediaStreamBitrateField *field = (const RTCPRTPFeedback::TempMaxMediaStreamBitrateField*) fb->GetField(i);
						}
						*/
						break;
					case RTCPRTPFeedback::TransportWideFeedbackMessage:
						break;
				}
				break;
			}
			case RTCPPacket::PayloadFeedback:
			{
				//cast to feedback packet
				auto fb = std::static_pointer_cast<RTCPPayloadFeedback>(packet);
				//Check feedback type
				switch(fb->GetFeedbackType())
				{
					case RTCPPayloadFeedback::PictureLossIndication:
					case RTCPPayloadFeedback::FullIntraRequest:
						Debug("-RTPSession::ProcessRTCPPacket() | FPU requested\n");
						//Chec listener
						if (listener)
							//Send intra refresh
							listener->onFPURequested(this);
						break;
					case RTCPPayloadFeedback::SliceLossIndication:
						Debug("-RTPSession::ProcessRTCPPacket() | SliceLossIndication\n");
						break;
					case RTCPPayloadFeedback::ReferencePictureSelectionIndication:
						Debug("-RTPSession::ProcessRTCPPacket() | ReferencePictureSelectionIndication\n");
						break;
					case RTCPPayloadFeedback::TemporalSpatialTradeOffRequest:
						Debug("-RTPSession::ProcessRTCPPacket() | TemporalSpatialTradeOffRequest\n");
						break;
					case RTCPPayloadFeedback::TemporalSpatialTradeOffNotification:
						Debug("-RTPSession::ProcessRTCPPacket() | TemporalSpatialTradeOffNotification\n");
						break;
					case RTCPPayloadFeedback::VideoBackChannelMessage:
						Debug("-RTPSession::ProcessRTCPPacket() | VideoBackChannelMessage\n");
						break;
					case RTCPPayloadFeedback::ApplicationLayerFeeedbackMessage:
						for (DWORD i=0;i<fb->GetFieldCount();i++)
						{
							//Get feedback
							auto msg = fb->GetField<RTCPPayloadFeedback::ApplicationLayerFeeedbackField>(i);
							//Get size and payload
							DWORD len		= msg->GetLength();
							const BYTE* payload	= msg->GetPayload();
							//Check if it is a REMB
							if (len>8 && payload[0]=='R' && payload[1]=='E' && payload[2]=='M' && payload[3]=='B')
							{
								//GEt exponent
								BYTE exp = payload[5] >> 2;
								DWORD mantisa = payload[5] & 0x03;
								mantisa = mantisa << 8 | payload[6];
								mantisa = mantisa << 8 | payload[7];
								//Get bitrate
								DWORD bitrate = mantisa << exp;
								//Check if it is for us
								if (listener)
									//call listener
									listener->onReceiverEstimatedMaxBitrate(this,bitrate);
							}
						}
						break;
					case RTCPPayloadFeedback::UNKNOWN:
						break;
				}
				break;
			}
			case RTCPPacket::FullIntraRequest:
				//This is message deprecated and just for H261, but just in case
				//Check listener
				if (listener)
					//Send intra refresh
					listener->onFPURequested(this);
				break;
			case RTCPPacket::NACK:
				Log("-RTPSession::ProcessRTCPPacket() | NACK!\n");
				break;
			case RTCPRTPFeedback::ExtendedJitterReport:
				break;	
		}
	}

}

RTCPCompoundPacket::shared RTPSession::CreateSenderReport()
{
	//Create packet
	auto rtcp = std::make_shared<RTCPCompoundPacket>();

	//Get now
	QWORD now = getTime();

	//Create report for receiver stream
	auto report = recv->media.CreateReport(now);
	
	//Check it we have sent anything
	if (!send->media.numPackets)
	{
		//Create sender report for normal stream
		auto sr = send->media.CreateSenderReport(now);
		
		//If got anything
		if (report)
			//Append it
			sr->AddReport(report);
		//Create sender report for RTX stream
		auto rtx = recv->rtx.CreateReport(now);
		//If got anything
		if (rtx)
			//Append it
			sr->AddReport(rtx);
		//Append SR to rtcp
		rtcp->AddPacket(sr);
	} else {
		//Create Sender report
		auto rr = std::make_shared<RTCPReceiverReport>();

		//If got anything
		if (report)
			//Append it
			rr->AddReport(report);
		
		//Append RR to rtcp
		rtcp->AddPacket(rr);
	}
	
	//Create SDES packet
	auto sdes = rtcp->CreatePacket<RTCPSDES>();
	//Create description
	auto desc = sdes->CreateDescription(send->media.ssrc);
	//Add item
	desc->CreateItem(RTCPSDES::Item::CName,cname);
	
	//Return it
	return rtcp;
}

int RTPSession::SendSenderReport()
{
	if (!useRTCP)
		return 0;
	
	//Create rtcp sender retpor
	auto rtcp = CreateSenderReport();
	
	//Get lastest estimation and convert to kbps
	DWORD estimation = recv->remoteRateEstimator.GetEstimatedBitrate();
	
	//If it was ok
	if (estimation)
	{
		//Resend TMMBR
		auto tmmbr = rtcp->CreatePacket<RTCPRTPFeedback>(RTCPRTPFeedback::TempMaxMediaStreamBitrateRequest,send->media.ssrc,recv->media.ssrc);
		//Limit incoming bitrate
		tmmbr->CreateField<RTCPRTPFeedback::TempMaxMediaStreamBitrateField>(recv->media.ssrc,estimation,WORD(0));
		//Get ssrcs
		std::list<DWORD> ssrcs;
		recv->remoteRateEstimator.GetSSRCs(ssrcs);
		//Create feedback
		// SSRC of media source (32 bits):  Always 0; this is the same convention as in [RFC5104] section 4.2.2.2 (TMMBN).
		auto remb = rtcp->CreatePacket<RTCPPayloadFeedback>(RTCPPayloadFeedback::ApplicationLayerFeeedbackMessage,send->media.ssrc,WORD(0));
		//Send estimation
		remb->AddField(RTCPPayloadFeedback::ApplicationLayerFeeedbackField::CreateReceiverEstimatedMaxBitrate(ssrcs,estimation));
	}

	//Send packet
	int ret =  SendPacket(rtcp);

	//Exit
	return ret;
}

int RTPSession::SendFIR()
{
	//If not using RTCp
	if (!useRTCP)
		//Do nothing
		return 0;
	
	Debug("-RTPSession::SendFIR()\n");

	//Create rtcp sender retpor
	RTCPCompoundPacket::shared rtcp = CreateSenderReport();

	//Check mode
	if (!usePLI) 
	{
		//Create fir request
		auto fir = rtcp->CreatePacket<RTCPPayloadFeedback>(RTCPPayloadFeedback::FullIntraRequest,send->media.ssrc,recv->media.ssrc);
		//ADD field
		fir->CreateField<RTCPPayloadFeedback::FullIntraRequestField>(recv->media.ssrc,firReqNum++);
	} else {
		//Add PLI
		auto pli = rtcp->CreatePacket<RTCPPayloadFeedback>(RTCPPayloadFeedback::PictureLossIndication,send->media.ssrc,recv->media.ssrc);
	}

	//Send packet
	int ret = SendPacket(rtcp);

	//Exit
	return ret;
}

int RTPSession::RequestFPU()
{
	//If not using RTCp
	if (!useRTCP)
		//Do nothing
		return 0;
	
	Debug("-RTPSession::RequestFPU()\n");
	//Execute on the event loop thread and wait
	transport.GetTimeService().Sync([=](auto now){
		//Reset pacekts
		recv->ResetPackets();
	});
	//Drop all paquets queued, we could also hurry up
	packets.Reset();
	//Do not wait until next RTCP SR
	packets.SetMaxWaitTime(0);
	//request FIR
	SendFIR();
	//Update last request FPU
	getUpdDifTime(&lastFPU);

	//OK
	return 1;
}

void RTPSession::SetRTT(DWORD rtt,QWORD now)
{
	//Set it
	this->rtt = rtt;
	//Set group rtt
	recv->SetRTT(rtt,now/1000);
	//Check RTT to enable NACK
	if (useNACK && rtt < 240)
	{
		//Enable NACK only if RTT is small
		isNACKEnabled = true;
		//Update jitter buffer size in ms in [60+rtt,300]
		packets.SetMaxWaitTime(fmin(60+rtt,300));
	} else {
		//Disable NACK
		isNACKEnabled = false;
		//Reduce jitter buffer as we don't use NACK
		packets.SetMaxWaitTime(60);
	}
	//Debug
	UltraDebug("-RTPSession::SetRTT(%s) | [%dms,nack:%d]\n",MediaFrame::TypeToString(media),rtt,isNACKEnabled);
}

void RTPSession::onTargetBitrateRequested(DWORD bitrate, DWORD bandwidthEstimation, DWORD totalBitrate)
{
	//If not using RTCp
	if (!useRTCP)
		//Do nothing
		return;
	
	UltraDebug("-RTPSession::onTargetBitrateRequested() | [%d]\n",bitrate);

	//Create rtcp sender retpor
	auto rtcp = CreateSenderReport();
	//Create TMMBR
	auto tmmbr = rtcp->CreatePacket<RTCPRTPFeedback>(RTCPRTPFeedback::TempMaxMediaStreamBitrateRequest,send->media.ssrc,recv->media.ssrc);
	//Limit incoming bitrate
	tmmbr->CreateField<RTCPRTPFeedback::TempMaxMediaStreamBitrateField>(recv->media.ssrc,bitrate,WORD(0));

	//We have a pending request
	pendingTMBR = true;
	//Store values
	pendingTMBBitrate = bitrate;

	//Send packet
	SendPacket(rtcp);
}

int RTPSession::ReSendPacket(int seq)
{
	//Lock send lock inside the method
	ScopedLock method(sendMutex);

	//Calculate ext seq number
	DWORD ext = ((DWORD)send->media.cycles)<<16 | seq;

	//Find packet to retransmit
	RTPOrderedPackets::iterator it = rtxs.find(ext);

	//If we don't have it
	if (it==rtxs.end())
	{
		UltraDebug("-RTPSession::ReSendPacket() | %d:%d %d not found first %d sending intra instead\n",send->media.cycles,seq,ext,rtxs.size() ?  rtxs.begin()->first : 0);
		//Check if got listener
		if (listener)
			//Request a I frame
			listener->onFPURequested(this);
		//Empty rtx queue
		rtxs.clear();
		return 0;
	}

	//Get packet clone
	auto packet = it->second->Clone();

	//If usint RTX type for retransmission
	if (useRTX) 
	{
		//Get apt type
		BYTE apt = aptMapOut->GetTypeForCodec(packet->GetPayloadType());
		
		//Update RTX headers
		packet->SetSSRC(send->rtx.ssrc);
		packet->SetOSN(send->rtx.NextSeqNum());
		packet->SetPayloadType(apt);
		//No padding
		packet->SetPadding(0);
		//Increase counters
		send->rtx.numPackets++;
		send->rtx.totalBytes += packet->GetMediaLength()+2;
	}
	
	//If using abs-time
	if (useAbsTime)
		//Set abs send time
		packet->SetAbsSentTime(getTimeMS());

	//Data
	Packet buffer;
	BYTE* data = buffer.GetData();
	size_t size = buffer.GetCapacity();

	//Serialize data
	int len = packet->Serialize(data,size,extMap);

	//Set serialized packet size
	buffer.SetSize(len);

	//Send packet
	transport.SendRTPPacket(std::move(buffer));
	
	//OK
	return 1;
}

int RTPSession::SendTempMaxMediaStreamBitrateNotification(DWORD bitrate,DWORD overhead)
{
	//If not using RTCp
	if (!useRTCP)
		//Do nothing
		return 0;
	
	//Create rtcp sender retpor
	auto rtcp = CreateSenderReport();

	//Create TMMBN
	auto tmmbn = rtcp->CreatePacket<RTCPRTPFeedback>(RTCPRTPFeedback::TempMaxMediaStreamBitrateNotification,send->media.ssrc,recv->media.ssrc);
	//Limit incoming bitrate
	tmmbn->CreateField<RTCPRTPFeedback::TempMaxMediaStreamBitrateField>(send->media.ssrc,bitrate,WORD(0));

	//Send packet
	return SendPacket(rtcp);
}