datalinkdbus.h

Go to the documentation of this file.

// SPDX-FileCopyrightText: Copyright (C) 2017 swift Project Community / Contributors
// SPDX-License-Identifier: GPL-3.0-or-later OR LicenseRef-swift-pilot-client-1

 
#ifndef SWIFT_MISC_SHAREDSTATE_DATALINKDBUS_H
#define SWIFT_MISC_SHAREDSTATE_DATALINKDBUS_H
 
#include <QSharedPointer>
#include <QTimer>
 
#include "misc/identifier.h"
#include "misc/sharedstate/datalink.h"
#include "misc/swiftmiscexport.h"
#include "misc/variantlist.h"
 
class QDBusConnection;
 
namespace swift::misc
{
    class CDBusServer;
 
    namespace shared_state
    {
        namespace dbus
        {
            class IHub;
            class IDuplex;
        } // namespace dbus

        class SWIFT_MISC_EXPORT CDataLinkDBus : public QObject, public IDataLink
        {
            Q_OBJECT
            Q_INTERFACES(swift::misc::shared_state::IDataLink)
 
        public:
            CDataLinkDBus(QObject *parent = nullptr);

            ~CDataLinkDBus() override;

            void overrideIdentifier(const CIdentifier &);

            void initializeLocal(CDBusServer *server = nullptr);

            void initializeRemote(const QDBusConnection &connection, const QString &service);
 
            void publish(const CPassiveMutator *mutator) override;
            void publish(const CActiveMutator *mutator) override;
            void subscribe(const CPassiveObserver *observer) override;
            void subscribe(const CActiveObserver *observer) override;
 
        private:
            struct Channel
            {
                QWeakPointer<const CActiveMutator> activeMutator;
                QVector<QWeakPointer<const CPassiveObserver>> passiveObservers;
                CVariantList peerSubscriptions;
            };
            QStringList getChannelNames() const;
            Channel &getChannel(const QString &name);
            Channel &getChannel(const QObject *object);
 
            void checkConnection();
            void onConnected();
            void onDisconnected();
 
            void handleLocalEvent(const QString &channel, const CVariant &param);
            void handlePeerEvent(const QString &channel, const CVariant &param);
            void announceLocalSubscriptions();
            void announceLocalSubscriptions(const QString &channel);
            void setPeerSubscriptions(const QString &channel, const CVariantList &filters);
            QFuture<CVariant> handleLocalRequest(const QString &channel, const CVariant &param);
            void handlePeerRequest(const QString &channel, const CVariant &param, quint32 token);
 
            QTimer m_watchTimer;
            dbus::IHub *m_hub = nullptr;
            QSharedPointer<dbus::IDuplex> m_duplex;
            CIdentifier m_identifier = CIdentifier::anonymous();
 
            QMap<QString, Channel> m_channels;
            mutable QRecursiveMutex m_channelsMutex;
        };
    } // namespace shared_state
} // namespace swift::misc
 
#endif // SWIFT_MISC_SHAREDSTATE_DATALINKDBUS_H