#include "tools.h"
#include "Buffer.h"
#include "rtmp/rtmpmessage.h"
#include "avcdescriptor.h"
#include <stdexcept>
#include <cstdlib>


namespace 
{

/**
 * Get signed 24bit integer
 */
int32_t GetSI24(const uint8_t* data)
{
	return (int32_t(get3(data, 0)) << 8) >> 8;
}


std::string Uint32ToFourCcStr(uint32_t value)
{
	std::string str;
	for (size_t i = 0; i < sizeof(uint32_t); i++)
	{
		str.push_back(char(value >> (8 * (sizeof(uint32_t) - i - 1))));
	}
	
	return str;
}

}


/************************************
 * RTMPMesssage
 *
 ***********************************/

RTMPMessage::RTMPMessage(DWORD streamId,QWORD timestamp,Type type,DWORD length) 
{
	//Store values
	this->streamId 	= streamId;
	this->type 	= type;
	this->length 	= length;
	this->timestamp = timestamp;

	//Nothing
	cmd 	= NULL;
	ctrl 	= NULL;
	meta 	= NULL;
	media 	= NULL;

	//No skip
	skip = false;

	//Depending on the type
	switch(type)
	{
		case SetChunkSize:
			//Create ctrl msg
			ctrl = new RTMPSetChunkSize();
			break;
                case AbortMessage:
			//Create ctrl msg
			ctrl = new RTMPAbortMessage();
			break;
                case Acknowledgement:
			//Create ctrl msg
			ctrl = new RTMPAcknowledgement();
			break;
                case UserControlMessage:
			//Create ctrl msg
			ctrl = new RTMPUserControlMessage();
			break;
                case WindowAcknowledgementSize:
			//Create ctrl msg
			ctrl = new RTMPWindowAcknowledgementSize();
			break;
                case SetPeerBandwidth:
			//Create ctrl msg
			ctrl = new RTMPSetPeerBandWidth();
			break;
		case CommandAMF3:
			//Skip first byte if cero
			skip = true;
			//Create cmd message
			cmd = new RTMPCommandMessage();
			break;
		case Command:
			//Create cmd message
			cmd = new RTMPCommandMessage();
			break;
		case DataAMF3:
			//Skip first byte if cero
			skip = true;
			//Reset amf parser
			meta = new RTMPMetaData(timestamp);
			break;
		case Data:
			//Reset amf parser
			meta = new RTMPMetaData(timestamp);
			break;
		case SharedObjectAMF3:
		case RTMPMessage::SharedObject:
			//TODO: parse shared object
			break;
		case Audio:
			//Check length
			if (length)
				//Create frame
				media = new RTMPAudioFrame(timestamp,length);
			break;
		case Video:
			//Check length
			if (length)
				//Create frame
				media = new RTMPVideoFrame(timestamp,length);
			break;
		default:
			//Throw exception
			throw std::runtime_error("RTMP Message not supported");
	}
	
	//Check size of control messages,except for UserControlMessage that can have 2 different sizes
	if (ctrl && type!=UserControlMessage && ctrl->GetSize()!=length)
		//Throw exception
		throw std::runtime_error("Wrong size for control message");

	//Init position
	pos = 0;
	//We are parsing again
	parsing = (pos!=length);
}

RTMPMessage::RTMPMessage(DWORD streamId,QWORD timestamp,Type type,RTMPObject* ctrl) 
{
	//Store values
	this->streamId = streamId;
	this->type = type;
	this->timestamp = timestamp;
	//Calculate message size
	this->length = ctrl->GetSize();
	//Store msg
	this->ctrl = ctrl;
	this->cmd = NULL;
	this->meta = NULL;
	this->media = NULL;
}

RTMPMessage::RTMPMessage(DWORD streamId,QWORD timestamp,RTMPCommandMessage* cmd)
{
	//Store values
	this->streamId = streamId;
	this->type = RTMPMessage::Command;
	this->timestamp = timestamp;
	//Calculate message size
	this->length = cmd->GetSize();
	//Store msg
	this->ctrl = NULL;
	this->cmd = cmd;
	this->meta = NULL;
	this->media = NULL;
}

RTMPMessage::RTMPMessage(DWORD streamId,QWORD timestamp,RTMPMediaFrame* media)
{
	//Store values
	this->streamId = streamId;
	
	switch(media->GetType())
	{
		case RTMPMediaFrame::Audio:
			this->type = RTMPMessage::Audio;
			break;
		case RTMPMediaFrame::Video:
			this->type = RTMPMessage::Video;
			break;
	}
	this->timestamp = timestamp;
	//Calculate message size
	this->length = media->GetSize();
	//Store msg
	this->ctrl = NULL;
	this->cmd = NULL;
	this->meta = NULL;
	this->media = media;
}

RTMPMessage::RTMPMessage(DWORD streamId,QWORD timestamp,RTMPMetaData* meta)
{
	//Store values
	this->streamId = streamId;
	this->type = RTMPMessage::Data;
	this->timestamp = timestamp;
	//Calculate message size
	this->length = meta->GetSize();
	//Store msg
	this->ctrl = NULL;
	this->cmd = NULL;
	this->meta = meta;
	this->media = NULL;
}

RTMPMessage::~RTMPMessage()
{
	//Free
	if (ctrl)	
		delete(ctrl);
	if (cmd)
		delete(cmd);
	if (meta)
		delete(meta);
	if (media)
		delete(media);
}

DWORD RTMPMessage::Serialize(BYTE* data,DWORD size)
{
	if (ctrl)
		return ctrl->Serialize(data,size);
	if (cmd)
		return cmd->Serialize(data,size);
	if (meta)
		return meta->Serialize(data,size);
	if (media)
		return media->Serialize(data,size);
	return 0;
}

void RTMPMessage::Dump()
{
	Debug("[RTMPMessage type:%s,streamId:%u,length:%u,timestamp:%lu]\n",TypeToString(type),streamId,length,timestamp);
	if (ctrl)
	{
		//Check type
		switch((RTMPMessage::Type)type)
		{
			case RTMPMessage::SetChunkSize:
				//Get new chunk size
				Debug("\tSetChunkSize [size:%d]\n",((RTMPSetChunkSize *)ctrl)->GetChunkSize());
				break;
			case RTMPMessage:: AbortMessage:
				Debug("\tAbortMessage [chunkId:%d]\n",((RTMPAbortMessage*)ctrl)->GetChunkStreamId());
				break;
			case RTMPMessage::Acknowledgement:
				Debug("\tAcknowledgement [seq:%d]\n",((RTMPAcknowledgement*)ctrl)->GetSeNumber());
				break;
			case RTMPMessage::UserControlMessage:
			{
				//Get event
				RTMPUserControlMessage* event = (RTMPUserControlMessage*)ctrl;
				Debug("\tUserControl [%d] ",event->GetEventType());
				//Depending on the event received
				switch(event->GetEventType())
				{
					case RTMPUserControlMessage::StreamBegin:
						Debug("StreamBegin [stream:%d]\n",event->GetEventData());
						break;
					case RTMPUserControlMessage::StreamEOF:
						Debug("StreamEOF [stream:%d]\n",event->GetEventData());
						break;
					case RTMPUserControlMessage::StreamDry:
						Debug("StreamDry [stream:%d]\n",event->GetEventData());
						break;
					case RTMPUserControlMessage::SetBufferLength:
						Debug("SetBufferLength [stream:%d,size:%d]\n",event->GetEventData(),event->GetEventData2());
						break;
					case RTMPUserControlMessage::StreamIsRecorded:
						Debug("StreamIsRecorded [stream:%d]\n",event->GetEventData());
						break;
					case RTMPUserControlMessage::PingRequest:
						Debug("PingRequest [milis:%d]\n",event->GetEventData());
						break;
					case RTMPUserControlMessage::PingResponse:
						Debug("PingResponse [milis:%d]\n",event->GetEventData());
						break;

				}
			}
				break;
			case RTMPMessage::WindowAcknowledgementSize:
				Debug("\tWindowAcknowledgementSize [size:%d]\n",((RTMPWindowAcknowledgementSize*)ctrl)->GetWindowSize());
				break;
			case RTMPMessage::SetPeerBandwidth:
				Debug("\tSetPeerBandwidth [size:%d]\n",((RTMPSetPeerBandWidth*)ctrl)->GetWindowSize());
				break;
			default:
				Debug("\tUnknown type [type:%d]\n",type);
				break;
		}
	}
	if (cmd)
		 cmd->Dump();
	if (meta)
		 meta->Dump();
	if (media)
		 media->Dump();
	Debug("[/RTMPMessage]\n");
}

DWORD RTMPMessage::Parse(BYTE* data,DWORD size)
{
	//IF already parsed
	if (IsParsed())
		//Done
		return 0;

	//Get pointer and data size
	DWORD len = size;

	//Get reamining data
	DWORD left = GetLeft();
	
	//Check if have consumed all input but still we are not parsed
	if (!left)
		//Throw exception
		throw std::runtime_error("Wrong size for message");

	//Check sizes
	if (len > left)
		//Limit size
		len = left;

	if (IsControlProtocolMessage())
	{
		//Check if we have a ctrl object and parse
		if (ctrl)
		{
			//Parse
			pos += ctrl->Parse(data,len);
			//Check if we have finished
			parsing = !ctrl->IsParsed();
		}
	} else if (IsCommandMessage()) {
		//Check if we have a msg and parse
		if (cmd)
		{
			//If it is an amf3 object skip the first byte if 0
			if (skip && data[0]==0)
			{
				//Parse
				pos +=  cmd->Parse(data+1,len-1)+1;
				//Not skip more
				skip = false;
			} else 
				//Parse
				pos +=  cmd->Parse(data,len);
		}
		//Check if we have finished
		parsing = (pos!=length);
	} else if (IsMedia()) {
		//Check we have buffer allocated
		if (media)
			//Parse the media
			pos += media->Parse(data,len);
		//Check if we have finished
		parsing = (pos!=length);
	} else if (IsMetaData()) {
		if (meta)
		{
			//If it is an amf3 object skip the first byte if 0
			if (skip && data[0]==0)
			{
				//Parse
				pos += meta->Parse(data+1,len-1)+1;
				//Not skip more
				skip = false;
			} else 
				//Parse
				pos += meta->Parse(data,len);
			
		}
		//Check if we have finished
		parsing = (pos!=length);
	} else if (IsSharedObject()) {
		//Skip 
		pos +=len;
		//Check if we have finished
		parsing = (pos!=length);
	} else {
		//Skip 
		pos +=len;
		//Check if we have finished
		parsing = (pos!=length);
	}

	return len;
}

bool RTMPMessage::IsParsed()
{
	return !parsing;
}

DWORD RTMPMessage::GetLeft()
{
	return length - pos;
}

bool RTMPMessage::IsControlProtocolMessage()
{
	//Depending on the type
	switch(type)
	{
		case RTMPMessage::SetChunkSize:
                case RTMPMessage::AbortMessage:
                case RTMPMessage::Acknowledgement:
                case RTMPMessage::UserControlMessage:
                case RTMPMessage::WindowAcknowledgementSize:
                case RTMPMessage::SetPeerBandwidth:
			return true;
		default:
			return false;
	}
	return false;
}

bool RTMPMessage::IsCommandMessage()
{
	//Depending on the type
	switch(type)
	{
		case RTMPMessage::Command:
		case RTMPMessage::CommandAMF3:
			return true;
		default:
			return false;
	}
	return false;
}

bool RTMPMessage::IsMetaData()
{
	//Depending on the type
	switch(type)
	{
		case RTMPMessage::Data:
		case RTMPMessage::DataAMF3:
			return true;
		default:
			return false;
	}
	return false;
}

bool RTMPMessage::IsSharedObject()
{
	//Depending on the type
	switch(type)
	{
		case RTMPMessage::SharedObject:
		case RTMPMessage::SharedObjectAMF3:
			return true;
		default:
			return false;
	}
	return false;
}

bool RTMPMessage::IsMedia()
{
	//Depending on the type
	switch(type)
	{
		case RTMPMessage::Audio:
		case RTMPMessage::Video:
			return true;
		default:
			return false;
	}
	return false;
}


/********************************
 * RTMPCommandMessage
 *
 *********************************/
RTMPCommandMessage::RTMPCommandMessage()
{
	//Set data to null
	name = NULL;
	transId = NULL;
	params = NULL;
}

RTMPCommandMessage::RTMPCommandMessage(const wchar_t* name,QWORD transId,AMFData* params,AMFData* extra)
{
	//Set name
	this->name = new AMFString();
	this->name->SetWString(name);
	//Set transId
	this->transId = new AMFNumber();
	this->transId->SetNumber(transId);
	//Store objects
	if (params)
	    //Store object
	    this->params = params;
	else
	    //Create null object
	    this->params = new AMFNull();
	//If extra
	if (extra)
		this->extra.push_back(extra);
}

RTMPCommandMessage::RTMPCommandMessage(const wchar_t* name,QWORD transId,AMFData* params,const std::vector<AMFData*>& extra)
{
	//Set name
	this->name = new AMFString();
	this->name->SetWString(name);
	//Set transId
	this->transId = new AMFNumber();
	this->transId->SetNumber(transId);
	//Store objects
	if (params)
	    //Store object
	    this->params = params;
	else
	    //Create null object
	    this->params = new AMFNull();
	//If extra
	this->extra = extra;
}

RTMPCommandMessage::~RTMPCommandMessage()
{
	//If parsed objects
	if (name)
		delete(name);	
	if (transId)
		delete(transId);	
	if (params)
		delete(params);	
	//For each extra param
	for(DWORD i=0;i<extra.size();i++)
		//Delete object
		delete(extra[i]);
}

DWORD RTMPCommandMessage::Parse(BYTE *data,DWORD size)
{
	BYTE* buffer = data;
	DWORD bufferSize = size;

	while(bufferSize)
	{
		//Parse amf object
		DWORD len = parser.Parse(buffer,bufferSize);
		//If not parsed
		if (!len)
			return 0;

		//Remove used data
		buffer += len;
		bufferSize -= len;

		//Check if we got another object
		if (parser.IsParsed())
		{
			//Get Object
			AMFData* obj = parser.GetObject();
			//Dependind on the parsing state
			if (!name)
			{	
				//Assert it is a string
				obj->AssertType(AMFData::String);
				//Set cmd name
				name = (AMFString*)obj;
			} else if (!transId) {
				//Assert it is a number
				obj->AssertType(AMFData::Number);
				//Set transaction id
				transId = (AMFNumber*)obj;
			} else if (!params) {
				//Set param object
				params = obj;
			} else {
				//Add extra objects
				extra.push_back(obj);
			}
		}
	}

	return (buffer-data);
}

void RTMPCommandMessage::Dump()
{
	AMFNull null;

	Debug("[RTMPCommandMessage name:%ls transId:%d]\n",name ? name->GetWString().c_str() : L"<null>" ,transId ? (DWORD)transId->GetNumber() : 0);
	
	if (params)
		params->Dump();
	else
		null.Dump();
	
	for(DWORD i=0;i<extra.size();i++)
	{
		//Get object
		AMFData* obj = extra[i];
		//Check param
		if (obj)
			obj->Dump();
		else
			null.Dump();
	}
	Debug("[/RTMPCommandMessage]\n");
}


DWORD RTMPCommandMessage::Serialize(BYTE* buffer,DWORD size)
{
	AMFNull null;

	//Calculate size
	DWORD len = GetSize();

	//Check if we have enought size
	if (size<len)
		//Throw error
		return -1;
	
	//Reset
	len = 0;

	//Check if we have name
	if (name)
		//Serialize name
		len += name->Serialize(buffer+len,size-len);
	else
		len += null.Serialize(buffer+len,size-len);
	//Check if we have trans id
	if (transId)
		//Serialize trans id
		len += transId->Serialize(buffer+len,size-len);
	else	
		len += null.Serialize(buffer+len,size-len);
	//Check if we have params
	if (params)
		//Serialize params
		len += params->Serialize(buffer+len,size-len);
	else
		len += null.Serialize(buffer+len,size-len);
	
	//Check if we have extr;	
	for(DWORD i=0;i<extra.size();i++)
	{
		//Get object
		AMFData* obj = extra[i];
		//Check param
		if (obj)
			//Serialize extra
			len += obj->Serialize(buffer+len,size-len);
		else
			//Serialize null
			len += null.Serialize(buffer+len,size-len);
	}

	return len;	

}

DWORD RTMPCommandMessage::GetSize()
{
	AMFNull null;

	//Get base length
	DWORD len = 0;

	//Check if we have name
	if (name)
		len += name->GetSize();
	else
		len += null.GetSize();
	//Check if we have trans id
	if (transId)
		len += transId->GetSize();
	else
		len += null.GetSize();

	//Check if we have params
	if (params)
		len += params->GetSize();
	else
		len += null.GetSize();

	//Check if we have extr;	
	for(DWORD i=0;i<extra.size();i++)
	{
		//Get object
		AMFData* obj = extra[i];
		//Check param
		if (obj)
			//Get extra size
			len += obj->GetSize();
		else
			//Add null
			len += null.GetSize();
	}

	//Return lengt
	return len;
}

RTMPCommandMessage* RTMPCommandMessage::Clone() const 
{
	std::vector<AMFData*> extras;
	for (auto ext : extra)
		extras.push_back(ext ? ext->Clone() : nullptr);
	
	return new RTMPCommandMessage(
		name->GetWChar(),
		transId->GetNumber(),
		params ? params->Clone() : nullptr,
		extras
	);
}
/************************
 * RTMPMetaData
 *
 *************************/	
RTMPMetaData::RTMPMetaData(QWORD timestamp)
{
	//Store timestamp
	this->timestamp = timestamp;
}

RTMPMetaData* RTMPMetaData::Clone()
{
	RTMPMetaData* obj = new RTMPMetaData(timestamp);
	//for each extra param
	for(DWORD i=0;i<params.size();i++)
		//Clone and add
		obj->AddParam(params[i]->Clone());
	//Return
	return obj;
}


RTMPMetaData::~RTMPMetaData()
{
	//for each extra param
	for(DWORD i=0;i<params.size();i++)
		//Delete object
		delete(params[i]);
}


DWORD RTMPMetaData::Parse(BYTE *data,DWORD size)
{

	BYTE* buffer = data;
	DWORD bufferSize = size;

	while(bufferSize)
	{
		//Parse amf object
		DWORD len = parser.Parse(buffer,bufferSize);
		
		//If not parsed
		if (!len)
			return 0;

		//Remove used data
		buffer += len;
		bufferSize -= len;

		//Check if we got another object
		if (parser.IsParsed())
		{
			//Get Object
			AMFData* obj = parser.GetObject();
			//Add param
			params.push_back(obj);
		}
	}

	return (buffer-data);
}

DWORD RTMPMetaData::GetSize()
{
	//Get base length
	DWORD len = 0;

	//Check if we have extr;	
	for(DWORD i=0;i<params.size();i++)
		//Get extra size
		len += params[i]->GetSize();

	//Return length
	return len;
}

DWORD RTMPMetaData::Serialize(BYTE* buffer,DWORD size)
{
	AMFNull null;

	//Calculate size
	DWORD len = GetSize();

	//Check if we have enought size
	if (size<len)
		//Throw error
		return -1;
	
	//Reset
	len = 0;

	//Check if we have params;	
	for(DWORD i=0;i<params.size();i++)
		len += params[i]->Serialize(buffer+len,size-len);

	return len;	

}

DWORD RTMPMetaData::GetParamsLength()
{
	return params.size();
}

AMFData* RTMPMetaData::GetParams(DWORD i)
{
	return params[i];
}

void RTMPMetaData::AddParam(AMFData* param)
{
	params.push_back(param);
}


void RTMPMetaData::Dump()
{
	Debug("[RTMPMetaData ts=%lld]\n",timestamp);
	for(DWORD i=0;i<params.size();i++)
		params[i]->Dump();
	Debug("[/RTMPMetaData]\n");
}
/*************************
 * MediaFrame
 *
 ************************/

RTMPMediaFrame::RTMPMediaFrame(Type type, QWORD timestamp, const Buffer::shared& buffer) :
	type(type),
	timestamp(timestamp),
	buffer(buffer)
{
	//Not owned buffer
	ownedBuffer = false;
}

RTMPMediaFrame::RTMPMediaFrame(Type type, QWORD timestamp,DWORD size) :
	type(type),
	timestamp(timestamp)
{
	ResetData(size);
}

DWORD RTMPMediaFrame::Parse(BYTE *data,DWORD size)
{
	//Append to buffer
	AppendMedia(data, size);
	//Return consumed data length
	return size;
}

DWORD RTMPMediaFrame::Serialize(BYTE* data,DWORD size)
{
	//Check if enought space
	if (size < buffer->GetSize())
		//Failed
		return 0;

	//Copy data
	memcpy(data, buffer->GetData(), buffer->GetSize());
	
	//Exit
	return buffer->GetSize();
}


void RTMPMediaFrame::Dump()
{
	//Dump
	Debug("[MediaFrame type:%d timestamp:%lld mediaSize:%zu]\n",type,timestamp, buffer->GetSize());
	if(buffer->GetSize() >8)
		::Dump(buffer->GetData(), 8);
	else
		::Dump(buffer->GetData(), buffer->GetSize());
	Debug("[/MediaFrame]\n");
}

RTMPVideoFrame::RTMPVideoFrame(QWORD timestamp, const Buffer::shared& buffer) : RTMPMediaFrame(Video, timestamp, buffer)
{
}


RTMPVideoFrame::RTMPVideoFrame(QWORD timestamp,DWORD size) : RTMPMediaFrame(Video,timestamp,size)
{
}

RTMPVideoFrame::RTMPVideoFrame(QWORD timestamp,const AVCDescriptor &desc) : RTMPMediaFrame(Video,timestamp, desc.GetSize())
{
	//Set type
	SetVideoCodec(RTMPVideoFrame::AVC);
	//Set type
	SetFrameType(RTMPVideoFrame::INTRA);
	//Set NALU type
	SetAVCType(AVCHEADER);
	//Set no delay
	SetAVCTS(0);
	//Serialize
	DWORD size = desc.Serialize(buffer->GetData(), buffer->GetCapacity());
	//Set new length
	buffer->SetSize(size);
}

void RTMPVideoFrame::Dump()
{
	//Dump
	if (!isExtended)
	{
		Debug("[VideoFrame extended: false codec: %d frameType:%d timestamp:%lld mediaSize:%zu]\n",codec,frameType,timestamp,buffer->GetSize());
		
		if (codec==AVC)
			Debug("\t[AVC header 0x%.2x 0x%.2x 0x%.2x 0x%.2x /]\n",extraData[0],extraData[1],extraData[2],extraData[3]);
		if (codec==AVC && IsConfig())
		{
			//Paser AVCDesc
			AVCDescriptor desc;
			//Parse it
			desc.Parse(buffer->GetData(), buffer->GetSize());
			//Dump it
			desc.Dump();

		} else if(buffer->GetSize() > 16) {
			//Dump first 16 bytes only
			::Dump(buffer->GetData(), 16);
		} else {
			::Dump(buffer->GetData(), buffer->GetSize());
		}
		Debug("[/VideoFrame]\n");
	}
	else
	{
		auto codecStr = Uint32ToFourCcStr(codecEx);
		Debug("[VideoFrame extended: true codec: %s frameType:%d timestamp:%lld mediaSize:%zu packetType: %d]\n",
			codecStr.c_str(),frameType,timestamp,buffer->GetSize(), packetType);
		
		if (codecEx==VideoCodecEx::HEVC && packetType == CodedFrames)
		{
			Debug("\t[HEVC composition time: %d/]\n", GetSI24(extraData));
		}
			
		if (codecEx==VideoCodecEx::HEVC && IsConfig())
		{
			//Paser HEVCDescriptor
			HEVCDescriptor desc;
			//Parse it
			desc.Parse(buffer->GetData(), buffer->GetSize());
			//Dump it
			desc.Dump();

		} else if(buffer->GetSize() > 16) {
			//Dump first 16 bytes only
			::Dump(buffer->GetData(), 16);
		} else {
			::Dump(buffer->GetData(), buffer->GetSize());
		}
		
		Debug("[/VideoFrame]\n");
	}
}

int32_t RTMPVideoFrame::GetCompositionTimeOffset() const
{
	if (isExtended)
	{
		if (GetVideoCodecEx() == VideoCodecEx::HEVC)
			return  GetSI24(extraData);
			
		return 0;
	}
	else
	{	
		return GetSI24(&extraData[1]);
	}
}

DWORD RTMPVideoFrame::Parse(BYTE *data,DWORD size)
{
	BYTE* buffer = data;
	DWORD bufferLen = size;

	while (bufferLen > 0)
	{
		uint32_t usedBytes = 0;
		
		switch (parsingState)
		{
			case ParsingState::VideoTagHeader:
				isExtended = buffer[0] & 0x80;
				if (!isExtended)
				{
					//Parse type
					codec = VideoCodec(buffer[0] & 0x0f);
				
					if (codec == AVC)
					{
						bufferWritter = std::make_unique<BufferWritter>(extraData, 4);
					
						parsingState = ParsingState::VideoTagAvcExtra;
					}
					else
					{
						parsingState = ParsingState::VideoTagData;
					}
				}
				else
				{
					packetType = PacketType(buffer[0] & 0x0f);
				
					bufferWritter = std::make_unique<BufferWritter>(fourCc, 4);
				
					parsingState = ParsingState::VideoTagHeaderFourCc;
				}
			
				// The frame type wouldn't be valid when packet type is PacketTypeMetaData for extended header.
				// But it wouldn't be used anyway.
				frameType = (FrameType) ((buffer[0] & 0x70) >> 4);
			
				usedBytes = 1;
				break;
			
			case ParsingState::VideoTagAvcExtra:
				if (!bufferWritter)
				{
					// This should never happen
					Error("No buffer writter\n");
					return size;	
				}
			
				usedBytes = std::min(uint32_t(bufferWritter->GetLeft()), bufferLen);
				(void)bufferWritter->Set({buffer, usedBytes});
			
				if (bufferWritter->GetLeft() == 0)
				{
					bufferWritter.reset();
					parsingState = ParsingState::VideoTagData;
				}
				break;
			
			case ParsingState::VideoTagHeaderFourCc:
				if (!bufferWritter)
				{
					// This should never happen
					Error("No buffer writter\n");
					return size;	
				}
			
				usedBytes = std::min(uint32_t(bufferWritter->GetLeft()), bufferLen);
				(void)bufferWritter->Set({buffer, usedBytes});
			
				if (bufferWritter->GetLeft() == 0)
				{
					codecEx = VideoCodecEx(FourCcToUint32(fourCc));
					bufferWritter.reset();				
					parsingState = ParsingState::VideoTagBody;
				}
				break;
			
			case ParsingState::VideoTagBody:
				if (packetType == Metadata)
				{
					// colorInfo AMF encoded meta data. Ignore for now.
				
					// Frame type is not valid for meta data
					frameType = FrameType(0);
					return size;
				}
				else if (packetType == SequenceEnd)
				{
					// signals end of sequence
					return size;
				}
			
				if (codecEx == HEVC)
				{
					if (packetType == SequenceStart)
					{
						// HEVCDecoderConfigurationRecord
						parsingState = ParsingState::VideoTagData;
					}
					else if (packetType == CodedFrames)
					{
						bufferWritter = std::make_unique<BufferWritter>(extraData, 3);
					
						parsingState = ParsingState::VideoTagHevcCompositionTime;
					}
					else if (packetType == CodedFramesX)
					{					
						parsingState = ParsingState::VideoTagData;					
					}
				}
				else if (codecEx == AV1)
				{
					if (packetType == SequenceStart || packetType == CodedFrames)
						parsingState = ParsingState::VideoTagData;
					else
						return size;
				}
				else
				{
					// Not implemented for other codecs
					return size;
				}
			
				break;
			
			case ParsingState::VideoTagHevcCompositionTime:
				if (!bufferWritter)
				{
					// This should never happen
					Error("No buffer writter\n");
					return size;	
				}
			
				usedBytes = std::min(uint32_t(bufferWritter->GetLeft()), bufferLen);
				(void)bufferWritter->Set({buffer, usedBytes});
			
				if (bufferWritter->GetLeft() == 0)
				{	
					bufferWritter.reset();				
					parsingState = ParsingState::VideoTagData;
				}
				break;
			
			case ParsingState::VideoTagData:
				usedBytes = RTMPMediaFrame::Parse(buffer,bufferLen);
			
				return usedBytes + (buffer - data);
			default:
				Error("Invalid ParsingState: %d", parsingState);
				return size;
		}
		
		buffer	  += usedBytes;
		bufferLen -= usedBytes;
	}

	return size;
}

DWORD RTMPVideoFrame::Serialize(BYTE* data,DWORD size)
{
	if (size < GetSize()) return 0;
		
	if (!isExtended)
	{
		DWORD extra = 0;

		//Check codec
		if (codec==AVC)
			//Extra header
			extra = 4;

		//Check if enought space
		if (size < buffer->GetSize() + 1 + extra)
			//Failed
			return 0;

		//Set first byte
		data[0] = (uint8_t(frameType) <<4 ) | (uint8_t(codec) & 0x0f);

		//If it is AVC
		if (codec==AVC)
		{
			data[1] = extraData[0];
			data[2] = extraData[1];
			data[3] = extraData[2];
			data[4] = extraData[3];
		}
		
		//Copy media
		memcpy(data+1+extra, buffer->GetData(), buffer->GetSize());

		//Exit
		return buffer->GetSize() + 1 + extra;
	}
	else
	{	
		*data = (uint8_t(frameType) <<4 ) | (uint8_t(packetType) & 0x0f) | 0x80;
		data++;
		
		set4(data, 0, uint32_t(codecEx));
		data += 4;
		
		if (codecEx == VideoCodecEx::HEVC && packetType == PacketType::CodedFrames)
		{
			memcpy(data, extraData, 3);
			data += 3;
		}
		
		memcpy(data, buffer->GetData(), buffer->GetSize());
		
		return GetSize();
	}
}

DWORD RTMPVideoFrame::GetSize()
{
	if (!isExtended)
	{
		//If it is not AVC
		if (codec!=AVC)
			return buffer->GetSize() + 1;
		else
			return buffer->GetSize() + 1 + 4;
	}
	else
	{	
		uint32_t sz = 1; // The first byte
		sz += 4; 	 // The fouc CC
		
		if (codecEx == VideoCodecEx::HEVC && packetType == PacketType::CodedFrames)
		{
			sz += 3;	// The composition offset
		}		
		
		sz += buffer->GetSize();
		return sz;
	}
}

DWORD RTMPVideoFrame::SetVideoFrame(BYTE* data, DWORD size)
{
	//Set payload
	buffer->SetData(data, size);
	//Done
	return size;
}


RTMPMediaFrame *RTMPVideoFrame::Clone()
{
	RTMPVideoFrame *frame =  new RTMPVideoFrame(timestamp, buffer);
	//Set values
	frame->SetVideoCodec(codec);
	frame->SetFrameType(frameType);
	//Copy extra data
	memcpy(frame->extraData,extraData,4);
	memcpy(frame->fourCc,fourCc,4);
	//Copy v1 properties
	frame->codecEx = codecEx;
	frame->packetType = packetType;
	frame->isExtended = isExtended;
	//If we have disabled the shared buffer for this frame
	if (disableSharedBuffer)
		//Copy data
		frame->AdquireBuffer();
	//Return frame
	return frame;
}

RTMPAudioFrame::RTMPAudioFrame(QWORD timestamp,const AACSpecificConfig &config) : RTMPMediaFrame(Audio,timestamp,config.GetSize())
{
	//Set AAC codec properties
	SetAudioCodec(AAC);
        SetSoundRate(RTMPAudioFrame::RATE44khz);
        SetSamples16Bits(1);
        SetStereo(1);
	//Set type
	SetAACPacketType(AACSequenceHeader);
	//Set data
	DWORD mediaSize = config.Serialize(buffer->GetData(), buffer->GetCapacity());
	//Update length
	buffer->SetSize(mediaSize);
}

RTMPAudioFrame::RTMPAudioFrame(QWORD timestamp, const Buffer::shared& buffer) : RTMPMediaFrame(Audio, timestamp, buffer)
{
	//No header for parsing
	headerPos = 0;
}

RTMPAudioFrame::RTMPAudioFrame(QWORD timestamp,DWORD size) : RTMPMediaFrame(Audio,timestamp,size)
{
        //No header for parsing
	headerPos = 0;
}

void RTMPAudioFrame::Dump()
{
	//Dump
	Debug("[AudioFrame type:%d codec:%d rate:%d sample16bits:%d stereo:%d timestamp:%lld mediaSize:%zu]\n",type,codec,rate,sample16bits,stereo,timestamp,buffer->GetSize());
	if(buffer->GetSize()>8)
		::Dump(buffer->GetData(), 8);
	else
		::Dump(buffer->GetData(), buffer->GetSize());
	Debug("[/AudioFrame]\n");
}

DWORD RTMPAudioFrame::Parse(BYTE *data,DWORD size)
{
	BYTE* chunk = data;
	DWORD chunkLen = size;

        //Check size
        if (!size)
                //Done
                return size;
        
	//If it is the first
	if (headerPos == 0)
	{
		//Parse type
		codec		= (AudioCodec)(chunk[0]>>4);
		rate		= (SoundRate)((chunk[0]>>2) & 0x03);
		sample16bits	= ((chunk[0]>>1) & 0x01);
		stereo		=  chunk[0] & 0x01;
		//Remove from data
		chunk++;
		chunkLen--;
		headerPos++;
	}

        //Check still something
        if (!chunkLen)
                //Done so far
                return size;

	//Check AAC
	if (codec==AAC && headerPos == 1)
	{
		//Get type
		extraData[0] = chunk[0];
		//Remove from data
		chunk++;
		chunkLen--;
                //Increase header pos
                headerPos++;
	}
	//Parse the rest
	DWORD len = RTMPMediaFrame::Parse(chunk,chunkLen);

	//Return parsed data
	return len+(chunk-data);
}

DWORD RTMPAudioFrame::Serialize(BYTE* data,DWORD size)
{
	DWORD pos = 0;

	//Check if enought space
	if (size<GetSize())
		//Failed
		return 0;

	//Set first byte
	data[pos++] = (codec<<4) | (rate<<2) | (sample16bits<<1) | stereo;

	//Check codec
	if (codec==AAC)
		//Se type
		data[pos++] = extraData[0];

	//Copy media
	memcpy(data+pos,buffer->GetData(), buffer->GetSize());

	//Exit
	return buffer->GetSize()+pos;
}
DWORD RTMPAudioFrame::GetSize()
{
	//Check if extradata is used
	if (codec!=AAC)
		//Check if enought space
		return buffer->GetSize() + 1;
	else
		//Check if enought space
		return buffer->GetSize() + 2;
}

DWORD RTMPAudioFrame::SetAudioFrame(const BYTE* data,DWORD size)
{
	//Set payload
	buffer->SetData(data,size);
	//Done
	return size;
}

RTMPMediaFrame *RTMPAudioFrame::Clone()
{
	RTMPAudioFrame *frame =  new RTMPAudioFrame(timestamp, buffer);
	//Set values
	frame->SetAudioCodec(codec);
	frame->SetSoundRate(rate);
	frame->SetSamples16Bits(sample16bits);
	frame->SetStereo(stereo);
	frame->SetAACPacketType(GetAACPacketType());
	//If we have disabled the shared buffer for this frame
	if (disableSharedBuffer)
		//Copy data
		frame->AdquireBuffer();
	//Return frame
	return frame;
}