#include "ZMQServer.h"

#include <QCoreApplication>
#include <QByteArray>

#include "MainWindow.h"

ZMQServer::ZMQServer(QObject* param)
	: QThread(param)
	, ctx_()
	, socket_(ctx_, zmq::socket_type::pull){
}

bool ZMQServer::Start(quint16 port) {
	qDebug() << "NetClient::Start listen port=" << port;
	if (!stop_) {
		return false;
	}

	stop_ = false;
	port_ = port;
	start();
	return true;
}

void ZMQServer::Stop() {
	//m_udpSocket->close();
	stop_ = true;
	try {
		socket_.close();
		ctx_.close();
	}
	catch (const std::exception&) {

	}
	
	wait();
}

void ZMQServer::run() {
	std::string host = "tcp://0.0.0.0:" + std::to_string(port_);
	socket_.bind(host);
	while (!stop_) {
		zmq::message_t request;
		try {
			//char buffer[256] = { 0 };
			auto ok = socket_.recv(request, zmq::recv_flags::none);
			if (ok) {
				QByteArray buffer(reinterpret_cast<char*>(request.data()), (int)request.size());
				QString message(buffer);
				emit MessageReady(message);
				zmq::message_t reply(2);
				memcpy(reply.data(), "ok", 2);
				socket_.send(reply);
			}
		}
		catch (const std::exception&) {
			
		}
		
		
	}

	//socket_.unbind(host);
}