repositorySubscriberIf.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_COMPONENTFRAMEWORK_REPOSITORYSUBSCRIBERIF_HPP
#define RTCTK_COMPONENTFRAMEWORK_REPOSITORYSUBSCRIBERIF_HPP
 
#include <rtctk/componentFramework/repositoryIf.hpp>
 
namespace rtctk::componentFramework {
 
class RepositorySubscriberIf {
public:
    class SubscribeRequest {
    public:
        struct Parameters {
            Parameters() = default;
 
            explicit Parameters(
                const DataPointPath& path,
                void* buffer,
                const std::type_info& type,
                const std::function<void(const DataPointPath& path)>& removed_callback,
                const std::function<void(const DataPointPath& path)>& newvalue_callback)
                : m_path(path)
                , m_buffer(buffer)
                , m_type(type)
                , m_removed_callback(removed_callback)
                , m_newvalue_callback(newvalue_callback) {
            }
 
            DataPointPath m_path;
 
            void* m_buffer;
 
            const std::type_info& m_type;
 
            std::function<void(const DataPointPath& path)> m_removed_callback;
            std::function<void(const DataPointPath& path)> m_newvalue_callback;
        };
 
        template <typename F>
        void AddRemovedHandler(const DataPointPath& path, F handler);
 
        template <typename T, typename F>
        void AddNewValueHandler(const DataPointPath& path, T& buffer, F handler);
 
        inline const std::vector<Parameters>& GetParams() const {
            return m_params;
        };
 
    private:
        std::vector<Parameters> m_params;
    };
 
    class UnsubscribeRequest {
    public:
        struct Parameters {
            Parameters() = default;
 
            Parameters(const DataPointPath& path,
                       const bool unsubscribe_removed,
                       const bool unsubscribe_newvalue)
                : m_path(path)
                , m_unsubscribe_removed(unsubscribe_removed)
                , m_unsubscribe_newvalue(unsubscribe_newvalue) {
            }
 
            DataPointPath m_path;
 
            bool m_unsubscribe_removed;
 
            bool m_unsubscribe_newvalue;
        };
 
        void AddRemovedHandler(const DataPointPath& path);
 
        void AddNewValueHandler(const DataPointPath& path);
 
        inline const std::vector<Parameters>& GetParams() const {
            return m_params;
        };
 
    private:
        std::vector<Parameters> m_params;
    };
 
    virtual ~RepositorySubscriberIf();
 
    virtual RepositoryIf::Response SendSubscribeRequest(const SubscribeRequest& request) const = 0;
 
    virtual RepositoryIf::Response
    SendUnsubscribeRequest(const UnsubscribeRequest& request) const = 0;
 
    template <typename T, typename F>
    void Subscribe(const DataPointPath& path, T& buffer, F handler) const;
 
    void Unsubscribe(const DataPointPath& path) const;
};
 
template <typename F>
void RepositorySubscriberIf::SubscribeRequest::AddRemovedHandler(const DataPointPath& path,
                                                                 F handler) {
    m_params.push_back(Parameters(path, nullptr, typeid(void), handler, nullptr));
}
 
template <typename T, typename F>
void RepositorySubscriberIf::SubscribeRequest::AddNewValueHandler(const DataPointPath& path,
                                                                  T& buffer,
                                                                  F handler) {
    // We use a lambda here to have type erasure and allow storing callbacks for different types in
    // the m_newvalue_callback.
    auto callback = [handler, &buffer](const DataPointPath& path) -> void {
        handler(path, buffer);
    };
    m_params.push_back(Parameters(path, &buffer, typeid(buffer), nullptr, callback));
}
 
template <typename T, typename F>
void RepositorySubscriberIf::Subscribe(const DataPointPath& path, T& buffer, F handler) const {
    SubscribeRequest subscribe;
    subscribe.AddNewValueHandler(path, buffer, handler);
    SendSubscribeRequest(subscribe).Wait();
}
 
}  // namespace rtctk::componentFramework
 
#endif  // RTCTK_COMPONENTFRAMEWORK_REPOSITORYSUBSCRIBERIF_HPP