workspace/plasma/dataengines/nowplaying/playerinterface/dbuswatcher.cpp

   1 /*
   2  * Copyright 2008  Alex Merry <alex.merry@kdemail.net>
   3  *
   4  * This library is free software; you can redistribute it and/or
   5  * modify it under the terms of the GNU Lesser General Public
   6  * License as published by the Free Software Foundation; either
   7  * version 2.1 of the License, or (at your option) any later version.
   8  *
   9  * This library is distributed in the hope that it will be useful,
  10  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  11  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  12  * Lesser General Public License for more details.
  13  *
  14  * You should have received a copy of the GNU Lesser General Public
  15  * License along with this program.  If not, see <http://www.gnu.org/licenses/>.
  16  */
  17 #include "dbuswatcher.h"
  18
  19 #include "player.h"
  20 #include "playerfactory.h"
  21
  22 #include <QtDBus>
  23 #include <KDebug>
  24
  25 DBusWatcher::DBusWatcher(QObject* parent)
  26     : QObject(parent),
  27       m_bus(0)
  28 {
  29     setObjectName("DBusWatcher");
  30     QDBusConnection sessionCon = QDBusConnection::sessionBus();
  31     if (sessionCon.isConnected()) {
  32         m_bus = sessionCon.interface();
  33         connect(m_bus, SIGNAL(serviceOwnerChanged(QString,QString,QString)),
  34                 this,  SLOT(serviceChange(QString,QString,QString)));
  35     } else {
  36         kWarning() << "Couldn't connect to session bus";
  37     }
  38 }
  39
  40 QList<Player::Ptr> DBusWatcher::players()
  41 {
  42     return m_players.values();
  43 }
  44
  45 void DBusWatcher::addFactory(DBusPlayerFactory* factory)
  46 {
  47     m_factories.append(factory);
  48
  49     QDBusReply<QStringList> reply = m_bus->registeredServiceNames();
  50     if (reply.isValid()) {
  51         QStringList services = reply.value();
  52         foreach (const QString &name, services) {
  53             if (factory->matches(name)) {
  54                 if (m_players.contains(name)) {
  55                     kWarning() << "Already got a player called" << name;
  56                 } else {
  57                     QVariantList args;
  58                     args << QVariant(name);
  59                     Player::Ptr player = factory->create(args);
  60                     if (!player.isNull()) {
  61                         m_players[name] = player;
  62                         emit(newPlayer(player));
  63                     } else {
  64                         kWarning() << "Failed to get player" << name;
  65                     }
  66                 }
  67             }
  68         }
  69     } else {
  70         kWarning() << "Couldn't get service names:" << reply.error().message();
  71     }
  72 }
  73
  74 void DBusWatcher::serviceChange(const QString& name,
  75                                 const QString& oldOwner,
  76                                 const QString& newOwner)
  77 {
  78     if (oldOwner.isEmpty() && !newOwner.isEmpty()) {
  79         // got a new service
  80         foreach (DBusPlayerFactory* factory, m_factories) {
  81             if (factory->matches(name)) {
  82                 if (m_players.contains(name)) {
  83                     kWarning() << "Already got a player at" << name;
  84                 } else {
  85                     QVariantList args;
  86                     args << QVariant(name);
  87                     Player::Ptr player = factory->create(args);
  88                     if (!player.isNull()) {
  89                         m_players[name] = player;
  90                         emit(newPlayer(player));
  91                     } else {
  92                         kWarning() << "Failed to get player" << name;
  93                     }
  94                 }
  95             }
  96         }
  97     } else if (!oldOwner.isEmpty() && newOwner.isEmpty()) {
  98         // an old service disappeared
  99         if (m_players.contains(name)) {
 100             Player::Ptr player = m_players[name];
 101             m_players.remove(name);
 102             emit(playerDisappeared(player));
 103         }
 104     }
 105 }