objectmanagerImpl.cpp

Go to the documentation of this file.

/*
 *
 *  Object Manager implementation of bluez5
 *
 *  Copyright (C) 2018  Emanoil Kotsev <deloptes@gmail.com>
 *
 *
 *  This file is part of libtdebluez.
 *
 *  libtdebluez 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.
 *
 *  libtdebluez 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 kbluetooth; if not, write to the Free Software
 *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
 *
 */
 
#include <tqstringlist.h>
 
#include <tqdbusmessage.h>
#include <tqdbusobjectpath.h>
#include <tqdbusdatamap.h>
#include <tqdbusdata.h>
#include <tqdbusdatalist.h>
#include <tqdbusvariant.h>
 
#include "objectmanagerImpl.h"
#include "btuuids.h"
 
namespace TDEBluetooth
{
 
ObjectManagerImpl::ObjectManagerImpl(const TQString& service, const TQString& path, TQObject* parent, const char* name) :
        ObjectManagerProxy(service, path, parent, name)
{
    agentManager = 0;
    profileManager = 0;
    healthManager  = 0;
    agentRegisteredStatus = false;
    agentIsDefaultAgent = false;
    // init connection to dbus
    initDBUS();
}
 
ObjectManagerImpl::~ObjectManagerImpl()
{
    // close D-Bus connection
    close();
 
    if(agentManager)
        delete agentManager;
    if(profileManager)
        delete profileManager;
    if(healthManager)
        delete healthManager;
}
 
bool ObjectManagerImpl::reconnect()
{
    // close D-Bus connection
    close();
    // init D-Bus conntection
    return (initDBUS());
}
 
bool ObjectManagerImpl::isConnectedToDBUS()
{
    return dBusConn.isConnected();
}
 
TQT_DBusConnection* ObjectManagerImpl::getConnection()
{
    return &dBusConn;
}
 
bool ObjectManagerImpl::close()
{
    disconnect(this, TQ_SIGNAL(InterfacesAdded(const TQT_DBusObjectPath&, const TQT_DBusDataMap< TQString >&)),
            this, TQ_SLOT(slotInterfacesAdded(const TQT_DBusObjectPath&, const TQT_DBusDataMap< TQString >& )));
    disconnect(this, TQ_SIGNAL(InterfacesRemoved(const TQT_DBusObjectPath& , const TQStringList& )),
            this, TQ_SLOT(slotInterfacesRemoved(const TQT_DBusObjectPath& , const TQStringList& )));
 
    for (PropertiesMap::iterator it = adapters.begin(); it != adapters.end();
            ++it)
    {
        org::freedesktop::DBus::PropertiesProxy *p;
        p = it.data();
        if (p != NULL)
            delete p;
    }
    for (PropertiesMap::iterator it = devices.begin(); it != devices.end();
            ++it)
    {
        org::freedesktop::DBus::PropertiesProxy *p;
        p = it.data();
        if (p != NULL)
            delete p;
    }
    adapters.clear();
    devices.clear();
 
    dBusConn.closeConnection(DBUS_CONN_NAME);
    return true;
}
 
AgentManager1Proxy * ObjectManagerImpl::getAgentManager()
{
    return agentManager;
}
 
ProfileManager1Proxy * ObjectManagerImpl::getProfileManager()
{
    return profileManager;
}
 
HealthManager1Proxy * ObjectManagerImpl::getHealthManager()
{
    return healthManager;
}
 
ObjectManagerImpl::AdapterList ObjectManagerImpl::getAdapters()
{
    return adapters.keys();
}
 
ObjectManagerImpl::DeviceList ObjectManagerImpl::getDevices()
{
    return devices.keys();
}
 
ObjectManagerImpl::ConnectionList ObjectManagerImpl::listConnections(const TQString &adapter)
{
    ConnectionList list;
    return list;
}
 
bool ObjectManagerImpl::registerAgent()
{
    if (!agentRegisteredStatus)
    {
        if (!agentManager)
        {
            tqDebug(i18n("AgentManager is not initialized"));
            return false;
        }
 
        TQT_DBusError dbuserror;
        agentManager->RegisterAgent(
                TQT_DBusObjectPath(TQCString(DBUS_AUTH_SERVICE_PATH)), DEVICE_PIN_CAPABILITY, dbuserror);
        if (dbuserror.isValid())
        {
            tqDebug(i18n("Could not register agent: %1").arg(dbuserror.message()));
            return false;
        }
        agentRegisteredStatus = true;
    }
    return true;
}
 
bool ObjectManagerImpl::unregisterAgent()
{
    kdDebug() << k_funcinfo << endl;
    if (agentRegisteredStatus)
    {
        TQT_DBusError dbuserror;
        getAgentManager()->UnregisterAgent(
                TQT_DBusObjectPath(TQCString(DBUS_AUTH_SERVICE_PATH)), dbuserror);
        if (dbuserror.isValid())
        {
            tqDebug(i18n("Could not unregister agent"));
            return false;
        }
        agentRegisteredStatus = false;
        agentIsDefaultAgent = false;
    }
    return true;
}
 
bool ObjectManagerImpl::requestDefaultAgent()
{
    if (!agentManager)
    {
        tqDebug(i18n("AgentManager is not initialized"));
        return false;
    }
 
    TQT_DBusError dbuserror;
    agentManager->RequestDefaultAgent(
            TQT_DBusObjectPath(TQCString(DBUS_AUTH_SERVICE_PATH)), dbuserror);
    if (dbuserror.isValid())
    {
        tqDebug(i18n("Could not request default agent: %1").arg(dbuserror.message()));
        return false;
    }
    agentIsDefaultAgent = true;
    return true;
}
 
bool ObjectManagerImpl::isAgentRegistered()
{
    return agentRegisteredStatus;
}
 
bool ObjectManagerImpl::isAgentDefaultAgent()
{
    return agentIsDefaultAgent;
}
 
bool ObjectManagerImpl::initDBUS()
{
    dBusConn = TQT_DBusConnection::addConnection(TQT_DBusConnection::SystemBus, DBUS_CONN_NAME);
    if (!dBusConn.isConnected())
    {
        tqDebug(i18n("Failed to open connection to system message bus: %1").arg(dBusConn.lastError().message()));
        TQTimer::singleShot(4000, this, TQ_SLOT(reconnect()));
        return false;
    }
    setConnection(dBusConn);
 
    TQT_DBusDataMap<TQT_DBusObjectPath> objects;
    TQT_DBusError dbuserror;
    if (!GetManagedObjects(objects, dbuserror))
    {
        tqDebug(i18n("GetManagedObjects(objects,error) failed: %1").arg(dbuserror.message()));
        return false;
    }
 
    TQT_DBusDataMap<TQT_DBusObjectPath>::const_iterator it = objects.begin();
    for (it; it != objects.end(); ++it)
    {
        bool ok = false;
        slotInterfacesAdded(it.key(), it.data().toStringKeyMap(&ok));
        if (!ok)
            tqWarning(i18n("Failed to convert dbus data to string map: %1").arg(it.key()));
    }
 
    connect(this, TQ_SIGNAL(InterfacesAdded(const TQT_DBusObjectPath&, const TQT_DBusDataMap< TQString >&)),
            this, TQ_SLOT(slotInterfacesAdded(const TQT_DBusObjectPath&, const TQT_DBusDataMap< TQString >& )));
    connect(this, TQ_SIGNAL(InterfacesRemoved(const TQT_DBusObjectPath& , const TQStringList& )),
            this, TQ_SLOT(slotInterfacesRemoved(const TQT_DBusObjectPath& , const TQStringList& )));
 
    return true;
}
 
void ObjectManagerImpl::adapterPropertiesChanged(TQString path, const TQMap<
        TQString, TQT_DBusVariant>& changed_properties)
{
    TQMap<TQString, TQT_DBusVariant>::const_iterator it;
    for (it = changed_properties.begin(); it != changed_properties.end(); ++it)
    {
        bool ok = false;
        if (it.key() == "Powered")
            emit adapterPowerOnChanged(path, it.data().value.toBool(&ok));
        else if (it.key() == "Class")
            emit adapterClassChanged(path, it.data().value.toUInt32(&ok));
        else if (it.key() == "Name")
            emit adapterNameChanged(path, it.data().value.toString(&ok));
        else if (it.key() == "Alias")
            emit adapterAliasChanged(path, it.data().value.toString(&ok));
        else if (it.key() == "DiscoverableTimeout")
            emit adapterDiscoverableTimeoutChanged(path, it.data().value.toUInt32(&ok));
        else if (it.key() == "Discoverable")
            emit adapterDiscoverableChanged(path, it.data().value.toBool(&ok));
        else if (it.key() == "Discovering")
            emit adapterDiscoveringChanged(path, it.data().value.toBool(&ok));
        else
            continue;
        if (!ok)
            tqDebug(i18n("ObjectManagerImpl::adapterPropertiesChanged conversion failed"));
    }
}
 
void ObjectManagerImpl::devicePropertiesChanged(TQString path, const TQMap<TQString, TQT_DBusVariant>& changed_properties)
{
    //  https://github.com/r10r/bluez/blob/master/doc/device-api.txt
    TQMap<TQString, TQT_DBusVariant>::const_iterator it;
    for (it = changed_properties.begin(); it != changed_properties.end(); ++it)
    {
        bool ok = false;
        if (it.key() == "Address")
            emit deviceAddressChanged(path, it.data().value.toString(&ok));
        else if (it.key() == "Class")
            emit deviceClassChanged(path, it.data().value.toUInt32(&ok));
        else if (it.key() == "Name")
            emit deviceNameChanged(path, it.data().value.toString(&ok));
        else if (it.key() == "Alias")
            emit deviceAliasChanged(path, it.data().value.toString(&ok));
//      https://www.bluetooth.com/specifications/gatt/viewer?attributeXmlFile=org.bluetooth.characteristic.gap.appearance.xml
        else if (it.key() == "Appearance")
            emit deviceAppearanceChanged(path, it.data().value.toUInt16(&ok));
        else if (it.key() == "Icon")
            emit deviceIconChanged(path, it.data().value.toString(&ok));
        else if (it.key() == "Paired")
            emit devicePairedChanged(path, it.data().value.toBool(&ok));
        else if (it.key() == "Trusted")
            emit deviceTrustedChanged(path, it.data().value.toBool(&ok));
        else if (it.key() == "Blocked")
            emit deviceBlockedChanged(path, it.data().value.toBool(&ok));
        else if (it.key() == "LegacyPairing")
            emit deviceLegacyPairingChanged(path, it.data().value.toBool(&ok));
        else if (it.key() == "RSSI")
            emit deviceRSSIChanged(path, it.data().value.toInt16(&ok)); //INT16
        else if (it.key() == "Connected")
            emit deviceConnectedChanged(path, it.data().value.toBool(&ok));
        else if (it.key() == "UUIDs")
        {
            TQT_DBusDataList vl = TQT_DBusDataList(it.data().value.toTQValueList(&ok));
            emit deviceUUIDsChanged(path, vl.toStringList(&ok));
        }
        else if (it.key() == "Adapter")
            emit deviceAdapterChanged(path, it.data().value.toObjectPath(&ok));
        else if (it.key() == "ManufacturerData")
            emit deviceManufacturerDataChanged(path, it.data().value.toUInt16KeyMap(&ok)); //a{qv}
        else if (it.key() == "ServiceData")
            emit deviceServiceDataChanged(path, it.data().value.toStringKeyMap(&ok)); //a{sv}
        else if (it.key() == "TxPower")
            emit deviceTxPowerChanged(path, it.data().value.toInt16(&ok)); //INT16
        else if (it.key() == "ServicesResolved")
            emit deviceServicesResolvedChanged(path, it.data().value.toBool(&ok));
        else
            continue;
        if (!ok)
            tqDebug(i18n("ObjectManagerImpl::devicePropertiesChanged conversion failed"));
    }
 
}
 
void ObjectManagerImpl::mediaControlPropertiesChanged(TQString path, const TQMap<TQString, TQT_DBusVariant>& changed_properties)
{
    TQMap<TQString, TQT_DBusVariant>::const_iterator it;
    for (it = changed_properties.begin(); it != changed_properties.end(); ++it)
    {
        bool ok = false;
        if (it.key() == "Connected")
            emit mediaControlConnectedChanged(path, it.data().value.toBool(&ok));
        else if (it.key() == "Player")
            emit mediaControlPlayerChanged(path, it.data().value.toObjectPath(&ok));
        else
            continue;
        if (!ok)
            tqDebug(i18n("ObjectManagerImpl::mediaControlPropertiesChanged conversion failed"));
    }
}
 
void ObjectManagerImpl::slotInterfacesAdded(const TQT_DBusObjectPath& object, const TQT_DBusDataMap<TQString>& interfaces)
{
    TQT_DBusDataMap<TQString>::const_iterator it1 = interfaces.begin();
    for (it1; it1 != interfaces.end(); it1++)
    {
        TQString interface = it1.key();
        if (interface == "org.bluez.AgentManager1")
        {
            agentManager = new AgentManager1Proxy("org.bluez", object/*, this, "AgentManager1"*/);
            if (agentManager)
                agentManager->setConnection(dBusConn);
        }
        else if (interface == "org.bluez.ProfileManager1")
        {
            profileManager = new ProfileManager1Proxy("org.bluez", object/*, this, "ProfileManager1"*/);
            if (profileManager)
                profileManager->setConnection(dBusConn);
        }
        else if (interface == "org.bluez.HealthManager1")
        {
            healthManager = new HealthManager1Proxy("org.bluez", object/*, this, "HealthManager1"*/);
            if (healthManager)
                healthManager->setConnection(dBusConn);
        }
        else if (interface == "org.bluez.Adapter1")
        {
            org::freedesktop::DBus::PropertiesProxy *properties;
            properties = new org::freedesktop::DBus::PropertiesProxy("org.bluez", object);
            properties->setConnection(dBusConn);
            connect(properties, TQ_SIGNAL(PropertiesChanged ( const TQString&, const TQMap< TQString, TQT_DBusVariant >&, const TQStringList& )), this, TQ_SLOT(slotPropertiesChanged ( const TQString& , const TQMap< TQString, TQT_DBusVariant >&, const TQStringList& )));
            adapters.insert(TQString(object), properties);
            //notify others
            emit adapterAdded(TQString(object));
        }
        else if (interface == "org.bluez.GattManager1")
        {
            kdDebug() << "Interface not implemented: org.bluez.GattManager1" << endl;
            // TODO: Implement GattManager1
        }
        else if (interface == "org.bluez.Media1")
        {
            kdDebug() << "Interface not implemented: org.bluez.Media1" << endl;
            // TODO: Implement Media1
        }
        else if (interface == "org.bluez.NetworkServer1")
        {
            kdDebug() << "Interface not implemented: org.bluez.NetworkServer1" << endl;
            // TODO: Implement NetworkServer1
        }
        else if (interface == "org.bluez.Device1")
        {
            org::freedesktop::DBus::PropertiesProxy *properties;
            properties = new org::freedesktop::DBus::PropertiesProxy("org.bluez", object);
            properties->setConnection(dBusConn);
            connect(properties, TQ_SIGNAL(PropertiesChanged ( const TQString&, const TQMap< TQString, TQT_DBusVariant >&, const TQStringList& )), this, TQ_SLOT(slotPropertiesChanged ( const TQString& , const TQMap< TQString, TQT_DBusVariant >&, const TQStringList& )));
            devices.insert(TQString(object), properties);
            //notify others
            emit deviceAdded(TQString(object));
        }
        else if (interface == "org.bluez.MediaControl1")
        {
            kdDebug() << "Interface not implemented: org.bluez.MediaControl1" << endl;
            kdDebug() << "as the media control is triggered via properties changed." << endl;
        }
        else if (interface == "org.bluez.MediaTransport1")
        {
            kdDebug() << "Interface not implemented: org.bluez.MediaTransport1" << endl;
            // TODO: Implement MediaTransport1
        }
        else if (interface == "org.freedesktop.DBus.Introspectable")
        {
            // do nothing
        }
        else if (interface == "org.freedesktop.DBus.Properties")
        {
            // do nothing
        }
        else
        {
            tqWarning(i18n("Interface not implemented: %1").arg(interface));
        }
    }
}
 
void ObjectManagerImpl::slotInterfacesRemoved(const TQT_DBusObjectPath& object, const TQStringList& interfaces)
{
    // TODO: remove interface
    for (TQValueListConstIterator<TQString> it = interfaces.begin();
            it != interfaces.end(); ++it)
    {
        if ((*it) == "org.bluez.AgentManager1")
        {
            kdDebug() << "Remove org.bluez.AgentManager1" << endl;
            // TODO: remove AgentManager1
        }
        else if ((*it) == "org.bluez.ProfileManager1")
        {
            kdDebug() << "Interface not implemented: org.bluez.ProfileManager1" << endl;
            // TODO: remove ProfileManager1
        }
        else if ((*it) == "org.bluez.HealthManager1")
        {
            kdDebug() << "Interface not implemented: org.bluez.HealthManager1" << endl;
            // TODO: remove HealthManager1
        }
        else if ((*it) == "org.bluez.Adapter1")
        {
            kdDebug() << "Remove org.bluez.Adapter1" << endl;
            disconnect(adapters[object], TQ_SIGNAL(PropertiesChanged ( const TQString&, const TQMap< TQString, TQT_DBusVariant >&, const TQStringList& )), this, TQ_SLOT(slotPropertiesChanged ( const TQString& , const TQMap< TQString, TQT_DBusVariant >&, const TQStringList& )));
            adapters.remove(object);
            emit adapterRemoved(TQString(object));
        }
        else if ((*it) == "org.bluez.GattManager1")
        {
            kdDebug() << "Interface not implemented: org.bluez.GattManager1" << endl;
            // TODO: Implement GattManager1
        }
        else if ((*it) == "org.bluez.Media1")
        {
            kdDebug() << "Interface not implemented: org.bluez.Media1" << endl;
            // TODO: Implement Media1
        }
        else if ((*it) == "org.bluez.NetworkServer1")
        {
            kdDebug() << "Interface not implemented: org.bluez.NetworkServer1" << endl;
            // TODO: Implement NetworkServer1
        }
        else if ((*it) == "org.bluez.Device1")
        {
            kdDebug() << "Remove org.bluez.Device1" << endl;
            if (devices.contains(object))
            {
                disconnect(devices[object], TQ_SIGNAL(PropertiesChanged ( const TQString&, const TQMap< TQString, TQT_DBusVariant >&, const TQStringList& )), this, TQ_SLOT(slotPropertiesChanged ( const TQString& , const TQMap< TQString, TQT_DBusVariant >&, const TQStringList& )));
                devices.remove(object);
                emit deviceRemoved(TQString(object));
            }
        }
        else if ((*it) == "org.bluez.MediaControl1")
        {
            kdDebug() << "Interface not implemented: org.bluez.MediaControl1" << endl;
            kdDebug() << "as the media control is triggered via properties changed." << endl;
            //          emit mediaControlRemoved(TQString ( object.data() ));
        }
        else if ((*it) == "org.freedesktop.DBus.Introspectable")
        {
            // do nothing
        }
        else if ((*it) == "org.freedesktop.DBus.Properties")
        {
            // do nothing
        }
        else
        {
            tqWarning(i18n("Interface not implemented: %1").arg((*it)));
        }
    }
}
 
void ObjectManagerImpl::slotPropertiesChanged(const TQString& interface, const TQMap<TQString, TQT_DBusVariant>& changed_properties, const TQStringList& invalidated_properties)
{
    // who send the signal ?
    const TQObject * o = TQObject::sender();
    org::freedesktop::DBus::PropertiesProxy *obj;
    obj = const_cast<org::freedesktop::DBus::PropertiesProxy*>(reinterpret_cast<const org::freedesktop::DBus::PropertiesProxy*>(o));
    if (!obj) {
        tqWarning("slotPropertiesChanged: sender is not a PropertiesProxy");
        return;
    }
    TQString path;
 
    if (interface == "org.bluez.Adapter1")
    {
        for (PropertiesMap::Iterator it = adapters.begin();
                it != adapters.end(); ++it)
        {
            if (obj == it.data())
                path = it.key();
        }
        if (!path.isEmpty())
            adapterPropertiesChanged(path, changed_properties);
    }
    else if (interface == "org.bluez.Device1")
    {
        for (PropertiesMap::Iterator it = devices.begin(); it != devices.end();
                ++it)
        {
            if (obj == it.data())
                path = it.key();
        }
        if (!path.isEmpty())
            devicePropertiesChanged(path, changed_properties);
    }
    else if (interface == "org.bluez.MediaControl1")
    {
        for (PropertiesMap::Iterator it = devices.begin(); it != devices.end();
                ++it)
        {
            if (obj == it.data())
                path = it.key();
        }
        if (!path.isEmpty())
            mediaControlPropertiesChanged(path, changed_properties);
    }
 
//          TQStringList::const_iterator it1;
//          for ( it1 = invalidated_properties.begin(); it1 != invalidated_properties.end(); ++it1 )
//          {
//              kdDebug() << "Invalidated Key: " << (*it1) << endl;
//          }
 
}
 
}; // namespace TDEBluetooth
 
#include "objectmanagerImpl.moc"
// End of File