topology.hpp

Go to the documentation of this file.

 
#ifndef EAGINE_MESSAGE_BUS_SERVICE_TOPOLOGY_HPP
#define EAGINE_MESSAGE_BUS_SERVICE_TOPOLOGY_HPP
 
#include "../serialize.hpp"
#include "../subscriber.hpp"
 
namespace eagine::msgbus {
//------------------------------------------------------------------------------
template <typename Base = subscriber>
class network_topology : public Base {
    using This = network_topology;
 
protected:
    using Base::Base;
 
    void add_methods() {
        Base::add_methods();
        Base::add_method(
          this, EAGINE_MSG_MAP(eagiMsgBus, topoRutrCn, This, _handle_router));
        Base::add_method(
          this, EAGINE_MSG_MAP(eagiMsgBus, topoBrdgCn, This, _handle_bridge));
        Base::add_method(
          this, EAGINE_MSG_MAP(eagiMsgBus, topoEndpt, This, _handle_endpoint));
    }
 
public:
    void discover_topology() {
        message_view message{};
        message.set_target_id(broadcast_endpoint_id());
        const auto msg_id{EAGINE_MSGBUS_ID(topoQuery)};
        this->bus().post(msg_id, message);
    }
 
    virtual void router_appeared(const router_topology_info& info) = 0;
    virtual void bridge_appeared(const bridge_topology_info& info) = 0;
    virtual void endpoint_appeared(const endpoint_topology_info& info) = 0;
 
private:
    auto _handle_router(const message_context&, stored_message& message)
      -> bool {
        router_topology_info info{};
        if(default_deserialize(info, message.content())) {
            router_appeared(info);
        }
        return true;
    }
 
    auto _handle_bridge(const message_context&, stored_message& message)
      -> bool {
        bridge_topology_info info{};
        if(default_deserialize(info, message.content())) {
            bridge_appeared(info);
        }
        return true;
    }
 
    auto _handle_endpoint(const message_context&, stored_message& message)
      -> bool {
        endpoint_topology_info info{};
        if(default_deserialize(info, message.content())) {
            endpoint_appeared(info);
        }
        return true;
    }
};
//------------------------------------------------------------------------------
} // namespace eagine::msgbus
 
#endif // EAGINE_MESSAGE_BUS_SERVICE_TOPOLOGY_HPP