RetroShare/retroshare-qml-app/src/libresapilocalclient.cpp

/*
 * RetroShare Android QML App
 * Copyright (C) 2016-2018  Gioacchino Mazzurco <gio@eigenlab.org>
 * Copyright (C) 2016  Manu Pineda <manu@cooperativa.cat>
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Affero General Public License as
 * published by the Free Software Foundation, either version 3 of the
 * License, or (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU Affero General Public License for more details.
 *
 * You should have received a copy of the GNU Affero General Public License
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
 */

#include "libresapilocalclient.h"

#include <QJSEngine>
#include <QtDebug>

void LibresapiLocalClient::openConnection(const QString& socketPath)
{
	connect(& mLocalSocket, SIGNAL(error(QLocalSocket::LocalSocketError)),
	        this, SLOT(socketError(QLocalSocket::LocalSocketError)));
	connect(& mLocalSocket, SIGNAL(readyRead()),
	        this, SLOT(read()));
	mSocketPath = socketPath;
	socketConnectAttempt();
}

int LibresapiLocalClient::request( const QString& path, const QString& jsonData,
                                   QJSValue callback )
{
#ifdef QT_DEBUG
	if(mDebug)
		qDebug() << reqCount++ << __PRETTY_FUNCTION__ << path << jsonData
		         << callback.toString();
#endif // QT_DEBUG

	int ret = -1;

	if(mLocalSocket.isOpen())
	{
		QByteArray data;
		data.append(path); data.append('\n');
		data.append(jsonData); data.append('\n');
		processingQueue.enqueue(PQRecord(path, jsonData, callback));
		ret = mLocalSocket.write(data);
		if(ret < 0) socketError(mLocalSocket.error());
	}
	else
	{
		if(!mConnectAttemptTimer.isActive()) mConnectAttemptTimer.start();
		qDebug() << __PRETTY_FUNCTION__
		         << "Socket not ready yet! Ignoring request: "
		         << path << jsonData;
	}

	return ret;
}

void LibresapiLocalClient::socketError(QLocalSocket::LocalSocketError error)
{
	qCritical() << __PRETTY_FUNCTION__ << "Socket error! " << error
	            << mLocalSocket.errorString();

#ifdef QT_DEBUG
	QString pQueueDump;

	for (auto& qe: processingQueue )
	{
		pQueueDump.append(qe.mPath);
		pQueueDump.append(QChar::Space);
		pQueueDump.append(qe.mJsonData);
		pQueueDump.append(QChar::LineSeparator);
	}

	qDebug() << __PRETTY_FUNCTION__ << "Discarded requests dump:"
	         << QChar::LineSeparator << pQueueDump;
#endif //QT_DEBUG

	processingQueue.clear();

	if(mLocalSocket.state() == QLocalSocket::UnconnectedState &&
	        !mConnectAttemptTimer.isActive())
	{
		qDebug() << __PRETTY_FUNCTION__ << "Socket:" << mSocketPath
		         << "is not connected, scheduling a connect attempt again";

		mConnectAttemptTimer.start();
	}
}

void LibresapiLocalClient::read()
{
	if(processingQueue.isEmpty())
	{
		qCritical() << __PRETTY_FUNCTION__ << "callbackQueue is empty "
		            << "something really fishy is happening!";
		return;
	}

	if(!mLocalSocket.canReadLine())
	{
		qWarning() << __PRETTY_FUNCTION__
		           << "Strange, can't read a complete line!";
		return;
	}

	QByteArray&& ba(mLocalSocket.readLine());
	if(ba.size() < 2)
	{
		qWarning() << __PRETTY_FUNCTION__ << "Got answer of less then 2 bytes,"
		           << "something fishy is happening!";
		return;
	}

	QString receivedMsg(ba);
	PQRecord&& p(processingQueue.dequeue());

#ifdef QT_DEBUG
	if(mDebug)
		qDebug() << ansCount++ << __PRETTY_FUNCTION__ << receivedMsg << p.mPath
		         << p.mJsonData << p.mCallback.toString();
#endif // QT_DEBUG

	emit goodResponseReceived(receivedMsg); /// @deprecated
	emit responseReceived(receivedMsg);

	if(p.mCallback.isCallable())
	{
		QJSValue&& params(p.mCallback.engine()->newObject());
		params.setProperty("response", receivedMsg);

		QJSValue temp =  p.mCallback.call(QJSValueList { params });
		if(temp.isError())
		{
			qCritical() << __PRETTY_FUNCTION__
			            << "JavaScript callback uncaught exception:"
			            << temp.property("stack").toString()
			            << temp.toString();
		}
	}

	// In case of multiple reply coaleshed in the same signal
	if(mLocalSocket.bytesAvailable() > 0) read();
}

LibresapiLocalClient::PQRecord::PQRecord( const QString&
#ifdef QT_DEBUG
                                          path
#endif //QT_DEBUG
                                          , const QString&
#ifdef QT_DEBUG
                                          jsonData
#endif //QT_DEBUG
                                          , const QJSValue& callback) :
#ifdef QT_DEBUG
    mPath(path), mJsonData(jsonData),
#endif //QT_DEBUG
    mCallback(callback) {}

#ifdef QT_DEBUG
void LibresapiLocalClient::setDebug(bool v)
{
	if(v != mDebug)
	{
		mDebug = v;
		emit debugChanged();
	}
}
#endif // QT_DEBUG