File Metadata

Created: Sun, Feb 15, 1:13 PM

conduitclient.cpp
View Options

	#include "conduitclient.h"
	#include "QtNetwork/QNetworkAccessManager"
	#include <QtNetwork/QNetworkRequest>
	#include <QUrlQuery>
	#include <QJsonDocument>
	#include <ctime>
	#include <QEventLoop>
	#include <QEventLoopLocker>
	#include <QtNetwork/QNetworkReply>

	QEventLoopLocker* lockerWaitingResponce = 0;

	ConduitClient::~ConduitClient(){}

	ConduitClient::ConduitClient(const QString& uri, const QString& user, const QString& token, const QString& certificate)
	: QObject(nullptr), m_URI(uri), m_user(user), m_conduitToken(token), m_certificate(certificate), m_manager(new QNetworkAccessManager()), m_loopWaitingResponce(new QEventLoop())
	{
	connect(m_manager, SIGNAL(finished(QNetworkReply*)),
	this, SLOT(replyReceived(QNetworkReply*)));
	}

	bool
	ConduitClient::createSession()
	{
	const QString token = QString("%1").arg(time(0));
	const QString signatureRaw = token + m_certificate;
	QByteArray signatureHash = QCryptographicHash::hash(signatureRaw.toLatin1(), QCryptographicHash::Sha1);
	QString signatureHashLatin = QString::fromLatin1(signatureHash.toHex());
	QJsonObject query;
	query["authToken"] = token;
	query["authSignature"] =signatureHashLatin;
	query["client"] = "juffed-client";
	query["clientVersion"] = "1";
	query["user"] = m_user;

	QJsonObject reply = requestRaw("conduit.connect", query);

	//Example: "result\":{\"connectionID\":17,\"sessionKey\":\"l6jih3u7kxz3i624tewq2fvvmvmjiwzzp5ddicnk\"
	if (reply.contains("result")){
	QJsonObject sessionData = reply.find("result").value().toObject();

	if (sessionData.empty()) return false;
	m_SessionKey = sessionData["sessionKey"].toString();
	m_ConnectionID = sessionData["connectionID"].toInt();;
	return true;
	}

	return false;
	}

	QJsonObject
	ConduitClient::request(const QString& method, const QJsonObject& json){
	if (m_SessionKey.isNull()) {
	if (!createSession()){
	return QJsonObject();
	}
	}

	QJsonObject metaQuery;
	metaQuery["sessionKey"] = m_SessionKey;
	metaQuery["connectionID"] = m_ConnectionID;
	metaQuery["token"] = m_conduitToken;

	QJsonObject query(json);
	query["__conduit__"] = metaQuery;

	return requestRaw(method, query);
	}

	void
	ConduitClient::replyReceived(QNetworkReply* reply){
	m_serverReply = reply;

	delete lockerWaitingResponce;
	lockerWaitingResponce = 0;
	}

	QJsonObject
	ConduitClient::requestRaw(const QString& method, const QJsonObject& json)
	{
	QUrl requestUrl(m_URI + "/api/" + method);

	QUrlQuery query;
	query.addQueryItem("output", "json");
	query.addQueryItem("__conduit__", "true");
	query.addQueryItem("params", QJsonDocument(json).toJson(QJsonDocument::Compact));

	qDebug()<<requestUrl;
	qDebug()<<query.toString();

	QNetworkRequest request(requestUrl);
	request.setHeader(QNetworkRequest::ContentTypeHeader, "application/x-www-form-urlencoded");

	m_manager->post(request, query.toString(QUrl::FullyEncoded).replace("+", "%2B").toUtf8());
	lockerWaitingResponce = new QEventLoopLocker(m_loopWaitingResponce);
	m_loopWaitingResponce->exec();

	QString replyJson(m_serverReply->readAll());
	qDebug() << replyJson;
	delete m_serverReply;

	return QJsonDocument::fromJson(replyJson.toUtf8()).object();
	}

	//void
	//ConduitClient::req

conduitclient.cpp
No OneTemporary
Actions

File Metadata

conduitclient.cpp
View Options

Event Timeline

conduitclient.cppNo OneTemporaryActions

File Metadata

conduitclient.cppView Options

Event Timeline

conduitclient.cpp
No OneTemporary
Actions

conduitclient.cpp
View Options