jrpc_server_impl.hpp

Go to the documentation of this file.

#ifndef KAGOME_API_JRPC_SERVER_IMPL_HPP
#define KAGOME_API_JRPC_SERVER_IMPL_HPP

#include <jsonrpc-lean/server.h>

#include "api/jrpc/jrpc_server.hpp"
#include "metrics/metrics.hpp"

namespace kagome::api {

  class JRpcServerImpl : public JRpcServer {
   public:
    enum class Error {
      JSON_FORMAT_FAILED = 1,
    };

    JRpcServerImpl();

    ~JRpcServerImpl() override = default;

    void registerHandler(const std::string &name, Method method) override;

    std::vector<std::string> getHandlerNames() override;

    void processData(std::string_view request,
                     const ResponseHandler &cb) override;

    void processJsonData(std::string method_name,
                         const jsonrpc::Request::Parameters &from,
                         const FormatterHandler &cb) override;

   private:
    jsonrpc::Server jsonrpc_handler_{};
    jsonrpc::JsonFormatHandler format_handler_{};

    // Metrics
    metrics::RegistryPtr metrics_registry_ = metrics::createRegistry();
    metrics::Counter *metric_rpc_requests_count_;
  };

}  // namespace kagome::api

OUTCOME_HPP_DECLARE_ERROR(kagome::api, JRpcServerImpl::Error);

#endif  // KAGOME_API_JRPC_SERVER_IMPL_HPP