duplex.h

Go to the documentation of this file.

// SPDX-FileCopyrightText: Copyright (C) 2020 swift Project Community / Contributors
// SPDX-License-Identifier: GPL-3.0-or-later OR LicenseRef-swift-pilot-client-1
 
 
#ifndef SWIFT_MISC_SHAREDSTATE_DBUS_DUPLEX_H
#define SWIFT_MISC_SHAREDSTATE_DBUS_DUPLEX_H
 
#include <QFuture>
#include <QMap>
#include <QObject>
 
#include "misc/genericdbusinterface.h"
#include "misc/promise.h"
#include "misc/swiftmiscexport.h"
#include "misc/variant.h"
 
#define SWIFT_MISC_DUPLEX_INTERFACE "org.swift_project.misc.sharedstate.duplex"
 
#define SWIFT_MISC_DUPLEX_PATH_ROOT "/org/swift_project/duplex"
 
namespace swift::misc
{
    class CVariantList;
 
    namespace shared_state::dbus
    {
        class SWIFT_MISC_EXPORT IDuplex : public QObject
        {
            Q_OBJECT
            Q_CLASSINFO("D-Bus Interface", SWIFT_MISC_DUPLEX_INTERFACE)
 
        public:
            QFuture<CVariant> submitRequest(const QString &channel, const swift::misc::CVariant &param);
 
            QFuture<CVariant> receiveRequest(const QString &channel, const swift::misc::CVariant &param);
 
        public slots:
            virtual void postEvent(const QString &channel, const swift::misc::CVariant &param) = 0;
 
            virtual void setSubscription(const QString &channel, const swift::misc::CVariantList &filters) = 0;
 
            virtual void requestPeerSubscriptions() = 0;
 
            virtual void submitRequest(const QString &channel, const swift::misc::CVariant &param, quint32 token) = 0;
 
            virtual void reply(const swift::misc::CVariant &param, quint32 token);
 
            virtual void advertise(const QString &channel) = 0;
 
            virtual void withdraw(const QString &channel) = 0;
 
        signals:
            void eventPosted(const QString &channel, const swift::misc::CVariant &param);
 
            void peerSubscriptionsReceived(const QString &channel, const swift::misc::CVariantList &filters);
 
            void requestReceived(const QString &channel, const swift::misc::CVariant &param, quint32 token,
                                 QPrivateSignal);
 
            void replyReceived(const QString &channel, const swift::misc::CVariant &param, quint32 token);
 
        protected:
            IDuplex(QObject *parent = nullptr);
 
        private:
            quint32 getToken();
 
            quint32 m_token = 0;
            QMap<quint32, CPromise<CVariant>> m_submittedRequests;
            QMap<quint32, CPromise<CVariant>> m_receivedRequests;
        };
    } // namespace shared_state::dbus
} // namespace swift::misc
 
#endif // SWIFT_MISC_SHAREDSTATE_DBUS_DUPLEX_H