fakeRepositorySubscriber.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_COMPONENTFRAMEWORK_TEST_FAKEREPOSITORYSUBSCRIBER_HPP
#define RTCTK_COMPONENTFRAMEWORK_TEST_FAKEREPOSITORYSUBSCRIBER_HPP
 
#include <rtctk/componentFramework/repositorySubscriberIf.hpp>
#include <rtctk/componentFramework/test/fakeRepository.hpp>
 
namespace rtctk::componentFramework::test {

class FakeRepositorySubscriber : virtual public RepositorySubscriberIf,
                                 virtual protected FakeRepository {
public:
    FakeRepositorySubscriber();
    ~FakeRepositorySubscriber() override = default;
 
protected:
    template <typename T>
    void CreateImpl(detail::CreateRequest<T>& req);
 
    template <typename T>
    void ReadImpl(detail::ReadRequest<T>& req);
 
    template <typename T>
    void WriteImpl(detail::WriteRequest<T>& req);
 
    template <typename T>
    void PartialReadImpl(detail::PartialReadRequest<T>& req);
 
    template <typename T>
    void PartialWriteImpl(detail::PartialWriteRequest<T>& req);
 
    void ReadMetaDataImpl(detail::ReadMetaDataRequest& req);
    void WriteMetaDataImpl(detail::WriteMetaDataRequest& req);
    void DeleteImpl(detail::DeleteRequest& req);
    void ExistsImpl(detail::ExistsRequest& req);
    void GetChildrenImpl(detail::GetChildrenRequest& req);
    void CreateLinkImpl(detail::CreateSymlinkRequest& req);
    void UpdateLinkImpl(detail::UpdateSymlinkRequest& req);
    void SubscribeImpl(detail::ValueSubscribeRequest& req);
    void CreateDeleteSubscribeImpl(detail::CreateDeleteSubscribeRequest& req);
    void UnsubscribeImpl(detail::UnsubscribeRequest& req);
    Data& GetDataNode(const DataPointPath& path) override;
    void InvokeRequestHandler(std::any& request) override;
 
    void InvokeCreateCallbacks(const DataPointPath&);
    void InvokeDeleteCallbacks(const DataPointPath&);
    void InvokeWriteCallbacks(const DataPointPath&);
    bool ShouldInvokeErrorCallbacks();
    void InvokeErrorCallbacks();
 
    struct ValueSubscription {
        ValueSubscription(SubscriptionId,
                          const DataPointPath&,
                          NotifyCallbackType,
                          ErrorCallbackType);
        SubscriptionId id;
        DataPointPath path;
        NotifyCallbackType cb_value;
        ErrorCallbackType cb_error;
        std::atomic<size_t> cb_value_busy = 0;
        std::atomic<size_t> cb_error_busy = 0;
    };
 
    struct CreateDeleteSubscription {
        CreateDeleteSubscription(SubscriptionId, CallbackType, CallbackType, ErrorCallbackType);
        SubscriptionId id;
        CallbackType cb_created;
        CallbackType cb_deleted;
        ErrorCallbackType cb_error;
        std::atomic<size_t> cb_created_busy = 0;
        std::atomic<size_t> cb_deleted_busy = 0;
        std::atomic<size_t> cb_error_busy = 0;
    };
 
    std::list<ValueSubscription> m_value_subscriptions;
    std::list<CreateDeleteSubscription> m_create_delete_subscriptions;
 
    template <typename T>
    static RequestDispatcher<FakeRepositorySubscriber>::TableEntries BindTypeHandlers();
 
    static const RequestDispatcher<FakeRepositorySubscriber> S_REQUEST_DISPATCHER;

    Data m_invoke_error_callbacks;
};
 
}  // namespace rtctk::componentFramework::test
 
#endif  // RTCTK_COMPONENTFRAMEWORK_TEST_FAKEREPOSITORYSUBSCRIBER_HPP