///////////////////////////////////////////////////////////////////////////////
// LameXP - Audio Encoder Front-End
// Copyright (C) 2004-2012 LoRd_MuldeR <MuldeR2@GMX.de>
//
// This program 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 2 of the License, or
// (at your option) any later version.
//
// This program 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 this program; if not, write to the Free Software Foundation, Inc.,
// 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
//
// http://www.gnu.org/licenses/gpl-2.0.txt
///////////////////////////////////////////////////////////////////////////////

#pragma once

#include <QRunnable>
#include <QReadWriteLock>
#include <QWaitCondition>
#include <QStringList>
#include <QMutex>

class AudioFileModel;
class QFile;
class QDir;
class QFileInfo;
class LockedFile;

////////////////////////////////////////////////////////////
// Splash Thread
////////////////////////////////////////////////////////////

class AnalyzeTask: public QObject, public QRunnable
{
	Q_OBJECT

public:
	AnalyzeTask(const QString &inputFile, const QString &templateFile, volatile bool *abortFlag);
	~AnalyzeTask(void);
	
	static void reset(void);
	static int getAdditionalFiles(QStringList &fileList);
	static unsigned int filesAccepted(void);
	static unsigned int filesRejected(void);
	static unsigned int filesDenied(void);
	static unsigned int filesDummyCDDA(void);
	static unsigned int filesCueSheet(void);

	//Wait till the next running thread terminates
	static __forceinline bool waitForOneThread(unsigned long timeout)
	{
		bool ret = false;
		s_waitMutex.lock();
		ret = s_waitCond.wait(&s_waitMutex, timeout);
		s_waitMutex.unlock();
		return ret;
	}

signals:
	void fileSelected(const QString &fileName);
	void fileAnalyzed(const AudioFileModel &file);
	void progressValChanged(unsigned int);
	void progressMaxChanged(unsigned int);

protected:
	void run(void);
	void run_ex(void);

private:
	enum cover_t
	{
		coverNone,
		coverJpeg,
		coverPng,
		coverGif
	};
	enum fileType_t
	{
		fileTypeNormal = 0,
		fileTypeCDDA = 1,
		fileTypeDenied = 2,
		fileTypeSkip = 3
	};

	const AudioFileModel analyzeFile(const QString &filePath, int *type);
	void updateInfo(AudioFileModel &audioFile, bool *skipNext, unsigned int *id_val, cover_t *coverType, QByteArray *coverData, const QString &key, const QString &value);
	unsigned int parseYear(const QString &str);
	unsigned int parseDuration(const QString &str);
	bool checkFile_CDDA(QFile &file);
	void retrieveCover(AudioFileModel &audioFile, cover_t coverType, const QByteArray &coverData);
	bool analyzeAvisynthFile(const QString &filePath, AudioFileModel &info);
	void waitForPreviousThreads(void);

	const unsigned __int64 m_threadIdx;

	const QString m_mediaInfoBin;
	const QString m_avs2wavBin;
	const QString m_templateFile;
	const QString m_inputFile;
	
	volatile bool *m_abortFlag;

	static QReadWriteLock s_lock;
	static QMutex s_waitMutex;
	static QWaitCondition s_waitCond;
	
	static unsigned __int64 s_threadIdx_created;
	static unsigned __int64 s_threadIdx_finished;

	static QStringList s_recentlyAdded;
	static QStringList s_additionalFiles;
	
	static unsigned int s_filesAccepted;
	static unsigned int s_filesRejected;
	static unsigned int s_filesDenied;
	static unsigned int s_filesDummyCDDA;
	static unsigned int s_filesCueSheet;
	
	static unsigned __int64 makeThreadIdx(void);
};