#include "DaemonQT.h"
#include "../../Daemon.h"
#include "i2pd_qt_gui.h"
#include "mainwindow.h"
#include <QMessageBox>
#include <QApplication>
#include <QMutexLocker>
#include <QThread>

namespace i2p
{
namespace util
{
	 bool DaemonQT::init(int argc, char* argv[])
     {
     	return Daemon_Singleton::init(argc, argv);
     }
}
}

namespace i2p
{
namespace qt
{
	Worker::Worker (DaemonQTImpl& daemon):
		m_Daemon (daemon)
	{
	}

	void Worker::startDaemon() 
	{
		qDebug("Performing daemon start...");
		m_Daemon.start();
		qDebug("Daemon started.");
		emit resultReady();
	}
	void Worker::restartDaemon() 
	{
		qDebug("Performing daemon restart...");
		m_Daemon.restart();
		qDebug("Daemon restarted.");
		emit resultReady();
	}
	void Worker::stopDaemon() {
		qDebug("Performing daemon stop...");
		m_Daemon.stop();
		qDebug("Daemon stopped.");
		emit resultReady();
	}

    Controller::Controller(DaemonQTImpl& daemon):
		m_Daemon (daemon) 
	{
		Worker *worker = new Worker (m_Daemon);
		worker->moveToThread(&workerThread);
		connect(&workerThread, &QThread::finished, worker, &QObject::deleteLater);
		connect(this, &Controller::startDaemon, worker, &Worker::startDaemon);
		connect(this, &Controller::stopDaemon, worker, &Worker::stopDaemon);
		connect(this, &Controller::restartDaemon, worker, &Worker::restartDaemon);
		connect(worker, &Worker::resultReady, this, &Controller::handleResults);
		workerThread.start();
	}
	Controller::~Controller() 
	{
		qDebug("Closing and waiting for daemon worker thread...");
		workerThread.quit();
		workerThread.wait();
		qDebug("Waiting for daemon worker thread finished.");
        if(m_Daemon.isRunning())
        {
		    qDebug("Stopping the daemon...");
            m_Daemon.stop();
		    qDebug("Stopped the daemon.");
		}
	}
	
	DaemonQTImpl::DaemonQTImpl ():
        mutex(nullptr), m_IsRunning(nullptr), m_RunningChangedCallback(nullptr)
	{
	}

	DaemonQTImpl::~DaemonQTImpl ()
	{
		delete mutex;
	}

	bool DaemonQTImpl::init(int argc, char* argv[])
	{
		mutex=new QMutex(QMutex::Recursive);
		setRunningCallback(0);
        m_IsRunning=false;
		return Daemon.init(argc,argv);

	}
	void DaemonQTImpl::deinit()
	{
		delete mutex; mutex = nullptr;
	}

	void DaemonQTImpl::start()
	{
		QMutexLocker locker(mutex);
		setRunning(true);
		Daemon.start();
	}

	void DaemonQTImpl::stop()
	{
		QMutexLocker locker(mutex);
		Daemon.stop();
		setRunning(false);
	}

	void DaemonQTImpl::restart()
	{
		QMutexLocker locker(mutex);
		stop();
		start();
	}

	void DaemonQTImpl::setRunningCallback(runningChangedCallback cb)				
	{
		m_RunningChangedCallback = cb;
	}

	bool DaemonQTImpl::isRunning()
	{
        return m_IsRunning;
	}

	void DaemonQTImpl::setRunning(bool newValue)
	{
        bool oldValue = m_IsRunning;
		if(oldValue!=newValue) 
		{
            m_IsRunning = newValue;
		    if(m_RunningChangedCallback)
				m_RunningChangedCallback();
		}
	}

	int RunQT (int argc, char* argv[])
	{
		 //int result = runGUI(argc, argv);
		//QMessageBox::information(0,"Debug","runGUI completed");
		QApplication app(argc, argv);
		DaemonQTImpl daemon;
		qDebug("Initialising the daemon...");
		bool daemonInitSuccess = daemon.init(argc, argv);
		if(!daemonInitSuccess) 
		{
		    QMessageBox::critical(0, "Error", "Daemon init failed");
		    return 1;
		}
		qDebug("Initialised, creating the main window...");
		MainWindow w;
		qDebug("Before main window.show()...");
		w.show ();
		int result;
		{
		    i2p::qt::Controller daemonQtController(daemon);
		    qDebug("Starting the daemon...");
		    emit daemonQtController.startDaemon();
		    qDebug("Starting gui event loop...");
		    result = app.exec();
		    //QMessageBox::information(&w, "Debug", "exec finished");
		}
		daemon.deinit();
		//QMessageBox::information(&w, "Debug", "demon stopped");
		//exit(result); //return from main() causes intermittent sigsegv bugs in some Androids. exit() is a workaround for this
		qDebug("Exiting the application");
		return result;
	}
}
}