1 files changed, 91 insertions, 0 deletions
diff --git a/src/plugins/General/udisks/udisksmanager.cpp b/src/plugins/General/udisks/udisksmanager.cpp
new file mode 100644
index 000000000..749f36ab1
--- /dev/null
+++ b/src/plugins/General/udisks/udisksmanager.cpp
@@ -0,0 +1,91 @@
+/***************************************************************************
+ *   Copyright (C) 2013-2021 by Ilya Kotov                                 *
+ *   forkotov02@ya.ru                                                      *
+ *                                                                         *
+ *   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 Street, Fifth Floor, Boston, MA  02110-1301, USA.         *
+ ***************************************************************************/
+
+#include <QDBusInterface>
+#include <QDBusConnection>
+#include <QDBusReply>
+#include <QDBusArgument>
+#include <QDBusMetaType>
+#include <QXmlStreamReader>
+#include "udisksmanager.h"
+
+UDisksManager::UDisksManager(QObject *parent)
+        : QObject(parent)
+{
+    m_interface = new QDBusInterface("org.freedesktop.UDisks2", "/org/freedesktop/UDisks2",
+                                     "org.freedesktop.DBus.ObjectManager",
+                                     QDBusConnection::systemBus(), this);
+
+    m_interface->connection().connect("org.freedesktop.UDisks2", "/org/freedesktop/UDisks2",
+                                      "org.freedesktop.DBus.ObjectManager", "InterfacesAdded",
+                                      this, SLOT(onInterfacesAdded(QDBusObjectPath,QVariantMapMap)));
+
+    m_interface->connection().connect("org.freedesktop.UDisks2", "/org/freedesktop/UDisks2",
+                                      "org.freedesktop.DBus.ObjectManager", "InterfacesRemoved",
+                                      this, SIGNAL(onInterfacesRemoved(QDBusObjectPath, QStringList)));
+}
+
+
+UDisksManager::~UDisksManager()
+{
+}
+
+QList<QDBusObjectPath> UDisksManager::findAllDevices()
+{
+    QList<QDBusObjectPath> paths;
+    QDBusMessage call = QDBusMessage::createMethodCall("org.freedesktop.UDisks2",
+                                                       "/org/freedesktop/UDisks2/block_devices",
+                                                       "org.freedesktop.DBus.Introspectable",
+                                                       "Introspect");
+    QDBusPendingReply<QString> reply = QDBusConnection::systemBus().call(call);
+
+
+    if (!reply.isValid())
+    {
+        qWarning("UDisks2Manager: error: %s", qPrintable(reply.error().name()));
+        return paths;
+    }
+    QXmlStreamReader xml(reply.value());
+    while (!xml.atEnd())
+    {
+        xml.readNext();
+        if (xml.tokenType() == QXmlStreamReader::StartElement && xml.name().toString() == "node" )
+        {
+            QString name = xml.attributes().value("name").toString();
+            if(!name.isEmpty())
+                paths << QDBusObjectPath("/org/freedesktop/UDisks2/block_devices/" + name);
+        }
+    }
+    return paths;
+}
+
+void UDisksManager::onInterfacesAdded(const QDBusObjectPath &object_path, const QVariantMapMap &)
+{
+    if(object_path.path().startsWith("/org/freedesktop/UDisks2/jobs"))
+        return;
+    emit deviceAdded(object_path);
+}
+
+void UDisksManager::onInterfacesRemoved(const QDBusObjectPath &object_path, const QStringList &)
+{
+    if(object_path.path().startsWith("/org/freedesktop/UDisks2/jobs"))
+        return;
+    emit deviceRemoved(object_path);
+}