#include "application.h"
#include "tfarmcontroller.h"
#include "ttcpip.h"
#include "tfilepath.h"
#include "tsystem.h"
#include "tthread.h"
#include "tenv.h"
#include "tconvert.h"
#include "tfilepath_io.h"
#include <vector>
#include <set>
#include <assert.h>
#include <fstream>
using namespace std;

//===================================================================

namespace
{

TFilePath getGlobalRoot()
{
#ifdef WIN32
	TFilePath groot(TSystem::getSystemValue(
		TFilePath("SOFTWARE\\Digital Video\\ToonzFarm\\1.0\\GLOBALROOT")));

	return groot;
#else
	TFilePath name = "TFARMGLOBALROOT";
	char *s = getenv(name.getFullPath().c_str());
	TFilePath rootDir = string(s ? s : "");
	return rootDir;
#endif
}
};

class Application::Imp
{
public:
	Imp() : m_farmController(0) {}
	~Imp() {}

	void loadControllerData();

	TFarmController *m_farmController;
	TFilePath m_currentFolder;

	ControllerData m_controllerData;
};

//------------------------------------------------------------------------------

void Application::Imp::loadControllerData()
{
	TFilePath groot = getGlobalRoot();
	TFilePath fp = groot + "config" + "controller.txt";

	::loadControllerData(fp, m_controllerData);
}

//===================================================================

namespace
{

//===================================================================

Application *theApp;
bool programEnded = false;

class Cleanup
{
public:
	~Cleanup()
	{
		delete theApp;
		theApp = 0;
		programEnded = true;
	}
} cleanup;

//===================================================================

} // end of anonymous namespace

//===================================================================

Application::Application() : m_imp(new Imp)
{
}

//------------------------------------------------------------------------------

Application::~Application()
{
	delete m_imp;
}

//------------------------------------------------------------------------------

Application *Application::instance()
{
	assert(!programEnded);
	if (!theApp) {
		static TThread::Mutex AppMutex;
		TThread::ScopedLock sl(AppMutex);
		if (programEnded)
			return 0;

		if (!theApp)
			theApp = new Application;
	}
	return theApp;
}

//------------------------------------------------------------------------------

TFarmController *Application::getController()
{
	return m_imp->m_farmController;
}

//------------------------------------------------------------------------------

bool Application::testControllerConnection() const
{
	TTcpIpClient client;

	int sock;
	int ret = client.connect(m_imp->m_controllerData.m_hostName,
							 m_imp->m_controllerData.m_ipAddress,
							 m_imp->m_controllerData.m_port,
							 sock);
	if (ret == OK) {
		client.disconnect(sock);
		return true;
	}
	return false;
}

//------------------------------------------------------------------------------

void Application::getControllerData(string &hostName, string &ipAddr, int &port) const
{
	hostName = m_imp->m_controllerData.m_hostName;
	ipAddr = m_imp->m_controllerData.m_ipAddress;
	port = m_imp->m_controllerData.m_port;
}

//------------------------------------------------------------------------------

void Application::init()
{
	m_imp->loadControllerData();

	TFarmControllerFactory factory;
	int ret = factory.create(m_imp->m_controllerData, &m_imp->m_farmController);
}

//------------------------------------------------------------------------------

void Application::setCurrentFolder(const TFilePath &fp)
{
	m_imp->m_currentFolder = fp;
}

//------------------------------------------------------------------------------

TFilePath Application::getCurrentFolder()
{
	return m_imp->m_currentFolder;
}