chain_jrpc_processor.cpp

Go to the documentation of this file.

#include "api/service/chain/chain_jrpc_processor.hpp"

#include "api/jrpc/jrpc_method.hpp"
#include "api/jrpc/value_converter.hpp"
#include "api/service/chain/requests/get_block.hpp"
#include "api/service/chain/requests/get_block_hash.hpp"
#include "api/service/chain/requests/get_finalized_head.hpp"
#include "api/service/chain/requests/get_header.hpp"
#include "api/service/chain/requests/subscribe_finalized_heads.hpp"
#include "api/service/chain/requests/subscribe_new_heads.hpp"
#include "api/service/chain/requests/unsubscribe_finalized_heads.hpp"
#include "api/service/chain/requests/unsubscribe_new_heads.hpp"

namespace kagome::api::chain {

  ChainJrpcProcessor::ChainJrpcProcessor(std::shared_ptr<JRpcServer> server,
                                         std::shared_ptr<ChainApi> api)
      : api_{std::move(api)}, server_{std::move(server)} {
    BOOST_ASSERT(api_ != nullptr);
    BOOST_ASSERT(server_ != nullptr);
  }

  template <typename Request>
  using Handler = Method<Request, ChainApi>;

  void ChainJrpcProcessor::registerHandlers() {
    server_->registerHandler("chain_getBlockHash",
                             Handler<request::GetBlockhash>(api_));
    server_->registerHandler("chain_getHead",
                             Handler<request::GetBlockhash>(api_));

    server_->registerHandler("chain_getHeader",
                             Handler<request::GetHeader>(api_));

    server_->registerHandler("chain_getBlock",
                             Handler<request::GetBlock>(api_));

    server_->registerHandler("chain_getFinalizedHead",
                             Handler<request::GetFinalizedHead>(api_));
    server_->registerHandler("chain_getFinalisedHead",
                             Handler<request::GetFinalizedHead>(api_));

    server_->registerHandler("chain_subscribeFinalizedHeads",
                             Handler<request::SubscribeFinalizedHeads>(api_));

    server_->registerHandler("chain_unsubscribeFinalizedHeads",
                             Handler<request::UnsubscribeFinalizedHeads>(api_));

    server_->registerHandler("chain_subscribeNewHeads",
                             Handler<request::SubscribeNewHeads>(api_));

    server_->registerHandler("chain_unsubscribeNewHeads",
                             Handler<request::UnsubscribeNewHeads>(api_));

    server_->registerHandler("chain_subscribeNewHead",
                             Handler<request::SubscribeNewHeads>(api_));

    server_->registerHandler("chain_unsubscribeNewHead",
                             Handler<request::UnsubscribeNewHeads>(api_));
  }

}  // namespace kagome::api::chain