observer.h

Go to the documentation of this file.

 
#pragma once
#include <knp/core/impexp.h>
#include <knp/core/message_endpoint.h>
#include <knp/core/messaging/messaging.h>
 
#include <filesystem>
#include <fstream>
#include <functional>
#include <string>
#include <unordered_map>
#include <utility>
#include <vector>
 
#include <boost/mp11.hpp>
 
 
namespace knp::framework::monitoring
{
template <class Message>
using MessageProcessor = std::function<void(const std::vector<Message>)>;
 
 
template <class Message>
class MessageObserver
{
public:
    MessageObserver(
        core::MessageEndpoint &&endpoint, MessageProcessor<Message> &&processor, core::UID uid = core::UID{true})
        : endpoint_(std::move(endpoint)), process_messages_(processor), base_data_{uid}
    {
    }
 
    MessageObserver(MessageObserver<Message> &&other) noexcept = default;
 
    void subscribe(const std::vector<core::UID> &entities) { endpoint_.subscribe<Message>(base_data_.uid_, entities); }
 
    void update()
    {
        endpoint_.receive_all_messages();
        auto messages_raw = endpoint_.unload_messages<Message>(base_data_.uid_);
        process_messages_(messages_raw);
    }
 
    [[nodiscard]] knp::core::UID get_uid() const { return base_data_.uid_; }
 
private:
    core::MessageEndpoint endpoint_;
    MessageProcessor<Message> process_messages_;
    core::BaseData base_data_;
};
 
using AllObservers = boost::mp11::mp_transform<MessageObserver, core::messaging::AllMessages>;
 
using AnyObserverVariant = boost::mp11::mp_rename<AllObservers, std::variant>;
 
}  // namespace knp::framework::monitoring