event_handler.hpp

Go to the documentation of this file.

#pragma once
 
#include <async/async_queue.hpp>
#include <core/events.hpp>
#include <memory>
#include <variant>
 
namespace radix_relay::core {
 
template<typename CommandHandler, typename CommandParser> struct event_handler
{
  using in_queue_t = async::async_queue<events::raw_command>;
 
  struct out_queues_t
  {
    std::shared_ptr<async::async_queue<events::display_filter_input_t>> display;
    std::shared_ptr<async::async_queue<events::transport::in_t>> transport;
    std::shared_ptr<async::async_queue<events::session_orchestrator::in_t>> session;
    std::shared_ptr<async::async_queue<events::connection_monitor::in_t>> connection_monitor;
  };
 
  explicit event_handler(std::shared_ptr<CommandHandler> command_handler,
    std::shared_ptr<CommandParser> parser,
    const out_queues_t & /*queues*/)
    : command_handler_(std::move(command_handler)), parser_(std::move(parser))
  {}
 
  auto handle(const events::raw_command &event) const -> void
  {
    auto command = parser_->parse(event.input);
    std::visit(*command_handler_, command);
  }
 
private:
  std::shared_ptr<CommandHandler> command_handler_;
  std::shared_ptr<CommandParser> parser_;
};
 
}// namespace radix_relay::core