/**
 * Overlay drawing test application.
 */

#include "../../overlay/overlay.h"

#include "SharedMemory.h"
#include "Timer.h"

#ifdef Q_OS_WIN
# include "win.h"
#endif

#include <QtCore>
#include <QtNetwork>
#include <QtGui>

#include <ctime>

class OverlayWidget : public QWidget {
		Q_OBJECT

	protected:
		QImage img;
		OverlayMsg om;
		QLocalSocket *qlsSocket;
		SharedMemory2 *smMem;
		QTimer *qtTimer;
		QRect qrActive;
		QTime qtWall;

		unsigned int iFrameCount;
		int iLastFpsUpdate;

		unsigned int uiWidth, uiHeight;

		void resizeEvent(QResizeEvent *);
		void paintEvent(QPaintEvent *);
		void init(const QSize &);
		void detach();

		void keyPressEvent(QKeyEvent *);
	protected slots:
		void connected();
		void disconnected();
		void readyRead();
		void error(QLocalSocket::LocalSocketError);
		void update();
	public:
		OverlayWidget(QWidget *p = NULL);
};

OverlayWidget::OverlayWidget(QWidget *p) : QWidget(p) {
	qlsSocket = NULL;
	smMem = NULL;
	uiWidth = uiHeight = 0;

	setFocusPolicy(Qt::StrongFocus);
	setFocus();

	qtTimer = new QTimer(this);
	connect(qtTimer, SIGNAL(timeout()), this, SLOT(update()));
	qtTimer->start(100);
}

void OverlayWidget::keyPressEvent(QKeyEvent *evt) {
	evt->accept();
	qWarning("Keypress");
	detach();
}

void OverlayWidget::resizeEvent(QResizeEvent *evt) {
	QWidget::resizeEvent(evt);

	if (! img.isNull())
		img = img.scaled(evt->size().width(), evt->size().height());
	init(evt->size());
}

void OverlayWidget::paintEvent(QPaintEvent *) {
	if (! qlsSocket || qlsSocket->state() == QLocalSocket::UnconnectedState) {
		detach();

		qlsSocket = new QLocalSocket(this);
		connect(qlsSocket, SIGNAL(connected()), this, SLOT(connected()));
		connect(qlsSocket, SIGNAL(disconnected()), this, SLOT(disconnected()));
		connect(qlsSocket, SIGNAL(readyRead()), this, SLOT(readyRead()));
		connect(qlsSocket, SIGNAL(error(QLocalSocket::LocalSocketError)), this, SLOT(error(QLocalSocket::LocalSocketError)));
#ifdef Q_OS_WIN
		qlsSocket->connectToServer(QLatin1String("MumbleOverlayPipe"));
#else
		qlsSocket->connectToServer(QDir::home().absoluteFilePath(QLatin1String(".MumbleOverlayPipe")));
#endif
	}

	QPainter painter(this);
	painter.fillRect(0, 0, width(), height(), QColor(128,0,128));
	painter.setClipRect(qrActive);
	painter.drawImage(0, 0, img);
}

void OverlayWidget::init(const QSize &sz) {
	qWarning() << "Init" << sz.width() << sz.height();

	qtWall.start();
	iFrameCount = 0;
	iLastFpsUpdate = 0;

	OverlayMsg m;
	m.omh.uiMagic = OVERLAY_MAGIC_NUMBER;
	m.omh.uiType = OVERLAY_MSGTYPE_INIT;
	m.omh.iLength = sizeof(OverlayMsgInit);
	m.omi.uiWidth = sz.width();
	m.omi.uiHeight = sz.height();

	if (qlsSocket && qlsSocket->state() == QLocalSocket::ConnectedState)
		qlsSocket->write(m.headerbuffer, sizeof(OverlayMsgHeader) + sizeof(OverlayMsgInit));

	img = QImage(sz.width(), sz.height(), QImage::Format_ARGB32_Premultiplied);
}

void OverlayWidget::detach() {
	if (qlsSocket) {
		qlsSocket->abort();
		qlsSocket->deleteLater();
		qlsSocket = NULL;
	}
	if (smMem) {
		smMem = NULL;
	}
}

void OverlayWidget::connected() {
	qWarning() << "connected";

	OverlayMsg m;
	m.omh.uiMagic = OVERLAY_MAGIC_NUMBER;
	m.omh.uiType = OVERLAY_MSGTYPE_PID;
	m.omh.iLength = sizeof(OverlayMsgPid);
#ifdef Q_OS_WIN
	m.omp.pid = GetCurrentProcessId();
#else
	m.omp.pid = getpid();
#endif
	qlsSocket->write(m.headerbuffer, sizeof(OverlayMsgHeader) + sizeof(OverlayMsgPid));

	om.omh.iLength = -1;

	init(size());
}

void OverlayWidget::disconnected() {
	qWarning() << "disconnected";

	QLocalSocket *qls = qobject_cast<QLocalSocket *>(sender());
	if (qls == qlsSocket) {
		detach();
	}
}

void OverlayWidget::error(QLocalSocket::LocalSocketError) {
	qWarning() << "error";
	disconnected();
}

void OverlayWidget::update() {
	++iFrameCount;

	clock_t t = clock();
	float elapsed = static_cast<float>(qtWall.elapsed() - iLastFpsUpdate) / 1000.0f;

	if (elapsed > OVERLAY_FPS_INTERVAL) {
		struct OverlayMsg om;
		om.omh.uiMagic = OVERLAY_MAGIC_NUMBER;
		om.omh.uiType = OVERLAY_MSGTYPE_FPS;
		om.omh.iLength = sizeof(struct OverlayMsgFps);
		om.omf.fps = static_cast<int>(static_cast<float>(iFrameCount) / elapsed);

		if (qlsSocket && qlsSocket->state() == QLocalSocket::ConnectedState) {
			qlsSocket->write(reinterpret_cast<char*>(&om), sizeof(OverlayMsgHeader) + om.omh.iLength);
		}

		iFrameCount = 0;
		iLastFpsUpdate = 0;
		qtWall.start();
	}

	QWidget::update();
}

void OverlayWidget::readyRead() {
	QLocalSocket *qls = qobject_cast<QLocalSocket *>(sender());
	if (qls != qlsSocket)
		return;

	while (true) {
		int ready = qlsSocket->bytesAvailable();

		if (om.omh.iLength == -1) {
			if (ready < sizeof(OverlayMsgHeader))
				break;
			else {
				qlsSocket->read(reinterpret_cast<char *>(om.headerbuffer), sizeof(OverlayMsgHeader));
				if ((om.omh.uiMagic != OVERLAY_MAGIC_NUMBER) || (om.omh.iLength < 0) || (om.omh.iLength > sizeof(OverlayMsgShmem))) {
					detach();
					return;
				}
				ready -= sizeof(OverlayMsgHeader);
			}
		}

		if (ready >= om.omh.iLength) {
			int length = qlsSocket->read(om.msgbuffer, om.omh.iLength);

			qWarning() << length << om.omh.uiType;

			if (length != om.omh.iLength) {
				detach();
				return;
			}

			switch (om.omh.uiType) {
				case OVERLAY_MSGTYPE_SHMEM: {
						OverlayMsgShmem *oms = & om.oms;
						QString key = QString::fromUtf8(oms->a_cName, length);
						qWarning() << "SHMAT" << key;
						if (smMem)
							delete smMem;
						smMem = new SharedMemory2(this, width() * height() * 4, key);
						if (! smMem->data()) {
							qWarning() << "SHMEM FAIL";
							delete smMem;
							smMem = NULL;
						} else {
							qWarning() << "SHMEM" << smMem->size();
						}
					}
					break;
				case OVERLAY_MSGTYPE_BLIT: {
						OverlayMsgBlit *omb = & om.omb;
						length -= sizeof(OverlayMsgBlit);

						qWarning() << "BLIT" << omb->x << omb->y << omb->w << omb->h;

						if (! smMem)
							break;

						if (((omb->x + omb->w) > img.width()) ||
						        ((omb->y + omb->h) > img.height()))
							break;


						for (int y = 0; y < omb->h; ++y) {
							unsigned char *src = reinterpret_cast<unsigned char *>(smMem->data()) + 4 * (width() * (y + omb->y) + omb->x);
							unsigned char *dst = img.scanLine(y + omb->y) + omb->x * 4;
							memcpy(dst, src, omb->w * 4);
						}

						update();
					}
					break;
				case OVERLAY_MSGTYPE_ACTIVE: {
						OverlayMsgActive *oma = & om.oma;

						qWarning() << "ACTIVE" << oma->x << oma->y << oma->w << oma->h;

						qrActive = QRect(oma->x, oma->y, oma->w, oma->h);
						update();
					};
					break;
				default:
					break;
			}
			om.omh.iLength = -1;
			ready -= length;
		} else {
			break;
		}
	}
}

class TestWin : public QObject {
		Q_OBJECT

	protected:
		QWidget *qw;
	public:
		TestWin();
};

TestWin::TestWin() {
	QMainWindow *qmw = new QMainWindow();
	qmw->setObjectName(QLatin1String("main"));

	OverlayWidget *ow = new OverlayWidget();
	qmw->setCentralWidget(ow);

	qmw->show();
	qmw->resize(1280, 720);

	QMetaObject::connectSlotsByName(this);
}

int main(int argc, char **argv) {
	QApplication a(argc, argv);

	TestWin t;

	return a.exec();
}

#include "OverlayTest.moc"