| 1 | /* |
|---|
| 2 | SPDX-FileCopyrightText: 2014 Aleix Pol Gonzalez <aleixpol@blue-systems.com> |
|---|
| 3 | |
|---|
| 4 | SPDX-License-Identifier: LGPL-2.1-or-later |
|---|
| 5 | */ |
|---|
| 6 | |
|---|
| 7 | #include <KPluginFactory> |
|---|
| 8 | #include <QDebug> |
|---|
| 9 | #include <QJsonArray> |
|---|
| 10 | #include <QProcess> |
|---|
| 11 | #include <QStandardPaths> |
|---|
| 12 | #include <purpose/pluginbase.h> |
|---|
| 13 | |
|---|
| 14 | #include <QDBusConnection> |
|---|
| 15 | #include <QDBusMessage> |
|---|
| 16 | #include <QDBusPendingCallWatcher> |
|---|
| 17 | #include <QDBusPendingReply> |
|---|
| 18 | |
|---|
| 19 | using namespace Qt::StringLiterals; |
|---|
| 20 | |
|---|
| 21 | class KDEConnectJob : public Purpose::Job |
|---|
| 22 | { |
|---|
| 23 | Q_OBJECT |
|---|
| 24 | public: |
|---|
| 25 | KDEConnectJob(QObject *parent) |
|---|
| 26 | : Purpose::Job(parent) |
|---|
| 27 | { |
|---|
| 28 | } |
|---|
| 29 | |
|---|
| 30 | QStringList arrayToList(const QJsonArray &array) |
|---|
| 31 | { |
|---|
| 32 | QStringList ret; |
|---|
| 33 | for (const QJsonValue &val : array) { |
|---|
| 34 | ret += val.toString(); |
|---|
| 35 | } |
|---|
| 36 | return ret; |
|---|
| 37 | } |
|---|
| 38 | |
|---|
| 39 | void start() override |
|---|
| 40 | { |
|---|
| 41 | const QString deviceId = data().value(key: QLatin1String("device" )).toString(); |
|---|
| 42 | QJsonArray urlsJson = data().value(key: QLatin1String("urls" )).toArray(); |
|---|
| 43 | |
|---|
| 44 | QDBusMessage msg = QDBusMessage::createMethodCall(destination: u"org.kde.kdeconnect"_s , |
|---|
| 45 | path: "/modules/kdeconnect/devices/"_L1 + deviceId + "/share"_L1 , |
|---|
| 46 | interface: u"org.kde.kdeconnect.device.share"_s , |
|---|
| 47 | method: u"shareUrls"_s ); |
|---|
| 48 | msg.setArguments({arrayToList(array: urlsJson)}); |
|---|
| 49 | |
|---|
| 50 | QDBusPendingReply<> reply = QDBusConnection::sessionBus().asyncCall(message: msg); |
|---|
| 51 | |
|---|
| 52 | QDBusPendingCallWatcher *watcher = new QDBusPendingCallWatcher(reply); |
|---|
| 53 | connect(sender: watcher, signal: &QDBusPendingCallWatcher::finished, context: this, slot: [this](QDBusPendingCallWatcher *watcher) { |
|---|
| 54 | QDBusPendingReply<> reply = *watcher; |
|---|
| 55 | if (reply.isError()) { |
|---|
| 56 | qWarning() << "kdeconnect share error:" << reply.error().message(); |
|---|
| 57 | setError(2); |
|---|
| 58 | setErrorText(reply.error().message()); |
|---|
| 59 | emitResult(); |
|---|
| 60 | } else { |
|---|
| 61 | setError(0); |
|---|
| 62 | setOutput({{QStringLiteral("url" ), QString()}}); |
|---|
| 63 | emitResult(); |
|---|
| 64 | } |
|---|
| 65 | }); |
|---|
| 66 | } |
|---|
| 67 | |
|---|
| 68 | private: |
|---|
| 69 | }; |
|---|
| 70 | |
|---|
| 71 | class KDEConnectPlugin : public Purpose::PluginBase |
|---|
| 72 | { |
|---|
| 73 | Q_OBJECT |
|---|
| 74 | public: |
|---|
| 75 | using PluginBase::PluginBase; |
|---|
| 76 | Purpose::Job *createJob() const override |
|---|
| 77 | { |
|---|
| 78 | return new KDEConnectJob(nullptr); |
|---|
| 79 | } |
|---|
| 80 | }; |
|---|
| 81 | |
|---|
| 82 | K_PLUGIN_CLASS_WITH_JSON(KDEConnectPlugin, "kdeconnectplugin.json" ) |
|---|
| 83 | |
|---|
| 84 | #include "kdeconnectplugin.moc" |
|---|
| 85 | |
|---|
