listobserver.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_LISTOBSERVER_H
#define SWIFT_MISC_SHAREDSTATE_LISTOBSERVER_H
 
#include <QMutex>
#include <QObject>
 
#include "misc/sharedstate/activeobserver.h"
#include "misc/sharedstate/datalink.h"
#include "misc/swiftmiscexport.h"
#include "misc/variantlist.h"
 
namespace swift::misc::shared_state
{
    class SWIFT_MISC_EXPORT CGenericListObserver : public QObject
    {
        Q_OBJECT
 
    protected:
        CGenericListObserver(QObject *parent) : QObject(parent) {}

        virtual void initialize(IDataLink *);

        void setFilter(const CVariant &filter);

        CVariantList allValues() const;

        int cleanValues();
 
    private:
        void reconstruct();
        void handleEvent(const CVariant &param);
        virtual void onGenericElementAdded(const CVariant &value) = 0;
        virtual void onGenericElementsReplaced(const CVariantList &values) = 0;
 
        QSharedPointer<CActiveObserver> m_observer = CActiveObserver::create(this, &CGenericListObserver::handleEvent);
        CDataLinkConnectionWatcher *m_watcher = nullptr;
        mutable QMutex m_listMutex;
        CVariantList m_list;
    };

    template <typename T, typename U = CAnyMatch>
    class CListObserver : public CGenericListObserver
    {
    protected:
        CListObserver(QObject *parent) : CGenericListObserver(parent) {}
 
    public:
        void initialize(IDataLink *dataLink) override
        {
            CGenericListObserver::initialize(dataLink);
            if (std::is_same_v<U, CAnyMatch>)
            {
                setFilter({});
            }
        }

        void setFilter(const U &filter) { CGenericListObserver::setFilter(CVariant::fromValue(filter)); }

        T allValues() const { return CVariant::fromValue(CGenericListObserver::allValues()).template value<T>(); }

        virtual void onElementAdded(const typename T::value_type &value) = 0;

        virtual void onElementsReplaced(const T &values) = 0;
 
    private:
        void onGenericElementAdded(const CVariant &value) final
        {
            onElementAdded(value.value<typename T::value_type>());
        }
 
        void onGenericElementsReplaced(const CVariantList &values) final { onElementsReplaced(values.to<T>()); }
    };
} // namespace swift::misc::shared_state
 
#endif // SWIFT_MISC_SHAREDSTATE_LISTOBSERVER_H