File indexing completed on 2024-04-28 15:17:52

 /*
  * BluezQt - Asynchronous Bluez wrapper library
  *
  * SPDX-FileCopyrightText: 2021 Ivan Podkurkov <podkiva2@gmail.com>
  *
  * SPDX-License-Identifier: LGPL-2.1-only OR LGPL-3.0-only OR LicenseRef-KDE-Accepted-LGPL
  */
 
 #include "gattserviceremote_p.h"
 #include "gattserviceremote.h"
 #include "gattcharacteristicremote_p.h"
 #include "gattcharacteristicremote.h"
 #include "device_p.h"
 #include "device.h"
 #include "adapter.h"
 #include "input.h"
 #include "input_p.h"
 #include "mediaplayer.h"
 #include "mediaplayer_p.h"
 #include "utils.h"
 #include "macros.h"
 
 namespace BluezQt
 {
 
 GattServiceRemotePrivate::GattServiceRemotePrivate(const QString &path, const QVariantMap &properties, const DevicePtr &device)
     : QObject()
     , m_dbusProperties(nullptr)
     , m_primary(false)
     , m_device(device)
     , m_handle(0)
 {
     m_bluezGattService = new BluezGattService(Strings::orgBluez(), path, DBusConnection::orgBluez(), this);
 
     init(properties);
 }
 
 void GattServiceRemotePrivate::init(const QVariantMap &properties)
 {
     m_dbusProperties = new DBusProperties(Strings::orgBluez(), m_bluezGattService->path(),
                                           DBusConnection::orgBluez(), this);
 
     // Init properties    
     m_uuid = properties.value(QStringLiteral("UUID")).toString();
     m_primary = properties.value(QStringLiteral("Primary")).toBool();
     m_includes = properties.value(QStringLiteral("Includes")).value<QList<QDBusObjectPath>>();
     m_handle = static_cast<quint16>(properties.value(QStringLiteral("Handle")).toUInt());
 
 }
 
 void GattServiceRemotePrivate::interfacesAdded(const QString &path, const QVariantMapMap &interfaces)
 {
     bool changed = false;
     QVariantMapMap::const_iterator it;
 
     for (it = interfaces.constBegin(); it != interfaces.constEnd(); ++it) {
         if (it.key() == Strings::orgBluezGattCharacteristic1()) {
             addGattCharacteristic(path,it.value());
             changed = true;
         }
     }
 
     for (auto& ch: m_characteristics) {
         if (path.startsWith(ch->ubi())) {
             ch->d->interfacesAdded(path, interfaces);
             changed = true;
         }
     }
 
     if (changed) {
         Q_EMIT q.lock().data()->serviceChanged(q.toStrongRef());
     }
 }
 
 void GattServiceRemotePrivate::interfacesRemoved(const QString &path, const QStringList &interfaces)
 {
     Q_UNUSED(path)
     bool changed = false;
 
     for (auto& interface : interfaces) {
         if (interface == Strings::orgBluezGattCharacteristic1()) {
             removeGattCharacteristic(path);
             changed = true;
         }
     }
 
     for (auto& ch: m_characteristics) {
         if (path.startsWith(ch->ubi())) {
             ch->d->interfacesRemoved(path, interfaces);
             changed = true;
         }
     }
 
     if (changed) {
         Q_EMIT q.lock().data()->serviceChanged(q.toStrongRef());
     }
 }
 
 void GattServiceRemotePrivate::addGattCharacteristic(const QString &gattCharacteristicPath, const QVariantMap &properties)
 {
     // Check if we have the right path
     if (m_bluezGattService->path() != properties.value(QStringLiteral("Service")).value<QDBusObjectPath>().path()) {
         return;
     }
 
     GattServiceRemotePtr service = GattServiceRemotePtr(this->q);
 
     if (!service) {
         return;
     }
 
     GattCharacteristicRemotePtr gattCharacteristic = GattCharacteristicRemotePtr(new GattCharacteristicRemote(gattCharacteristicPath, properties, service));
     gattCharacteristic->d->q = gattCharacteristic.toWeakRef();
     m_characteristics.append(gattCharacteristic);
 
     Q_EMIT service->gattCharacteristicAdded(gattCharacteristic);
     Q_EMIT service->characteristicsChanged(m_characteristics);
 
     // Connections
     connect(gattCharacteristic.data(),&GattCharacteristicRemote::characteristicChanged,q.lock().data(),&GattServiceRemote::gattCharacteristicChanged);
 }
 
 void GattServiceRemotePrivate::removeGattCharacteristic(const QString &gattCharacteristicPath)
 {
     GattServiceRemotePtr service = GattServiceRemotePtr(this->q);
 
     if (!service) {
         return;
     }
 
     GattCharacteristicRemotePtr gattCharacteristic = nullptr;
     for (int i=0; i < service->characteristics().size(); ++i) {
         if (service->characteristics().at(i)->ubi() == gattCharacteristicPath) {
             gattCharacteristic = service->characteristics().at(i);
         }
     }
 
     if (gattCharacteristic == nullptr) {
         return;
     }
 
     m_characteristics.removeOne(gattCharacteristic);
 
     Q_EMIT service->gattCharacteristicRemoved(gattCharacteristic);
     Q_EMIT service->characteristicsChanged(m_characteristics);
 
     // Connections
     disconnect(gattCharacteristic.data(),&GattCharacteristicRemote::characteristicChanged,q.lock().data(),&GattServiceRemote::gattCharacteristicChanged);
 }
 
 QDBusPendingReply<> GattServiceRemotePrivate::setDBusProperty(const QString &name, const QVariant &value)
 {
     return m_dbusProperties->Set(Strings::orgBluezGattService1(), name, QDBusVariant(value));
 }
 
 void GattServiceRemotePrivate::propertiesChanged(const QString &path, const QString &interface, const QVariantMap &changed, const QStringList &invalidated)
 {
     if (interface == Strings::orgBluezGattCharacteristic1() || interface == Strings::orgBluezGattDescriptor1()) {
         for (GattCharacteristicRemotePtr characteristic : m_characteristics) {
             if (path.startsWith(characteristic->ubi())) {
                 characteristic->d->propertiesChanged(path, interface, changed, invalidated);
                 return;
             }
         }
     } else if (interface != Strings::orgBluezGattService1()) {
         return;
     }
 
     QVariantMap::const_iterator i;
     for (i = changed.constBegin(); i != changed.constEnd(); ++i) {
         const QVariant &value = i.value();
         const QString &property = i.key();
 
         if (property == QLatin1String("UUID")) {
             PROPERTY_CHANGED(m_uuid, toString, uuidChanged);
         } else if (property == QLatin1String("Primary")) {
             PROPERTY_CHANGED(m_primary, toBool, primaryChanged);
         } else if (property == QLatin1String("Includes")) {
             PROPERTY_CHANGED2(m_includes, value.value<QList<QDBusObjectPath>>(), includesChanged);
         } else if (property == QLatin1String("Handle")) {
             PROPERTY_CHANGED2(m_handle, value.value<quint16>(), handleChanged);
         }
     }
 
     for (auto& property : invalidated) {
         if (property == QLatin1String("UUID")) {
             PROPERTY_INVALIDATED(m_uuid, QString(), uuidChanged);
         } else if (property == QLatin1String("Primary")) {
             PROPERTY_INVALIDATED(m_primary, false, primaryChanged);
         } else if (property == QLatin1String("Includes")) {
             PROPERTY_INVALIDATED(m_includes, QList<QDBusObjectPath>(), includesChanged);
         } else if (property == QLatin1String("Handle")) {
             PROPERTY_INVALIDATED(m_handle, quint16(), handleChanged);
         }
     }
 
     q.lock().data()->serviceChanged(q.toStrongRef());
 }
 
 } // namespace BluezQt
 
 #include "moc_gattserviceremote_p.cpp"