blob: f8d4b7bec7edce9eef956a3a695ea89a8ef44fc6 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
|
#include "add_server_wizard.h"
#include "../../RWADBusAdaptor.h"
#include <QDebug>
#include <QtDBus>
#include <QDBusPendingCallWatcher>
Add_Server_wizard::Add_Server_wizard(QObject *parent) : QObject(parent) {
_initDBus();
}
bool Add_Server_wizard::processStep1(QString host_url) {
qDebug() << "Processing Step 1 with args: " << host_url;
if(host_url == "") {
emit step1Failed(tr("This field can't be empty!"));
return false;
}
return _add_server(host_url);
}
bool Add_Server_wizard::processStep2() {
qDebug() << "Processing Step 2 with args: No Args.";
emit step2Failed(tr("The feature you expected here are not yet implemented."));
// Just show placeholder scene now.
emit step2Success();
return false;
}
bool Add_Server_wizard::_add_server(QString host_url) {
return _add_web_app_host(host_url);
}
void Add_Server_wizard::_initDBus() {
if (!QDBusConnection::sessionBus().isConnected()) {
qCritical() << "Cannot connect to the D-Bus session bus.";
}
// Create DBus object
_dbus_rwa = new OrgArcticaProjectRWASupportSessionServiceInterface("org.ArcticaProject.RWASupportSessionService", "/RWASupportSessionService",
QDBusConnection::sessionBus(), this->parent());
qDebug("Initialized DBus object!");
}
bool Add_Server_wizard::_add_web_app_host(QString host_url) {
qDebug() << "Requesting D-Bus session service to add a new host: " << host_url;
// Make an asynchrous 'add_web_app_host' call (Response will be sent to '_add_web_app_host_dbus_replied')
QDBusPendingCall async = _dbus_rwa->asyncCall("add_web_app_host", host_url);
QDBusPendingCallWatcher *watcher = new QDBusPendingCallWatcher(async, this);
QObject::connect(watcher, SIGNAL(finished(QDBusPendingCallWatcher*)),
this, SLOT(_add_web_app_host_dbus_replied(QDBusPendingCallWatcher*)));
return true;
}
void Add_Server_wizard::_add_web_app_host_dbus_replied(QDBusPendingCallWatcher *call) {
QString result = "";
QDBusPendingReply<QString> reply = *call;
if (reply.isError()) {
qDebug() << "D-Bus 'add_web_app_host' request failed, this was the reply:";
qDebug() << reply.error();
return;
} else {
result = reply.argumentAt<0>();
}
call->deleteLater();
qDebug() << "Raw JSON from starting session is:" << result.toUtf8().replace('"', "");
QJsonDocument doc = QJsonDocument::fromJson(result.toUtf8());
// Get the QJsonObject
QJsonObject jObject = doc.object();
QVariantMap mainMap = jObject.toVariantMap();
// Status of request
QString request_status = mainMap["status"].toString();
if (request_status == "success") {
qDebug() << "Successfully started a Session.";
emit step1Success();
} else {
qCritical() << "An error occured while adding a new host!";
QString reason = "An error occured while adding a new host!";
QString type = mainMap["type"].toString();
if(type == "connection"){
reason = tr("Couldn't connect to the specified host!");
} else if (type == "duplicate") {
reason = tr("The specified host was already added!");
} else if (type == "invalid_url") {
reason = tr("The specified host address is not valid!");
}
emit step1Failed(reason);
}
}
|
