registry.hpp

Go to the documentation of this file.

 
#ifndef EAGINE_MESSAGE_BUS_REGISTRY_HPP
#define EAGINE_MESSAGE_BUS_REGISTRY_HPP
 
#include "../main_ctx_object.hpp"
#include "direct.hpp"
#include "endpoint.hpp"
#include "router.hpp"
#include "service_interface.hpp"
#include <memory>
 
namespace eagine::msgbus {
//------------------------------------------------------------------------------
struct registered_entry {
    std::unique_ptr<endpoint> _endpoint{};
    std::unique_ptr<service_interface> _service{};
 
    auto update_service() -> bool;
};
//------------------------------------------------------------------------------
class registry : public main_ctx_object {
public:
    registry(main_ctx_parent parent);
 
    [[nodiscard]] auto establish(identifier log_id) -> endpoint& {
        return *(_add_entry(log_id)._endpoint);
    }
 
    template <typename Service>
    auto emplace(identifier log_id) -> std::
      enable_if_t<std::is_base_of_v<service_interface, Service>, Service&> {
        auto& entry = _add_entry(log_id);
        auto temp{std::make_unique<Service>(*(entry._endpoint))};
        auto& result = *temp;
        entry._service = std::move(temp);
        return result;
    }
 
    auto update() -> bool;
    auto update_all() -> bool;
    void cleanup() {
        _router.cleanup();
    }
 
private:
    std::shared_ptr<direct_acceptor> _acceptor;
    router _router;
    std::vector<registered_entry> _entries;
 
    auto _add_entry(identifier log_id) -> registered_entry&;
};
//------------------------------------------------------------------------------
} // namespace eagine::msgbus
 
#if !EAGINE_LINK_LIBRARY || defined(EAGINE_IMPLEMENTING_LIBRARY)
#include <eagine/message_bus/registry.inl>
#endif
 
#endif // EAGINE_MESSAGE_BUS_REGISTRY_HPP