retroshare-gui now handle JsonApiServer too

2025-07-22 14:10:54 -04:00 · 2018-09-21 01:58:38 +02:00 · 2018-09-21 01:58:38 +02:00 · ccabf82e60
commit ccabf82e60
parent 1c7f02655e
10 changed files with 461 additions and 26 deletions
--- a/retroshare-gui/src/gui/settings/JsonApiPage.cc
+++ b/retroshare-gui/src/gui/settings/JsonApiPage.cc
@ -0,0 +1,173 @@
+/*
+ * RetroShare JSON API
+ * Copyright (C) 2018  Gioacchino Mazzurco <gio@eigenlab.org>
+ *
+ * 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 "JsonApiPage.h"
+
+#include "rsharesettings.h"
+#include "jsonapi/jsonapi.h"
+#include "util/misc.h"
+
+#include <QTimer>
+#include <QStringListModel>
+#include <QProgressDialog>
+
+
+JsonApiPage::JsonApiPage(QWidget */*parent*/, Qt::WindowFlags /*flags*/)
+{
+	ui.setupUi(this);
+	connect( ui.addTokenPushButton, &QPushButton::clicked,
+	         this, &JsonApiPage::addTokenClicked);
+	connect( ui.removeTokenPushButton, &QPushButton::clicked,
+	         this, &JsonApiPage::removeTokenClicked );
+	connect( ui.tokensListView, &QListView::clicked,
+	         this, &JsonApiPage::tokenClicked );
+	connect( ui.applyConfigPushButton, &QPushButton::clicked,
+	         this, &JsonApiPage::onApplyClicked );
+}
+
+bool JsonApiPage::updateParams(QString &errmsg)
+{
+	bool ok = true;
+	bool changed = false;
+
+	bool enabled = ui.enableCheckBox->isChecked();
+	if( enabled != Settings->getJsonApiEnabled())
+	{
+		Settings->setJsonApiEnabled(enabled);
+		changed = true;
+	}
+
+	uint16_t port = ui.portSpinBox->value();
+	if(port != Settings->getJsonApiPort())
+	{
+		Settings->setJsonApiPort(port);
+		changed = true;
+	}
+
+	QString listenAddress = ui.listenAddressLineEdit->text();
+	if(listenAddress != Settings->getJsonApiListenAddress())
+	{
+		Settings->setJsonApiListenAddress(listenAddress);
+		changed = true;
+	}
+
+	if(changed)
+	{
+		checkShutdownJsonApi();
+		ok = checkStartJsonApi();
+	}
+
+	if(!ok) errmsg = "Could not start JSON API Server!";
+	return ok;
+}
+
+void JsonApiPage::load()
+{
+	whileBlocking(ui.enableCheckBox)->setChecked(Settings->getJsonApiEnabled());
+	whileBlocking(ui.portSpinBox)->setValue(Settings->getJsonApiPort());
+	whileBlocking(ui.listenAddressLineEdit)->setText(Settings->getJsonApiListenAddress());
+	whileBlocking(ui.tokensListView)->setModel(new QStringListModel(Settings->getJsonApiAuthTokens()));
+}
+
+QString JsonApiPage::helpText() const { return ""; }
+
+/*static*/ bool JsonApiPage::checkStartJsonApi()
+{
+	checkShutdownJsonApi();
+
+	if(Settings->getJsonApiEnabled())
+	{
+		jsonApiServer = new JsonApiServer(
+		            Settings->getJsonApiPort(),
+		            Settings->getJsonApiListenAddress().toStdString() );
+		jsonApiServer->start("jsonApiServer");
+
+		for(const QString& token : Settings->getJsonApiAuthTokens())
+			jsonApiServer->authorizeToken(token.toStdString());
+	}
+
+	return true;
+}
+
+/*static*/ void JsonApiPage::checkShutdownJsonApi()
+{
+	if(jsonApiServer)
+	{
+		/* It is important to make a copy of +jsonApiServer+ pointer so the old
+		 * object can be deleted later, while the original pointer is
+		 * reassigned */
+		JsonApiServer* oldJsonApiServer = jsonApiServer;
+		jsonApiServer = nullptr;
+
+		oldJsonApiServer->shutdown();
+
+		QProgressDialog* pd = new QProgressDialog(
+		            "Stopping JSON API Server", QString(), 0, 3000);
+		QTimer* prtm = new QTimer;
+		prtm->setInterval(16); // 60 FPS
+		connect( prtm, &QTimer::timeout,
+		         pd, [=](){pd->setValue(pd->value()+16);} );
+		pd->show();
+		prtm->start();
+
+		/* Must wait for deletion because stopping of the server is async.
+		 * It is important to capture a copy so it "survive" after
+		 * safeStopJsonApiServer returns */
+		QTimer::singleShot(3*1000, [=]()
+		{
+			delete oldJsonApiServer;
+			prtm->stop();
+			pd->close();
+			prtm->deleteLater();
+			pd->deleteLater();
+		});
+	}
+}
+
+void JsonApiPage::onApplyClicked(bool)
+{
+	QString errmsg;
+	updateParams(errmsg);
+}
+
+void JsonApiPage::addTokenClicked(bool)
+{
+	QString token(ui.tokenLineEdit->text());
+	if(jsonApiServer) jsonApiServer->authorizeToken(token.toStdString());
+	QStringList newTk(Settings->getJsonApiAuthTokens());
+	newTk.removeAll(token);
+	newTk.append(token);
+	Settings->setJsonApiAuthTokens(newTk);
+	whileBlocking(ui.tokensListView)->setModel(new QStringListModel(newTk));
+}
+
+void JsonApiPage::removeTokenClicked(bool)
+{
+	QString token(ui.tokenLineEdit->text());
+	if(jsonApiServer) jsonApiServer->revokeAuthToken(token.toStdString());
+	QStringList newTk(Settings->getJsonApiAuthTokens());
+	newTk.removeAll(token);
+	Settings->setJsonApiAuthTokens(newTk);
+	whileBlocking(ui.tokensListView)->setModel(
+	            new QStringListModel(Settings->getJsonApiAuthTokens()) );
+}
+
+void JsonApiPage::tokenClicked(const QModelIndex& index)
+{
+	ui.tokenLineEdit->setText(ui.tokensListView->model()->data(index).toString());
+}
+