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:
        virtual void initialize(IDataLink *dataLink) override
        {
            CGenericListObserver::initialize(dataLink);
            if (std::is_same_v<U, CAnyMatch>) { setFilter({}); }
        }
 
        void setFilter(const U &filter) { CGenericListObserver::setFilter(CVariant::from(filter)); }
 
        T allValues() const { return CVariant::from(CGenericListObserver::allValues()).template to<T>(); }
 
        virtual void onElementAdded(const typename T::value_type &value) = 0;
 
        virtual void onElementsReplaced(const T &values) = 0;
 
    private:
        virtual void onGenericElementAdded(const CVariant &value) override final
        {
            onElementAdded(value.to<typename T::value_type>());
        }
        virtual void onGenericElementsReplaced(const CVariantList &values) override final
        {
            onElementsReplaced(values.to<T>());
        }
    };
} // namespace swift::misc::shared_state
 
#endif // SWIFT_MISC_SHAREDSTATE_LISTOBSERVER_H