registry.h

#pragma once
//
// Copyright (c) 2019-2020 Ivan Baidakou (basiliscos) (the dot dmol at gmail dot com)
//
// Distributed under the MIT Software License
//
 
#include "actor_base.h"
#include "messages.hpp"
#include <unordered_map>
#include <set>
#include <list>
 
#if defined(_MSC_VER)
#pragma warning(push)
#pragma warning(disable : 4251)
#endif
 
namespace rotor {

struct ROTOR_API registry_t : public actor_base_t {
    using actor_base_t::actor_base_t;
 
    void configure(plugin::plugin_base_t &plugin) noexcept override;

    virtual void on_reg(message::registration_request_t &request) noexcept;

    virtual void on_dereg_service(message::deregistration_service_t &message) noexcept;

    virtual void on_dereg(message::deregistration_notify_t &message) noexcept;

    virtual void on_discovery(message::discovery_request_t &request) noexcept;

    virtual void on_promise(message::discovery_promise_t &request) noexcept;

    virtual void on_cancel(message::discovery_cancel_t &notify) noexcept;

    template <typename T> auto &access() noexcept;
 
  protected:
    using promise_ptr_t = intrusive_ptr_t<message::discovery_promise_t>;

    using promises_list_t = std::list<promise_ptr_t>;

    using registered_map_t = std::unordered_map<std::string, address_ptr_t>;

    using registered_names_t = std::set<std::string>;

    using reverse_map_t = std::unordered_map<address_ptr_t, registered_names_t>;

    registered_map_t registered_map;

    reverse_map_t reverse_map;

    promises_list_t promises;
};
 
} // namespace rotor
 
#if defined(_MSC_VER)
#pragma warning(pop)
#endif