#include "batchserversviewer.h"
#include "toonzqt/menubarcommand.h"
#include "menubarcommandids.h"
#include "floatingpanelcommand.h"
#include "tfarmstuff.h"
#include "batches.h"
#include "tsystem.h"

#include <QGridLayout>
#include <QLabel>
#include <QComboBox>
#include <QPushButton>
#include <QSettings>
#include <QMouseEvent>
#include <QMenu>

using namespace DVGui;
using namespace TFarmStuff;

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

class MyListItem : public QListWidgetItem
{
public:
	QString m_id;

	MyListItem(const QString &id, const QString &name, QListWidget *w) : QListWidgetItem(name, w), m_id(id) {}
};

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

FarmServerListView::FarmServerListView(QWidget *parent)
	: QListWidget(parent)
{
	setFrameStyle(QFrame::StyledPanel);
}

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

void FarmServerListView::update()
{
	try {
		while (count())
			delete takeItem(0);

		TFarmController *controller = getTFarmController();

		vector<ServerIdentity> servers;
		controller->getServers(servers);
		vector<ServerIdentity>::iterator it = servers.begin();
		for (; it != servers.end(); ++it) {
			ServerIdentity sid = *it;
			new MyListItem(sid.m_id, sid.m_name, this);
		}
	} catch (TException &e) {
		MsgBox(WARNING, QString::fromStdString(toString(e.getMessage())));
	}
}

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

void FarmServerListView::activate()
{
	MyListItem *item = (MyListItem *)currentItem();
	if (!item)
		return;

	TFarmController *controller = getTFarmController();
	try {
		controller->activateServer(item->m_id);
		BatchesController::instance()->update();
		static_cast<BatchServersViewer *>(parentWidget())->updateSelected();
	} catch (TException &e) {
		MsgBox(WARNING, QString::fromStdString(toString(e.getMessage())));
	}
}

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

void FarmServerListView::deactivate()
{
	MyListItem *item = (MyListItem *)currentItem();
	if (!item)
		return;

	TFarmController *controller = getTFarmController();
	try {
		controller->deactivateServer(item->m_id);
		BatchesController::instance()->update();
		static_cast<BatchServersViewer *>(parentWidget())->updateSelected();
	} catch (TException &e) {
		MsgBox(WARNING, QString::fromStdString(toString(e.getMessage())));
	}
}
//-----------------------------------------------------------------------------

void FarmServerListView::openContextMenu(const QPoint &p)
{
	MyListItem *item = (MyListItem *)currentItem();
	if (!item)
		return;

	m_menu.reset(new QMenu(this));

	TFarmController *controller = getTFarmController();
	ServerState state;
	try {
		state = controller->queryServerState2(item->m_id);
	} catch (TException &e) {
		MsgBox(WARNING, QString::fromStdString(toString(e.getMessage())));
		return;
	}

	QAction *action;
	if (state == Offline) {
		action = new QAction(tr("Activate"), this);
		connect(action, SIGNAL(triggered(bool)), this, SLOT(activate()));
	} else {
		action = new QAction(tr("Deactivate"), this);
		connect(action, SIGNAL(triggered(bool)), this, SLOT(deactivate()));
	}

	m_menu->addAction(action);
	m_menu->exec(p);
}

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

void FarmServerListView::mousePressEvent(QMouseEvent *event)
{
	QListWidget::mousePressEvent(event);

	if (event->button() == Qt::RightButton)
		openContextMenu(event->globalPos());
}

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

void BatchServersViewer::updateServerInfo(const QString &id)
{
	if (id == "") {
		m_name->setText("");
		m_ip->setText("");
		m_port->setText("");
		m_state->setText("");
		m_tasks->setText("");
		m_cpu->setText("");
		m_mem->setText("");
		return;
	}

	if (id == "localhost") {
		m_name->setText(TSystem::getHostName());
		m_ip->setText("");
		m_port->setText("");
		m_state->setText("");
		m_tasks->setText("");
		m_cpu->setText(QString::number(TSystem::getProcessorCount()));

#ifdef WIN32
		//Please observe that the commented value is NOT the same reported by tfarmserver...
		MEMORYSTATUSEX buff;
		buff.dwLength = sizeof(MEMORYSTATUSEX);
		GlobalMemoryStatusEx(&buff);

		unsigned long mem = buff.ullTotalPhys >> 30;
		m_mem->setText(QString::number(mem, 'g', 2) + " GB");
#else
		double mem = (double)TSystem::getFreeMemorySize(false) / (1024 * 1024);
		m_mem->setText(QString::number(mem, 'g', 2) + " GB");
#endif

		return;
	}

	TFarmController *controller = getTFarmController();
	ServerInfo info;

	try {
		controller->queryServerInfo(id, info);
	} catch (TException &e) {
		MsgBox(WARNING, QString::fromStdString(toString(e.getMessage())));
	}

	switch (info.m_state) {
	case Ready:
		m_state->setText("Ready");
		break;
	case Busy:
		m_state->setText("Busy");
		break;
	case NotResponding:
		m_state->setText("Not Responding");
		break;
	case Down:
		m_state->setText("Down");
		break;
	case Offline:
		m_state->setText("Offline");
		break;
	case ServerUnknown:
		m_state->setText("");
		m_name->setText("");
		m_ip->setText("");
		m_port->setText("");
		m_tasks->setText("");
		m_cpu->setText("");
		m_mem->setText("");
		return;
	}

	m_name->setText(info.m_name);
	m_ip->setText(info.m_ipAddress);
	m_port->setText(info.m_portNumber);
	if (info.m_currentTaskId == "")
		m_tasks->setText("");
	else {
		TFarmTask task;
		try {
			controller->queryTaskInfo(info.m_currentTaskId, task);
			m_tasks->setText("<" + task.m_id + "> " + task.m_name);
		} catch (TException &e) {
			m_tasks->setText("");
			MsgBox(WARNING, QString::fromStdString(toString(e.getMessage())));
		}
	}

	if (info.m_state != Down) {
		m_cpu->setText(QString::number(info.m_cpuCount));
		double mem = (double)info.m_totPhysMem / (1024 * 1024);
		m_mem->setText(QString::number(mem, 'g', 2) + " GB");
	} else {
		m_cpu->setText("");
		m_mem->setText("");
	}
}

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

void BatchServersViewer::updateSelected()
{
	MyListItem *item = (MyListItem *)m_serverList->currentItem();
	onCurrentItemChanged(item);
}

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

void BatchServersViewer::onCurrentItemChanged(QListWidgetItem *_item)
{
	MyListItem *item = (MyListItem *)_item;
	updateServerInfo(item ? item->m_id : QString());
}

//=============================================================================
/*! \class BatchServersViewer
		\brief The BatchServersViewer class is a ...

		Inherits \b QFrame.
*/

LineEdit *create(QGridLayout *layout, const QString &name, int &row, bool readOnly = true)
{
	layout->addWidget(new QLabel(name), row, 0, Qt::AlignRight);
	LineEdit *ret = new LineEdit();
	ret->setReadOnly(readOnly);
	layout->addWidget(ret, row++, 1);
	return ret;
}

#if QT_VERSION >= 0x050500
BatchServersViewer::BatchServersViewer(QWidget *parent, Qt::WindowFlags flags)
#else
BatchServersViewer::BatchServersViewer(QWidget *parent, Qt::WFlags flags)
#endif
	: QFrame(parent)
{
	int row = 0;

	setFrameStyle(QFrame::StyledPanel);
	setObjectName("OnePixelMarginFrame");

	QGridLayout *layout = new QGridLayout();
	layout->setMargin(15);
	layout->setSpacing(8);

	layout->addWidget(new QLabel(tr("Process with:")), row, 0, Qt::AlignRight);
	m_processWith = new QComboBox();
	QStringList type;
	type << tr("Local") << tr("Render Farm");
	m_processWith->addItems(type);
	layout->addWidget(m_processWith, row++, 1);
	connect(m_processWith, SIGNAL(currentIndexChanged(int)), this, SLOT(onProcessWith(int)));

	m_farmRootField = ::create(layout, tr("Farm Global Root:"), row, false);

	QString path = QSettings().value("TFarmGlobalRoot").toString();
	if (path != "") {
		m_farmRootField->setText(path);
		TFarmStuff::setGlobalRoot(TFilePath(path.toStdWString()));
	}
	connect(m_farmRootField, SIGNAL(editingFinished()),
			this, SLOT(setGRoot()));

	m_serverList = new FarmServerListView(this);
	connect(
		m_serverList, SIGNAL(currentItemChanged(QListWidgetItem *, QListWidgetItem *)),
		this, SLOT(onCurrentItemChanged(QListWidgetItem *)));
	//connect(m_serverList, SIGNAL(itemPressed(QListWidgetItem *)), this, SLOT(onCurrentItemChanged(QListWidgetItem *)));

	layout->addWidget(m_serverList, row, 0, 18, 2);
	row += 18 + 1;

	m_name = ::create(layout, tr("Name:"), row);
	m_ip = ::create(layout, tr("IP Address:"), row);
	m_port = ::create(layout, tr("Port Number:"), row);
	m_tasks = ::create(layout, tr("Tasks:"), row);
	m_state = ::create(layout, tr("State:"), row);
	m_cpu = ::create(layout, tr("Number of CPU:"), row);
	m_mem = ::create(layout, tr("Physical Memory:"), row);

	setLayout(layout);
}

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

BatchServersViewer::~BatchServersViewer()
{
}

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

void BatchServersViewer::setGRoot()
{
	TFarmStuff::setGlobalRoot(TFilePath(m_farmRootField->text().toStdWString()));
	QSettings().setValue("TFarmGlobalRoot", m_farmRootField->text());
}

//=============================================================================
// vinz: GRootEnvVarPopup togliere?

void BatchServersViewer::onProcessWith(int index)
{
	if (index == 0) {
		BatchesController::instance()->setController(0);
		m_serverList->clear();
		m_serverId = "localhost";
		return;
	}

	bool connected = false;
	try {
		connected = TFarmStuff::testConnectionToController();
	} catch (TMissingGRootEnvironmentVariable &) {
		MsgBox(WARNING, QString(tr("In order to use the render farm you have to define the Farm Global Root first.")));
		m_processWith->setCurrentIndex(0);
		return;
	} catch (TMissingGRootFolder &) {
		MsgBox(WARNING, tr("The Farm Global Root folder doesn't exist\nPlease create this folder before using the render farm."));
		m_processWith->setCurrentIndex(0);
		return;
	} catch (TException &e) {
		MsgBox(WARNING, QString::fromStdString(toString(e.getMessage())));
		m_processWith->setCurrentIndex(0);
		return;
	}

	if (!TFarmStuff::testConnectionToController()) {
		QString hostName, addr;
		int port;
		TFarmStuff::getControllerData(hostName, addr, port);

		QString msg(tr("Unable to connect to the ToonzFarm Controller\n \
  The Controller should run on %1 at port %2\n \
  Please start the Controller before using the ToonzFarm")
						.arg(hostName)
						.arg(QString::number(port)));

		MsgBox(WARNING, msg);
		m_processWith->setCurrentIndex(0);
		return;
	}

	BatchesController::instance()->setController(getTFarmController());

	m_serverList->update();

	//m_serversListView->update();
	//if (m_serversListView->getItemCount() > 0)
	//  m_serversListView->select(0, true);
}

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

OpenFloatingPanel openBatchServersCommand(MI_OpenBatchServers, "BatchServers", QObject::tr("Batch Servers"));