ability.hpp

Go to the documentation of this file.

 
#ifndef EAGINE_MESSAGE_BUS_SERVICE_ABILITY_HPP
#define EAGINE_MESSAGE_BUS_SERVICE_ABILITY_HPP
 
#include "../serialize.hpp"
#include "../subscriber.hpp"
 
namespace eagine::msgbus {
//------------------------------------------------------------------------------
template <typename Base = subscriber>
class ability_provider : public Base {
    using This = ability_provider;
 
protected:
    using Base::Base;
 
    void add_methods() {
        Base::add_methods();
        Base::add_method(
          this, EAGINE_MSG_MAP(Ability, query, This, _handle_query));
    }
 
public:
    virtual auto can_handle(message_id) -> bool = 0;
 
private:
    auto _handle_query(const message_context& msg_ctx, stored_message& message)
      -> bool {
        message_id msg_id{};
        if(default_deserialize_message_type(msg_id, message.content())) {
            if(can_handle()) {
                msg_ctx.bus().respond_to(
                  message,
                  EAGINE_MSG_ID(Ability, response),
                  {message.content()});
            }
        }
        return true;
    }
};
//------------------------------------------------------------------------------
template <typename Base = subscriber>
class ability_tester : public Base {
 
    using This = ability_tester;
 
protected:
    using Base::Base;
 
    void add_methods() {
        Base::add_methods();
        Base::add_method(
          this, EAGINE_MSG_MAP(Ability, response, This, _handle_response));
    }
 
public:
    void find_handler(message_id msg_id) {
        std::array<byte, 32> temp{};
        auto serialized{default_serialize(msg_id, cover(temp))};
        EAGINE_ASSERT(serialized);
 
        message_view message{extract(serialized)};
        this->bus().broadcast(EAGINE_MSG_ID(Ability, query), message);
    }
 
    virtual void on_handler_found(identifier_t target_id, message_id) = 0;
 
private:
    auto _handle_response(const message_context&, stored_message& message)
      -> bool {
        message_id msg_id{};
        if(default_deserialize_message_type(msg_id, message.content())) {
            on_handler_found(message.source_id, msg_id);
        }
        return true;
    }
};
//------------------------------------------------------------------------------
} // namespace eagine::msgbus
 
#endif // EAGINE_MESSAGE_BUS_SERVICE_ABILITY_HPP