listener.hpp

Go to the documentation of this file.

#ifndef KAGOME_CORE_API_TRANSPORT_LISTENER_HPP
#define KAGOME_CORE_API_TRANSPORT_LISTENER_HPP

#include <boost/asio/ip/tcp.hpp>
#include <memory>

#include "api/transport/rpc_io_context.hpp"
#include "api/transport/session.hpp"
#include "outcome/outcome.hpp"

namespace kagome::api {
  class Listener {
   protected:
    using Acceptor = boost::asio::ip::tcp::acceptor;
    using Endpoint = boost::asio::ip::tcp::endpoint;
    using NewSessionHandler =
        std::function<void(const std::shared_ptr<Session> &)>;

   public:
    using Context = RpcContext;

    struct Configuration {
      Endpoint endpoint{};

      uint32_t ws_max_connections{};

      Configuration() {
        endpoint.address(boost::asio::ip::address_v4::any());
        endpoint.port(0);
      }
    };

    virtual ~Listener() = default;

    virtual bool prepare() = 0;

    virtual bool start() = 0;

    virtual void stop() = 0;

    virtual void setHandlerForNewSession(
        NewSessionHandler &&on_new_session) = 0;

   protected:
    virtual void acceptOnce() = 0;
  };
}  // namespace kagome::api

#endif  // KAGOME_CORE_API_TRANSPORT_LISTENER_IMPL_HPP