aboutsummaryrefslogtreecommitdiff
path: root/rwa-support-desktopapp/src/session.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'rwa-support-desktopapp/src/session.cpp')
-rw-r--r--rwa-support-desktopapp/src/session.cpp271
1 files changed, 271 insertions, 0 deletions
diff --git a/rwa-support-desktopapp/src/session.cpp b/rwa-support-desktopapp/src/session.cpp
new file mode 100644
index 0000000..25a8512
--- /dev/null
+++ b/rwa-support-desktopapp/src/session.cpp
@@ -0,0 +1,271 @@
+/*
+ * This file is part of Remote Support Desktop
+ * https://gitlab.das-netzwerkteam.de/RemoteWebApp/rwa.support.desktopapp
+ * Copyright 2020, 2021 Daniel Teichmann <daniel.teichmann@das-netzwerkteam.de>
+ * Copyright 2020, 2021 Mike Gabriel <mike.gabriel@das-netzwerkteam.de>
+ * SPDX-License-Identifier: GPL-2.0-or-later
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 2 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 General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program; if not, write to the
+ * Free Software Foundation, Inc.,
+ * 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program. If not, see <https://www.gnu.org/licenses/>.
+ */
+
+#include "session.h"
+
+Session::Session(DBusAPI *dbus_api, RWAHost *host) : QObject() {
+ Q_ASSERT(host != nullptr);
+ Q_ASSERT(dbus_api != nullptr);
+
+ _dbus_api = dbus_api;
+ _host = host;
+
+ setPin("-----");
+ setSessionID("-----");
+ setURL(tr("Not available yet"));
+ setStatus("unknown");
+ started = false;
+}
+
+Session::~Session() {
+ qDebug().noquote() << QString("Session #'%0' on host '%1' will be deconstructed.")
+ .arg(getSessionID())
+ .arg(getHost()->alias());
+ stop();
+ disconnect();
+}
+
+void Session::statusTimerEvent() {
+ qDebug() << "Status timer event triggered";
+
+ refresh_status();
+}
+
+bool Session::isSessionAliveOrRunning() {
+ if (getStatus() == "running" || getStatus() == "active") {
+ return true;
+ } else {
+ return false;
+ }
+}
+
+RWAHost* Session::getHost() {
+ return _host;
+}
+
+QString Session::getStatus() {
+ return _status;
+}
+
+QString Session::getURL() {
+ return _url;
+}
+
+QString Session::getSessionID() {
+ return _session_id;
+}
+
+QString Session::getPin() {
+ return _pin;
+}
+
+void Session::setURL(QString url) {
+ _url = url;
+ emit urlChanged(url);
+}
+
+void Session::setSessionID(QString session_id) {
+ _session_id = session_id;
+ emit sessionIDChanged(session_id);
+}
+
+void Session::setPin(QString pin) {
+ _pin = pin;
+ emit pinChanged(pin);
+}
+
+void Session::setHost(RWAHost *host) {
+ _host = host;
+ emit hostChanged(host);
+}
+
+void Session::setStatus(QString status) {
+ _status = status;
+ emit statusChanged(status);
+}
+
+void Session::start() {
+ _dbus_api->start_request(_host);
+}
+
+void Session::start_response(QJsonDocument *doc) {
+ // Q_ASSERT lets the program crash immediatly after method call
+ // when the session service is not started.
+ // Don't use Q_ASSERT(doc != nullptr); instead use:
+ if (doc == nullptr) {
+ emit startFailed(tr("Can't connect to underlying session service! "
+ "Is the session service started?"));
+ return;
+ }
+
+ // Get the QJsonObject
+ QJsonObject jObject = doc->object();
+ QVariantMap mainMap = jObject.toVariantMap();
+
+ // Status of request
+ QString status = mainMap["status"].toString();
+ if (status != "success") {
+ QString type = mainMap["type"].toString();
+ QString error_message = tr("An error occured while creating a new session!");
+
+ if (type == "multiple") {
+ // TODO: Ask to stop other session via a message dialog.
+ error_message = tr("The session service is configured "
+ "to not support multiple sessions "
+ "and there is already a session running.");
+ } else if (type == "connection") {
+ error_message = tr("Couldn't connect to host '%0'.")
+ .arg(getHost()->alias());
+ } else if (type == "host_not_found") {
+ error_message = tr("The RWA host '%0' couldn't be found.")
+ .arg(getHost()->alias());
+ } else if (type == "permission_denid") {
+ error_message = tr("The RWA host '%0' doesn't grant access.")
+ .arg(getHost()->alias());
+ } else if (type == "unsupported_server") {
+ error_message = tr("The RWA host '%0' is not supported.")
+ .arg(getHost()->alias());
+ }
+
+ setStatus("start_session_error");
+ qCritical().noquote() << error_message;
+ emit startFailed(error_message);
+ return;
+ }
+
+ bool ok;
+
+ // URL of remote web app frontend
+ QString url = mainMap["url"].toString();
+ this->setURL(url);
+
+ // PIN
+ long long pin = mainMap["pin"].toLongLong(&ok);
+ // Sanity Check
+ if(ok == false){
+ QString error_message = "Unable to parse <pin> into longo long out of dbus answer!";
+ qCritical().noquote() << error_message;
+ emit startFailed(error_message);
+ return;
+ }
+ this->setPin(QString::number(pin));
+
+ // session_id = remote support id from the rwa-server
+ long long session_id = mainMap["session_id"].toLongLong();
+ // Sanity Check
+ if(ok == false){
+ QString error_message = "Unable to parse <session_id> into long long out of dbus answer!";
+ qCritical().noquote() << error_message;
+ emit startFailed(error_message);
+ return;
+ }
+ this->setSessionID(QString::number(session_id));
+
+ qDebug() << "Got session_id:" << session_id <<
+ "\nGot url:" << url <<
+ "\nGot pin:" << pin;
+
+ emit pinChanged(QString::number(pin));
+ emit urlChanged(url);
+ emit sessionIDChanged(QString::number(session_id));
+
+ started = true;
+
+ // Ask status every 1000 millisecond
+
+ QTimer *timer = new QTimer(this);
+ connect(timer, &QTimer::timeout, this,
+ QOverload<>::of(&Session::statusTimerEvent));
+ timer->start(1000);
+
+ qDebug() << "Successfully started a session.";
+ this->setStatus("start_session_success");
+
+ emit startSucceeded();
+}
+
+void Session::stop() {
+ if (started)
+ _dbus_api->stop_request(getHost(), getSessionID());
+}
+
+void Session::stop_response(QJsonDocument *doc) {
+ // Q_ASSERT lets the program crash immediatly after method call
+ // when the session service is not started.
+ // Don't use Q_ASSERT(doc != nullptr); instead use:
+ if (doc == nullptr) {
+ emit stopFailed(tr("Can't connect to underlying session service! "
+ "Is the session service started?"));
+ return;
+ }
+
+ QJsonObject jObject = doc->object();
+ QVariantMap mainMap = jObject.toVariantMap();
+
+ QString new_status = mainMap["status"].toString();
+ qDebug() << "stop_response() retrieved json. Status now:" << new_status;
+
+ started = false;
+
+ this->setStatus(new_status);
+
+ emit stopSucceeded();
+}
+
+void Session::status() {
+ _dbus_api->status_request(getHost(), this->getSessionID());
+}
+
+void Session::refresh_status() {
+ _dbus_api->refresh_status_request(getHost(), this->getSessionID());
+}
+
+void Session::status_response(QJsonDocument *doc) {
+ // Q_ASSERT lets the program crash immediatly after method call,
+ // when the session service is not started.
+ // Don't use Q_ASSERT(doc != nullptr); instead use:
+ if (doc == nullptr) {
+ if (!_emitted_status_error_already) {
+ emit statusFailed(tr("Can't connect to underlying session service! "
+ "Is the session service started?"));
+
+ _emitted_status_error_already = true;
+ }
+
+ return;
+ }
+
+ _emitted_status_error_already = false;
+
+ QJsonObject jObject = doc->object();
+ QVariantMap mainMap = jObject.toVariantMap();
+ QString new_status = mainMap["status"].toString();
+ qDebug() << "status_response() retrieved json. Status:" << new_status;
+
+ setStatus(new_status);
+
+ emit statusSucceeded();
+}
generated by cgit v1.2.3 (git 2.25.1) at 2025-11-25 01:36:27 +0000