#if HAVE_CRT
#define _CRTDBG_MAP_ALLOC 
#include <stdlib.h> 
#include <crtdbg.h>
#endif //HAVE_CRT
/*
* Copyright (C) 2020, University of the Basque Country (UPV/EHU)
* Contact for licensing options: <licensing-mcpttclient(at)mcopenplatform(dot)com>
*
* The original file was part of Open Source Doubango Framework
* Copyright (C) 2010-2011 Mamadou Diop.
* Copyright (C) 2012 Doubango Telecom <http://doubango.org>
*
* This file is part of Open Source Doubango Framework.
*
* DOUBANGO 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.
*
* DOUBANGO 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 DOUBANGO.
*
*/


/**@file tdav_codec_red.c
 * @brief RTP Payload for Redundant Audio Data as per RFC 2198
 */
#include "tinydav/codecs/fec/tdav_codec_red.h"

#include "tinyrtp/rtp/trtp_rtp_packet.h"

#include "tsk_memory.h"
#include "tsk_time.h"
#include "tsk_debug.h"

typedef struct tdav_codec_red_s
{
	TMEDIA_DECLARE_CODEC_VIDEO;

	tdav_codec_red_rtppacket_cb_f callback;
	const void* callback_data;
}
tdav_codec_red_t;

int tdav_codec_red_set_callback(tdav_codec_red_t *self, tdav_codec_red_rtppacket_cb_f callback, const void* callback_data)
{
	if(!self){
		TSK_DEBUG_ERROR("Invalid parameter");
		return -1;
	}

	self->callback = callback;
	self->callback_data = callback_data;

	return 0;
}

static int tdav_codec_red_open(tmedia_codec_t* self)
{
	return 0;
}

static int tdav_codec_red_close(tmedia_codec_t* self)
{
	return 0;
}

static tsk_size_t tdav_codec_red_encode(tmedia_codec_t* self, const void* in_data, tsk_size_t in_size, void** out_data, tsk_size_t* out_max_size)
{
	tdav_codec_red_t *red = (tdav_codec_red_t *)self;
	tsk_size_t xsize = (in_size + 1);
	static const uint8_t __first_octet = 0x00; // F=1, PT=0. Up to the caller to update this first octet with the right PT.

	if(!red || !in_data || !in_size || !out_data || !out_max_size){
		TSK_DEBUG_ERROR("Invalid parameter");
		return 0;
	}

	if(*out_max_size < xsize){
		if(!(*out_data = tsk_realloc(*out_data, xsize))){
			TSK_DEBUG_ERROR("Failed to realloc data");
			*out_max_size = 0;
		}
		*out_max_size = xsize;
	}

	((uint8_t*)*out_data)[0] = __first_octet;
	memcpy(&((uint8_t*)*out_data)[1], in_data, in_size);

	return xsize;
}

static tsk_size_t tdav_codec_red_decode(tmedia_codec_t* self, const void* in_data, tsk_size_t in_size, void** out_data, tsk_size_t* out_max_size, const tsk_object_t* proto_hdr)
{
	tdav_codec_red_t* red = (tdav_codec_red_t*)self;
	const trtp_rtp_header_t* rtp_hdr = proto_hdr;
	trtp_rtp_packet_t* red_rtp_pkt = tsk_null;
	const uint8_t* pdata = in_data;
	const uint8_t* red_hdr = in_data;
	tsk_size_t red_hdrs_count, i;
	tsk_bool_t last;
	uint8_t F;
	uint16_t timestamp_offset, block_length;

	if(!red || !in_data || (in_size < TDAV_CODEC_RED_MIN_PKT_SIZE)|| !out_data){
		TSK_DEBUG_ERROR("Invalid parameter");
		return 0;
	}

	if(!red->callback){
		TSK_DEBUG_WARN("Not callback installed for RED data");
		return 0;
	}

	if((F = (pdata[0] & 0x80)) == 0){
		i = 1;
		red_hdrs_count = 1;
	}
	else{
		for(i = 0, red_hdrs_count = 0; i < in_size; i+= 4, ++red_hdrs_count){
			if((F = (pdata[i] & 0x80)) == 0){ ++i; ++red_hdrs_count;  break; }
		}
	}

	if(i >= in_size){
		TSK_DEBUG_ERROR("Invalid data");
		return 0;
	}
	
	pdata += i;
	in_size -= i;

	for(i = 0; i < red_hdrs_count && in_size > 0; ++i){
		TSK_OBJECT_SAFE_FREE(red_rtp_pkt);
		if(!(red_rtp_pkt = trtp_rtp_packet_create_null())){
			TSK_DEBUG_ERROR("Failed to create RTP packet");
			continue;
		}
		if(!(red_rtp_pkt->header = trtp_rtp_header_create(rtp_hdr->ssrc, rtp_hdr->seq_num, rtp_hdr->timestamp, rtp_hdr->payload_type, rtp_hdr->marker))){
			TSK_DEBUG_ERROR("Failed to create RTP header");
			continue;
		}

		// Must create an RTP packet for each RED chunck as they will be saved in the JB
		last = (i == (red_hdrs_count - 1));
		F = (red_hdr[0] & 0x80);
		red_rtp_pkt->header->payload_type = (red_hdr[0] & 0x7F);
		
		if(last || !F){
			/*
			 0 1 2 3 4 5 6 7
             +-+-+-+-+-+-+-+-+
             |0|   Block PT  |
             +-+-+-+-+-+-+-+-+
			 */
			block_length = (uint16_t)in_size;
		}
		else{
			/*
			+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
		    |1| block PT=7  |  timestamp offset         |   block length    |
		    +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
			*/
			timestamp_offset = ((red_hdr[1] << 8) | red_hdr[2]) >> 2;
			block_length = ((red_hdr[2] & 0x03) << 8) | red_hdr[3];
			if(block_length > in_size){
				TSK_DEBUG_ERROR("Invalid 'block length'");
				break;
			}
			red_rtp_pkt->header->timestamp += timestamp_offset;
			red_hdr += 4;
		}

		// decode
		if(red->callback){
			// do not use "data_const" as payload will be saved in the jitter buffer and decoded later (async)
			#if HAVE_CRT //Debug memory
			if((red_rtp_pkt->payload.data =malloc(block_length))){
			#else
			if((red_rtp_pkt->payload.data = tsk_malloc(block_length))){
			#endif //HAVE_CRT
			
				memcpy(red_rtp_pkt->payload.data, pdata, block_length);
				red_rtp_pkt->payload.size = block_length;
				red->callback(red->callback_data, red_rtp_pkt);
			}
		}

		pdata += block_length;
		in_size -= block_length;
	}
	
	TSK_OBJECT_SAFE_FREE(red_rtp_pkt);

	return 0; // must be always zero
}

static tsk_bool_t tdav_codec_red_sdp_att_match(const tmedia_codec_t* codec, const char* att_name, const char* att_value)
{
	return tsk_true;
}

static char* tdav_codec_red_sdp_att_get(const tmedia_codec_t* self, const char* att_name)
{
	return tsk_null;
}


/* ============ red object definition ================= */

/* constructor */
static tsk_object_t* tdav_codec_red_ctor(tsk_object_t * self, va_list * app)
{
	tdav_codec_red_t *red = self;
	if(red){
		/* init base: called by tmedia_codec_create() */
		/* init self */
		
	}
	return self;
}
/* destructor */
static tsk_object_t* tdav_codec_red_dtor(tsk_object_t * self)
{ 
	tdav_codec_red_t *red = self;
	if(red){
		/* deinit base */
		tmedia_codec_video_deinit(red);
		/* deinit self */
		
	}

	return self;
}
/* object definition */
static const tsk_object_def_t tdav_codec_red_def_s = 
{
	sizeof(tdav_codec_red_t),
	tdav_codec_red_ctor, 
	tdav_codec_red_dtor,
	tmedia_codec_cmp, 
};
/* plugin definition*/
static const tmedia_codec_plugin_def_t tdav_codec_red_plugin_def_s = 
{
	&tdav_codec_red_def_s,

	(/* tmedia_video | tmedia_audio | */tmedia_t140), // FIXME: for now is only supported with T.140
	tmedia_codec_id_red,
	"red",
	"red codec",
	TMEDIA_CODEC_FORMAT_RED,
	tsk_true,
	1000, // rate: FIXME: for now it's only for T.140
	
	/* audio */
	{ 0 },

	/* video (defaul width,height,fps) */
	{176, 144, 15},

	tsk_null, // set()
	tdav_codec_red_open,
	tdav_codec_red_close,
	tdav_codec_red_encode,
	tdav_codec_red_decode,
	tdav_codec_red_sdp_att_match,
	tdav_codec_red_sdp_att_get
};
const tmedia_codec_plugin_def_t *tdav_codec_red_plugin_def_t = &tdav_codec_red_plugin_def_s;