#include "cupdatethread.h"
#include "cserie.h"
#include "cseason.h"
#include "cepisode.h"
#include "cthetvdb.h"
#include "cmessagedialog.h"

#include <QDebug>
#include <QTime>


cUpdateThread::cUpdateThread() :
	m_bStop(false)
{
}

void cUpdateThread::stop()
{
	QMutexLocker	locker(&m_mutex);
	m_bStop	= true;
	emit updateAppendMessage(" - cancel pending ...");
}

void cUpdateThread::run()
{
	QTime	timer;
	timer.restart();

	for(int x = 0;x < m_indexList.count();x++)
	{
		cSerie*	lpSerie	= m_indexList.at(x).data(Qt::UserRole).value<cSerie*>();
		if(lpSerie)
		{
			emit updateMessage(lpSerie->seriesName(), x);
			cTheTVDB		tvDB;
			cSerie*			lpSerieNew;

			if(lpSerie->seriesID() != -1)
			{
				lpSerieNew	= tvDB.load(lpSerie->id(), "de");

				lpSerieNew->setDownload(lpSerie->download());
				for(int x = 0;x < lpSerieNew->seasonList().count();x++)
				{
					cSeason*	lpSeasonNew	= lpSerieNew->seasonList().at(x);
					for(int y = 0;y < lpSeasonNew->episodeList().count();y++)
					{
						cEpisode*	lpEpisodeNew	= lpSeasonNew->episodeList().at(y);
						cEpisode*	lpEpisode		= lpSerie->findEpisode(lpEpisodeNew->id());
						if(lpEpisode)
							lpEpisodeNew->setState(lpEpisode->state());
					}
				}
				lpSerie->del(m_db);
				lpSerieNew->save(m_db);
			}
		}

		QMutexLocker	locker(&m_mutex);
		if(m_bStop)
			break;
		msleep(10);
	}
}

void cUpdateThread::setData(cMessageDialog* lpMessageDialog, const QModelIndexList &indexList, const QSqlDatabase& db)
{
	connect(lpMessageDialog->cancelButton(), SIGNAL(clicked()), this, SLOT(stop()));
	m_indexList	= indexList;
	m_db		= db;
}