Changeset 14621

Timestamp:

Dec 16, 2015, 5:57:05 PM (7 years ago)

Author:

mikedld

Message:

Refactor DBus IPC to allow for further extensibility

Location:

trunk/qt

Files:

• Application.cc (modified) (6 diffs)
• CMakeLists.txt (modified) (4 diffs)
• DBusInteropHelper.cc (added)
• DBusInteropHelper.h (added)
• InteropObject.cc (moved) (moved from trunk/qt/DBusAdaptor.cc) (1 diff)
• InteropObject.h (moved) (moved from trunk/qt/DBusAdaptor.h) (2 diffs)

trunk/qt/Application.cc

@@ -12 +12 @@
 
 #include <QDBusConnection>
-#include <QDBusConnectionInterface>
-#include <QDBusError>
 #include <QDBusMessage>
+#include <QDBusReply>
 #include <QIcon>
 #include <QLibraryInfo>
@@ -29 +28 @@
 #include "AddData.h"
 #include "Application.h"
-#include "DBusAdaptor.h"
+#include "DBusInteropHelper.h"
 #include "Formatter.h"
 #include "MainWindow.h"
@@ -40 +39 @@
 namespace
 {
-  const QString DBUS_SERVICE     = QString::fromUtf8 ("com.transmissionbt.Transmission" );
-  const QString DBUS_OBJECT_PATH = QString::fromUtf8 ("/com/transmissionbt/Transmission");
-  const QString DBUS_INTERFACE   = QString::fromUtf8 ("com.transmissionbt.Transmission" );
-
   const QLatin1String MY_CONFIG_NAME ("transmission");
   const QLatin1String MY_READABLE_NAME ("transmission-qt");
@@ -163 +158 @@
   // try to delegate the work to an existing copy of Transmission
   // before starting ourselves...
-  QDBusConnection bus = QDBusConnection::sessionBus ();
-  if (bus.isConnected ())
-  {
-    bool delegated = false;
-    for (const QString& filename: filenames)
-      {
-        QDBusMessage request = QDBusMessage::createMethodCall (DBUS_SERVICE,
-                                                               DBUS_OBJECT_PATH,
-                                                               DBUS_INTERFACE,
-                                                               QString::fromUtf8 ("AddMetainfo"));
-        QList<QVariant> arguments;
-        AddData a (filename);
-        switch (a.type)
-          {
-            case AddData::URL:      arguments.push_back (a.url.toString ()); break;
-            case AddData::MAGNET:   arguments.push_back (a.magnet); break;
-            case AddData::FILENAME: arguments.push_back (QString::fromLatin1 (a.toBase64 ())); break;
-            case AddData::METAINFO: arguments.push_back (QString::fromLatin1 (a.toBase64 ())); break;
-            default:                break;
-          }
-        request.setArguments (arguments);
-
-        QDBusMessage response = bus.call (request);
-        //std::cerr << qPrintable (response.errorName ()) << std::endl;
-        //std::cerr << qPrintable (response.errorMessage ()) << std::endl;
-        arguments = response.arguments ();
-        delegated |= (arguments.size ()==1) && arguments[0].toBool ();
-      }
-
-    if (delegated)
-      {
-        quitLater ();
-        return;
-      }
-  }
+  DBusInteropHelper interopClient;
+  if (interopClient.isConnected ())
+    {
+      bool delegated = false;
+      for (const QString& filename: filenames)
+        {
+          QString metainfo;
+
+          AddData a (filename);
+          switch (a.type)
+            {
+              case AddData::URL:      metainfo = a.url.toString (); break;
+              case AddData::MAGNET:   metainfo = a.magnet; break;
+              case AddData::FILENAME: metainfo = QString::fromLatin1 (a.toBase64 ()); break;
+              case AddData::METAINFO: metainfo = QString::fromLatin1 (a.toBase64 ()); break;
+              default:                break;
+            }
+
+          if (metainfo.isEmpty ())
+            continue;
+
+          const QVariant result = interopClient.addMetainfo (metainfo);
+          if (result.isValid () && result.toBool ())
+            delegated = true;
+        }
+
+      if (delegated)
+        {
+          quitLater ();
+          return;
+        }
+    }
 
   // set the fallback config dir
@@ -303 +295 @@
     addTorrent (filename);
 
-  // register as the dbus handler for Transmission
-  if (bus.isConnected ())
-    {
-      new DBusAdaptor (this);
-      if (!bus.registerService (DBUS_SERVICE))
-        std::cerr << "couldn't register " << qPrintable (DBUS_SERVICE) << std::endl;
-      if (!bus.registerObject (DBUS_OBJECT_PATH, this))
-        std::cerr << "couldn't register " << qPrintable (DBUS_OBJECT_PATH) << std::endl;
-    }
+  DBusInteropHelper::registerObject (this);
 }
 
@@ -559 +543 @@
 Application::notifyApp (const QString& title, const QString& body) const
 {
+  const QLatin1String dbusServiceName ("org.freedesktop.Notifications");
+  const QLatin1String dbusInterfaceName ("org.freedesktop.Notifications");
+  const QLatin1String dbusPath ("/org/freedesktop/Notifications");
+
   QDBusConnection bus = QDBusConnection::sessionBus ();
-  if (!bus.isConnected ())
-    {
-      myWindow->trayIcon ().showMessage (title, body);
-      return true;
-    }
-
-  const QString dbusServiceName   = QString::fromUtf8 ("org.freedesktop.Notifications");
-  const QString dbusInterfaceName = QString::fromUtf8 ("org.freedesktop.Notifications");
-  const QString dbusPath          = QString::fromUtf8 ("/org/freedesktop/Notifications");
-
-  QDBusMessage m = QDBusMessage::createMethodCall (dbusServiceName, dbusPath, dbusInterfaceName, QString::fromUtf8 ("Notify"));
-  QList<QVariant> args;
-  args.append (QString::fromUtf8 ("Transmission")); // app_name
-  args.append (0U);                                   // replaces_id
-  args.append (QString::fromUtf8 ("transmission")); // icon
-  args.append (title);                                // summary
-  args.append (body);                                 // body
-  args.append (QStringList ());                       // actions - unused for plain passive popups
-  args.append (QVariantMap ());                       // hints - unused atm
-  args.append (static_cast<int32_t> (-1));            // use the default timeout period
-  m.setArguments (args);
-  QDBusMessage replyMsg = bus.call (m);
-  //std::cerr << qPrintable (replyMsg.errorName ()) << std::endl;
-  //std::cerr << qPrintable (replyMsg.errorMessage ()) << std::endl;
-  return (replyMsg.type () == QDBusMessage::ReplyMessage) && !replyMsg.arguments ().isEmpty ();
+  if (bus.isConnected ())
+    {
+      QDBusMessage m = QDBusMessage::createMethodCall (dbusServiceName, dbusPath, dbusInterfaceName, QLatin1String ("Notify"));
+      QVariantList args;
+      args.append (QLatin1String ("Transmission")); // app_name
+      args.append (0U);                             // replaces_id
+      args.append (QLatin1String ("transmission")); // icon
+      args.append (title);                          // summary
+      args.append (body);                           // body
+      args.append (QStringList ());                 // actions - unused for plain passive popups
+      args.append (QVariantMap ());                 // hints - unused atm
+      args.append (static_cast<int32_t> (-1));      // use the default timeout period
+      m.setArguments (args);
+      const QDBusReply<quint32> replyMsg = bus.call (m);
+      if (replyMsg.isValid () && replyMsg.value () > 0)
+        return true;
+    }
+
+  myWindow->trayIcon ().showMessage (title, body);
+  return true;
 }
 

trunk/qt/CMakeLists.txt

@@ -30 +30 @@
     Application.cc
     ColumnResizer.cc
-    DBusAdaptor.cc
+    DBusInteropHelper.cc
     DetailsDialog.cc
     FaviconCache.cc
@@ -45 +45 @@
     FreeSpaceLabel.cc
     IconToolButton.cc
+    InteropObject.cc
     LicenseDialog.cc
     MainWindow.cc
@@ -78 +79 @@
     ColumnResizer.h
     CustomVariantType.h
-    DBusAdaptor.h
+    DBusInteropHelper.h
     DetailsDialog.h
     FaviconCache.h
@@ -93 +94 @@
     FreeSpaceLabel.h
     IconToolButton.h
+    InteropObject.h
     LicenseDialog.h
     MainWindow.h

trunk/qt/InteropObject.cc

@@ -10 +10 @@
 #include "AddData.h"
 #include "Application.h"
-#include "DBusAdaptor.h"
+#include "InteropObject.h"
 
-DBusAdaptor::DBusAdaptor (Application* app):
-  QDBusAbstractAdaptor (app),
-  myApp (app)
+InteropObject::InteropObject (QObject * parent):
+  QObject (parent)
 {
 }
 
 bool
-DBusAdaptor::PresentWindow ()
+InteropObject::PresentWindow ()
 {
-  myApp->raise ();
+  qApp->raise ();
   return true;
 }
 
 bool
-DBusAdaptor::AddMetainfo (const QString& key)
+InteropObject::AddMetainfo (const QString& metainfo)
 {
-  AddData addme (key);
+  AddData addme (metainfo);
 
   if (addme.type != addme.NONE)
-    myApp->addTorrent (addme);
+    qApp->addTorrent (addme);
 
   return true;

trunk/qt/InteropObject.h

@@ -8 +8 @@
  */
 
-#ifndef QTR_DBUS_ADAPTOR_H
-#define QTR_DBUS_ADAPTOR_H
+#ifndef QTR_INTEROP_OBJECT_H
+#define QTR_INTEROP_OBJECT_H
 
-#include <QDBusAbstractAdaptor>
+#include <QObject>
 
-class Application;
-
-class DBusAdaptor: public QDBusAbstractAdaptor
+class InteropObject: public QObject
 {
     Q_OBJECT
@@ -21 +19 @@
 
   public:
-    DBusAdaptor (Application *);
-    virtual ~DBusAdaptor () {}
+    InteropObject (QObject * parent = nullptr);
 
   public slots:
     bool PresentWindow ();
-    bool AddMetainfo (const QString&);
-
-  private:
-    Application * myApp;
+    bool AddMetainfo (const QString& metainfo);
 };
 
-#endif // QTR_DBUS_ADAPTOR_H
+#endif // QTR_INTEROP_OBJECT_H