service.hpp

Go to the documentation of this file.

 
#ifndef EAGINE_MESSAGE_BUS_SERVICE_HPP
#define EAGINE_MESSAGE_BUS_SERVICE_HPP
 
#include "../bool_aggregate.hpp"
#include "invoker.hpp"
#include "serialize.hpp"
#include "service_interface.hpp"
#include "skeleton.hpp"
#include "subscriber.hpp"
 
namespace eagine::msgbus {
//------------------------------------------------------------------------------
template <typename Base = subscriber>
class service_composition
  : public Base
  , public connection_user
  , public service_interface {
 
    using This = service_composition;
 
public:
    service_composition(endpoint& bus)
      : Base{bus} {
        _init();
    }
 
    // NOLINTNEXTLINE(hicpp-noexcept-move,performance-noexcept-move-constructor)
    service_composition(service_composition&& that)
      : Base{static_cast<Base&&>(that)} {
        _init();
    }
 
    service_composition(const service_composition&) = delete;
 
    auto operator=(service_composition&&) = delete;
 
    auto operator=(const service_composition&) = delete;
 
    ~service_composition() noexcept override {
        this->retract_subscriptions();
        this->finish();
    }
 
    auto add_connection(std::unique_ptr<connection> conn) -> bool final {
        return this->bus().add_connection(std::move(conn));
    }
 
    auto update_and_process_all() -> bool final {
        some_true something_done{};
        something_done(this->update());
        something_done(this->process_all());
        return something_done;
    }
 
protected:
    void add_methods() {
        Base::add_methods();
        Base::add_method(
          this,
          EAGINE_MSG_MAP(eagiMsgBus, qrySubscrp, This, _handle_sup_query));
        Base::add_method(
          this,
          EAGINE_MSG_MAP(eagiMsgBus, qrySubscrb, This, _handle_sub_query));
    }
 
private:
    auto _handle_sup_query(const message_context&, stored_message& message)
      -> bool {
        this->respond_to_subscription_query(message.source_id);
        return true;
    }
 
    auto _handle_sub_query(const message_context&, stored_message& message)
      -> bool {
        message_id sub_msg_id{};
        if(default_deserialize_message_type(sub_msg_id, message.content())) {
            this->respond_to_subscription_query(message.source_id, sub_msg_id);
        }
        return true;
    }
 
    void _init() {
        this->add_methods();
        this->init();
        this->announce_subscriptions();
    }
};
//------------------------------------------------------------------------------
template <typename Signature, std::size_t MaxDataSize = 8192 - 128>
using default_callback_invoker = callback_invoker<
  Signature,
  default_serializer_backend,
  default_deserializer_backend,
  block_data_sink,
  block_data_source,
  MaxDataSize>;
//------------------------------------------------------------------------------
template <typename Signature, std::size_t MaxDataSize = 8192 - 128>
using default_invoker = invoker<
  Signature,
  default_serializer_backend,
  default_deserializer_backend,
  block_data_sink,
  block_data_source,
  MaxDataSize>;
//------------------------------------------------------------------------------
template <typename Signature, std::size_t MaxDataSize = 8192 - 128>
using default_skeleton = skeleton<
  Signature,
  default_serializer_backend,
  default_deserializer_backend,
  block_data_sink,
  block_data_source,
  MaxDataSize>;
//------------------------------------------------------------------------------
template <typename Signature, std::size_t MaxDataSize = 8192 - 128>
using default_function_skeleton = function_skeleton<
  Signature,
  default_serializer_backend,
  default_deserializer_backend,
  block_data_sink,
  block_data_source,
  MaxDataSize>;
//------------------------------------------------------------------------------
template <typename Signature, std::size_t MaxDataSize = 8192 - 128>
using default_lazy_skeleton = lazy_skeleton<
  Signature,
  default_serializer_backend,
  default_deserializer_backend,
  block_data_sink,
  block_data_source,
  MaxDataSize>;
//------------------------------------------------------------------------------
template <typename Signature, std::size_t MaxDataSize = 8192 - 128>
using default_async_skeleton = async_skeleton<
  Signature,
  default_serializer_backend,
  default_deserializer_backend,
  block_data_sink,
  block_data_source,
  MaxDataSize>;
//------------------------------------------------------------------------------
} // namespace eagine::msgbus
 
#endif // EAGINE_MESSAGE_BUS_SERVICE_HPP