#define __USE_FILE_OFFSET64 1
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/stat.h>
#include <unistd.h>

#include <audio_lib.h>
#include <video_lib.h>

#include <common.h>
extern OutputHandler_t      OutputHandler;
extern PlaybackHandler_t    PlaybackHandler;
extern ContainerHandler_t   ContainerHandler;
extern ManagerHandler_t     ManagerHandler;

#include "playback_libeplayer3.h"
#include "lt_debug.h"

#define lt_debug(args...) _lt_debug(HAL_DEBUG_PLAYBACK, this, args)
#define lt_info(args...)  _lt_info(HAL_DEBUG_PLAYBACK, this, args)

static Context_t *player = NULL;

extern cAudio *audioDecoder;
extern cVideo *videoDecoder;

//Used by Fileplay
bool cPlayback::Open(playmode_t PlayMode)
{
	const char *aPLAYMODE[] =
	{
		"PLAYMODE_TS",
		"PLAYMODE_FILE"
	};

	if (PlayMode != PLAYMODE_TS)
	{
		audioDecoder->closeDevice();
		videoDecoder->closeDevice();
		decoders_closed = true;
	}

	pm = PlayMode;
	fn_ts = "";
	fn_xml = "";
	last_size = 0;
	nPlaybackSpeed = 0;
	init_jump = -1;
	if (player)
		free(player);
	player = NULL;
	player = (Context_t *) malloc(sizeof(Context_t));
	if (player)
	{
		player->playback    = &PlaybackHandler;
		player->output      = &OutputHandler;
		player->container   = &ContainerHandler;
		player->manager     = &ManagerHandler;
		lt_info("%s - player output name: %s PlayMode: %s\n", __func__, player->output->Name, aPLAYMODE[PlayMode]);
	}
	//Registration of output devices
	if (player && player->output)
	{
		player->output->Command(player, OUTPUT_ADD, (void *)"audio");
		player->output->Command(player, OUTPUT_ADD, (void *)"video");
	}
	return 0;
}

void cPlayback::Close(void)
{
	lt_info("%s\n", __func__);
	//Dagobert: movieplayer does not call stop, it calls close ;)
	if(playing)
		Stop();
	if (decoders_closed)
	{
		audioDecoder->openDevice();
		videoDecoder->openDevice();
		decoders_closed = false;
	}
}

bool cPlayback::Start(std::string filename, std::string headers)
{
	return Start((char *) filename.c_str(), 0, 0, 0, 0, 0, headers);
}

bool cPlayback::Start(char *filename, int vpid, int vtype, int apid, int ac3, int, std::string headers __attribute__((unused)))
{
	bool ret = false;
	bool isHTTP = false;
	no_probe = false;
	lt_info("%s - filename=%s vpid=%u vtype=%d apid=%u ac3=%d\n", __func__, filename, vpid, vtype, apid, ac3);
	init_jump = -1;
	//create playback path
	mAudioStream = 0;
	mSubtitleStream = -1;
	mTeletextStream = -1;
	unlink("/tmp/.id3coverart");
	std::string file;
	if (*filename == '/')
		file = "file://";
	file += filename;
	if ((file.find(":31339/id=") != std::string::npos) || (file.find(":10000") != std::string::npos) || (file.find(":8001/") != std::string::npos)) // for LocalTV and Entertain-TV streaming
		no_probe = true;
	if (file.substr(0, 7) == "file://")
	{
		if (file.substr(file.length() - 3) ==  ".ts")
		{
			fn_ts = file.substr(7);
			fn_xml = file.substr(7, file.length() - 9);
			fn_xml += "xml";
			no_probe = true;
		}
	}
	else
		isHTTP = true;
	PlayFiles_t playbackFiles = { (char *) file.c_str(), NULL};
	if (player->playback->Command(player, PLAYBACK_OPEN, &playbackFiles) == 0)
	{
		if (pm == PLAYMODE_TS)
		{
			struct stat64 s;
			if (!stat64(file.c_str(), &s))
				last_size = s.st_size;
			ret = true;
			videoDecoder->Stop(false);
			audioDecoder->Stop();
		}
		else
		{
			//AUDIO
			if (player && player->manager && player->manager->audio)
			{
				char ** TrackList = NULL;
				player->manager->audio->Command(player, MANAGER_LIST, &TrackList);
				if (TrackList != NULL)
				{
					printf("AudioTrack List\n");
					int i = 0;
					for (i = 0; TrackList[i] != NULL; i+=2)
					{
						printf("\t%s - %s\n", TrackList[i], TrackList[i+1]);
						free(TrackList[i]);
						free(TrackList[i+1]);
					}
					free(TrackList);
				}
			}
			//SUB
			if (player && player->manager && player->manager->subtitle)
			{
				char ** TrackList = NULL;
				player->manager->subtitle->Command(player, MANAGER_LIST, &TrackList);
				if (TrackList != NULL)
				{
					printf("SubtitleTrack List\n");
					int i = 0;
					for (i = 0; TrackList[i] != NULL; i+=2)
					{
						printf("\t%s - %s\n", TrackList[i], TrackList[i+1]);
						free(TrackList[i]);
						free(TrackList[i+1]);
					}
					free(TrackList);
				}
			}
			/*
			//Teletext
			if (player && player->manager && player->manager->teletext)
			{
				char ** TrackList = NULL;
				player->manager->teletext->Command(player, MANAGER_LIST, &TrackList);
				if (TrackList != NULL)
				{
					printf("TeletextTrack List\n");
					 int i = 0;
					for (i = 0; TrackList[i] != NULL; i+=2)
					{
						printf("\t%s - %s\n", TrackList[i], TrackList[i+1]);
						free(TrackList[i]);
						free(TrackList[i+1]);
					}
					free(TrackList);
				}
			}
			*/
			//Chapters
			if (player && player->manager && player->manager->chapter)
			{
				char ** TrackList = NULL;
				player->manager->chapter->Command(player, MANAGER_LIST, &TrackList);
				if (TrackList != NULL)
				{
					printf("Chapter List\n");
					int i = 0;
					for (i = 0; TrackList[i] != NULL; i+=2)
					{
						printf("\t%s - %s\n", TrackList[i], TrackList[i+1]);
						free(TrackList[i]);
						free(TrackList[i+1]);
					}
					free(TrackList);
				}
			}
			playing = true;
			first = true;
			player->output->Command(player, OUTPUT_OPEN, NULL);
			ret = (player->playback->Command(player, PLAYBACK_PLAY, NULL) == 0);
			if (ret && !isHTTP)
				playing = ret = (player->playback->Command(player, PLAYBACK_PAUSE, NULL) == 0);
		}
	}
	return ret;
}

bool cPlayback::Stop(void)
{
	lt_info("%s playing %d\n", __func__, playing);
	if (player && player->playback)
		player->playback->Command(player, PLAYBACK_STOP, NULL);
	if (player && player->output)
		player->output->Command(player, OUTPUT_CLOSE, NULL);
	if (player && player->output)
	{
		player->output->Command(player, OUTPUT_DEL, (void *)"audio");
		player->output->Command(player, OUTPUT_DEL, (void *)"video");
	}
	if (player && player->playback)
		player->playback->Command(player, PLAYBACK_CLOSE, NULL);
	playing = false;
	return true;
}

bool cPlayback::SetAPid(int pid, bool /* ac3 */)
{
	lt_info("%s\n", __func__);
	int i = pid;
	if (pid != mAudioStream)
	{
		if (player && player->playback)
			player->playback->Command(player, PLAYBACK_SWITCH_AUDIO, (void *)&i);
		mAudioStream = pid;
	}
	return true;
}

bool cPlayback::SetVPid(int /*pid*/)
{
	lt_info("%s\n", __func__);
	return true;
}

bool cPlayback::SetSubtitlePid(int pid)
{
	lt_info("%s\n", __func__);
	int i = pid;
	if (pid != mSubtitleStream)
	{
		if (player && player->playback)
			player->playback->Command(player, PLAYBACK_SWITCH_SUBTITLE, (void *)&i);
		mSubtitleStream = pid;
	}
	return true;
}

bool cPlayback::SetTeletextPid(int pid)
{
	lt_info("%s\n", __func__);
	//int i = pid;
	if (pid != mTeletextStream)
	{
		//if(player && player->playback)
		//player->playback->Command(player, PLAYBACK_SWITCH_TELETEXT, (void*)&i);
		mTeletextStream = pid;
	}
	return true;
}

bool cPlayback::SetSpeed(int speed)
{
	lt_info("%s playing %d speed %d\n", __func__, playing, speed);
	if (!decoders_closed)
	{
		audioDecoder->closeDevice();
		videoDecoder->closeDevice();
		decoders_closed = true;
		usleep(500000);
		if (player && player->output && player->playback)
		{
			player->output->Command(player, OUTPUT_OPEN, NULL);
			if (player->playback->Command(player, PLAYBACK_PLAY, NULL) == 0)
				playing = true;
		}
	}
	if (!playing)
		return false;
	if (player && player->playback)
	{
		int result = 0;
		nPlaybackSpeed = speed;
		if (speed > 1)
		{
			/* direction switch ? */
			if (player->playback->BackWard)
			{
				int r = 0;
				result = player->playback->Command(player, PLAYBACK_FASTBACKWARD, (void *)&r);
				printf("result = %d\n", result);
			}
			result = player->playback->Command(player, PLAYBACK_FASTFORWARD, (void *)&speed);
		}
		else if (speed < 0)
		{
			/* direction switch ? */
			if (player->playback->isForwarding)
			{
				result = player->playback->Command(player, PLAYBACK_CONTINUE, NULL);
				printf("result = %d\n", result);
			}
			result = player->playback->Command(player, PLAYBACK_FASTBACKWARD, (void *)&speed);
		}
		else if (speed == 0)
		{
			/* konfetti: hmmm accessing the member isn't very proper */
			if ((player->playback->isForwarding) || (!player->playback->BackWard))
				player->playback->Command(player, PLAYBACK_PAUSE, NULL);
			else
			{
				int _speed = 0; /* means end of reverse playback */
				player->playback->Command(player, PLAYBACK_FASTBACKWARD, (void *)&_speed);
			}
		}
		else
		{
			result = player->playback->Command(player, PLAYBACK_CONTINUE, NULL);
		}
		if (init_jump > -1)
		{
			SetPosition(init_jump);
			init_jump = -1;
		}
		if (result != 0)
		{
			printf("returning false\n");
			return false;
		}
	}
	return true;
}

bool cPlayback::GetSpeed(int &speed) const
{
	lt_debug("%s\n", __func__);
	speed = nPlaybackSpeed;
	return true;
}

void cPlayback::GetPts(uint64_t &pts)
{
	if (player && player->playback)
		player->playback->Command(player, PLAYBACK_PTS, (void *)&pts);
}

// in milliseconds
bool cPlayback::GetPosition(int &position, int &duration)
{
	bool got_duration = false;
	lt_debug("%s %d %d\n", __func__, position, duration);
	/* hack: if the file is growing (timeshift), then determine its length
	 * by comparing the mtime with the mtime of the xml file */
	if (pm == PLAYMODE_TS)
	{
		struct stat64 s;
		if (!stat64(fn_ts.c_str(), &s))
		{
			if (!playing || last_size != s.st_size)
			{
				last_size = s.st_size;
				time_t curr_time = s.st_mtime;
				if (!stat64(fn_xml.c_str(), &s))
				{
					duration = (curr_time - s.st_mtime) * 1000;
					if (!playing)
						return true;
					got_duration = true;
				}
			}
		}
	}
	if (!playing)
		return false;
	if (player && player->playback && !player->playback->isPlaying)
	{
		lt_info("%s !!!!EOF!!!! < -1\n", __func__);
		position = duration + 1000;
		return false;
	}
	int64_t vpts = 0;
	if (player && player->playback)
		player->playback->Command(player, PLAYBACK_PTS, &vpts);
	if (vpts <= 0)
	{
		//printf("ERROR: vpts==0");
	}
	else
	{
		/* len is in nanoseconds. we have 90 000 pts per second. */
		position = vpts / 90;
	}
	if (got_duration)
		return true;
	int64_t length = 0;
	if (player && player->playback)
		player->playback->Command(player, PLAYBACK_LENGTH, &length);
	if (length <= 0)
		duration = duration + 1000;
	else
		duration = length * 1000;
	return true;
}

bool cPlayback::SetPosition(int position, bool absolute)
{
	lt_info("%s %d\n", __func__, position);
	if (playing && first)
	{
		/* the calling sequence is:
		 * Start()       - paused
		 * SetPosition() - which fails if not running
		 * SetSpeed()    - to start playing
		 * so let's remember the initial jump position and later jump to it
		 */
		init_jump = position;
		first = false;
		return false;
	}
	int64_t pos = (position / 1000.0);
	if (player && player->playback)
		player->playback->Command(player, absolute ? PLAYBACK_SEEK_ABS : PLAYBACK_SEEK, (void *)&pos);
	return true;
}

void cPlayback::FindAllPids(int *apids, unsigned int *ac3flags, unsigned int *numpida, std::string *language)
{
	lt_info("%s\n", __func__);
	int max_numpida = *numpida;
	*numpida = 0;
	if (player && player->manager && player->manager->audio)
	{
		char **TrackList = NULL;
		player->manager->audio->Command(player, MANAGER_LIST, &TrackList);
		if (TrackList != NULL)
		{
			printf("AudioTrack List\n");
			int i = 0, j = 0;
			for (i = 0, j = 0; TrackList[i] != NULL; i += 2, j++)
			{
				printf("\t%s - %s\n", TrackList[i], TrackList[i + 1]);
				if (j < max_numpida)
				{
					int _pid;
					char _lang[strlen(TrackList[i])];
					if (2 == sscanf(TrackList[i], "%d %s\n", &_pid, _lang))
					{
						apids[j] = _pid;
						// atUnknown, atMPEG, atMP3, atAC3, atDTS, atAAC, atPCM, atOGG, atFLAC
						if (!strncmp("A_MPEG/L3",   TrackList[i + 1], 9))
							ac3flags[j] = 3;
						if (!strncmp("A_MP3",       TrackList[i + 1], 5))
							ac3flags[j] = 4;
						else if (!strncmp("A_AC3",       TrackList[i + 1], 5))
							ac3flags[j] = 1;
						else if (!strncmp("A_EAC3",      TrackList[i + 1], 6))
							ac3flags[j] = 7;
						else if (!strncmp("A_DTS",       TrackList[i + 1], 5))
							ac3flags[j] = 6;
						else if (!strncmp("A_AAC",       TrackList[i + 1], 5))
							ac3flags[j] = 5;
						else if (!strncmp("A_PCM",       TrackList[i + 1], 5))
							ac3flags[j] = 0;    //todo
						else if (!strncmp("A_VORBIS",    TrackList[i + 1], 8))
							ac3flags[j] = 0;    //todo
						else if (!strncmp("A_FLAC",      TrackList[i + 1], 6))
							ac3flags[j] = 0;    //todo
						else
							ac3flags[j] = 0;    //todo
						language[j] = std::string(_lang);
					}
				}
				free(TrackList[i]);
				free(TrackList[i + 1]);
			}
			free(TrackList);
			*numpida = j;
		}
	}
}

void cPlayback::FindAllSubtitlePids(int *pids, unsigned int *numpids, std::string *language)
{
	lt_info("%s\n", __func__);
	int max_numpids = *numpids;
	*numpids = 0;
	if (player && player->manager && player->manager->subtitle)
	{
		char **TrackList = NULL;
		player->manager->subtitle->Command(player, MANAGER_LIST, &TrackList);
		if (TrackList != NULL)
		{
			printf("SubtitleTrack List\n");
			int i = 0, j = 0;
			for (i = 0, j = 0; TrackList[i] != NULL; i += 2, j++)
			{
				printf("\t%s - %s\n", TrackList[i], TrackList[i + 1]);
				if (j < max_numpids)
				{
					int _pid;
					char _lang[strlen(TrackList[i])];
					if (2 == sscanf(TrackList[i], "%d %s\n", &_pid, _lang))
					{
						pids[j] = _pid;
						language[j] = std::string(_lang);
					}
				}
				free(TrackList[i]);
				free(TrackList[i + 1]);
			}
			free(TrackList);
			*numpids = j;
		}
	}
}

void cPlayback::FindAllTeletextsubtitlePids(int */*pids*/, unsigned int *numpids, std::string */*language*/, int */*mags*/, int */*pages*/)
{
	lt_info("%s\n", __func__);
	//int max_numpids = *numpids;
	*numpids = 0;
	/*
	if (player && player->manager && player->manager->teletext)
	{
		char **TrackList = NULL;
		player->manager->teletext->Command(player, MANAGER_LIST, &TrackList);
		if (TrackList != NULL)
		{
			printf("Teletext List\n");
			int i = 0, j = 0;
			for (i = 0, j = 0; TrackList[i] != NULL; i += 2)
			{
				int type = 0;
				printf("\t%s - %s\n", TrackList[i], TrackList[i + 1]);
				if (j < max_numpids)
				{
					int _pid;
					if (2 != sscanf(TrackList[i], "%d %*s %d %*d %*d", &_pid, &type))
						continue;
					if (type != 2 && type != 5) // return subtitles only
						continue;
					pids[j] = _pid;
					language[j] = std::string(TrackList[i]);
					j++;
				}
				free(TrackList[i]);
				free(TrackList[i + 1]);
			}
			free(TrackList);
			*numpids = j;
		}
	}
	*/
}

int cPlayback::GetTeletextPid(void)
{
	lt_info("%s\n", __func__);
	int pid = -1;
	/*
	if (player && player->manager && player->manager->teletext)
	{
		char **TrackList = NULL;
		player->manager->teletext->Command(player, MANAGER_LIST, &TrackList);
		if (TrackList != NULL)
		{
			printf("Teletext List\n");
			int i = 0;
			for (i = 0; TrackList[i] != NULL; i += 2)
			{
				int type = 0;
				printf("\t%s - %s\n", TrackList[i], TrackList[i+1]);
				if (pid < 0)
				{
					if (2 != sscanf(TrackList[i], "%*d %d %*s %d %*d %*d", &pid, &type))
						continue;
					if (type != 1)
						pid = -1;
				}
				free(TrackList[i]);
				free(TrackList[i + 1]);
			}
			free(TrackList);
		}
	}
	*/
	printf("teletext pid id %d (0x%x)\n", pid, pid);
	return pid;
}

/* dummy functions for subtitles */
void cPlayback::FindAllSubs(int * /*pids*/, unsigned int * /*supp*/, unsigned int *num, std::string * /*lang*/)
{
	*num = 0;
}

bool cPlayback::SelectSubtitles(int /*pid*/, std::string /*charset*/)
{
	return false;
}

void cPlayback::GetChapters(std::vector<int> &positions, std::vector<std::string> &titles)
{
	positions.clear();
	titles.clear();
	if (player && player->manager && player->manager->chapter)
	{
		char **TrackList = NULL;
		player->manager->chapter->Command(player, MANAGER_LIST, &TrackList);
		if (TrackList != NULL)
		{
			printf("%s: Chapter List\n", __func__);
			int i = 0;
			for (i = 0; TrackList[i] != NULL; i += 2)
			{
				printf("\t%s - %s\n", TrackList[i], TrackList[i + 1]);
				int pos = atoi(TrackList[i]);
				std::string title(TrackList[i + 1]);
				positions.push_back(pos);
				titles.push_back(title);
				free(TrackList[i]);
				free(TrackList[i + 1]);
			}
			free(TrackList);
		}
	}
}

void cPlayback::GetTitles(std::vector<int> &playlists, std::vector<std::string> &titles, int &current)
{
	playlists.clear();
	titles.clear();
	current = 0;
}

void cPlayback::SetTitle(int /*title*/)
{
}

void cPlayback::GetMetadata(std::vector<std::string> &keys, std::vector<std::string> &values)
{
	keys.clear();
	values.clear();
	char **metadata = NULL;
	if (player && player->playback)
	{
		player->playback->Command(player, PLAYBACK_METADATA, &metadata);
		if (metadata)
		{
			for (char **m = metadata; *m;)
			{
				keys.push_back(*m);
				free(*m++);
				values.push_back(*m);
				free(*m++);
			}
			free(metadata);
		}
	}
}

cPlayback::cPlayback(int num __attribute__((unused)))
{
	lt_info("%s\n", __func__);
	playing = false;
	decoders_closed = false;
	first = false;
}

cPlayback::~cPlayback()
{
	lt_info("%s\n", __func__);
	if (player)
		free(player);
	player = NULL;
}

void cPlayback::RequestAbort()
{
	if (player && player->playback && player->playback->isPlaying)
	{
		lt_info("%s\n", __func__);
		Stop();
		//player->playback->abortRequested = 1;
		while (player->playback->isPlaying)
			usleep(100000);
	}
}

bool cPlayback::IsPlaying()
{
	if (player && player->playback)
		return player->playback->isPlaying;
	return false;
}

uint64_t cPlayback::GetReadCount()
{
	//if (player && player->playback)
	//{
	//	return player->playback->readCount;
	//}
	return 0;
}

AVFormatContext *cPlayback::GetAVFormatContext()
{
	return NULL;
}

void cPlayback::ReleaseAVFormatContext()
{
}

#if 0
bool cPlayback::IsPlaying(void) const
{
	lt_info("%s\n", __func__);
	/* konfetti: there is no event/callback mechanism in libeplayer2
	 * so in case of ending playback we have no information on a
	 * terminated stream currently (or did I oversee it?).
	 * So let's ask the player the state.
	 */
	if (playing)
	{
		return player->playback->isPlaying;
	}
	return playing;
}
#endif