block_loader_service.hpp

Go to the documentation of this file.

#ifndef IROHA_BLOCK_LOADER_SERVICE_HPP
#define IROHA_BLOCK_LOADER_SERVICE_HPP

#include "ametsuchi/block_query_factory.hpp"
#include "consensus/consensus_block_cache.hpp"
#include "loader.grpc.pb.h"
#include "logger/logger_fwd.hpp"

namespace iroha {
  namespace network {
    class BlockLoaderService : public proto::Loader::Service {
     public:
      BlockLoaderService(
          std::shared_ptr<ametsuchi::BlockQueryFactory> block_query_factory,
          std::shared_ptr<iroha::consensus::ConsensusResultCache>
              consensus_result_cache,
          logger::LoggerPtr log);

      grpc::Status retrieveBlocks(
          ::grpc::ServerContext *context,
          const proto::BlockRequest *request,
          ::grpc::ServerWriter<protocol::Block> *writer) override;

      grpc::Status retrieveBlock(::grpc::ServerContext *context,
                                 const proto::BlockRequest *request,
                                 protocol::Block *response) override;

     private:
      std::shared_ptr<ametsuchi::BlockQueryFactory> block_query_factory_;
      std::shared_ptr<iroha::consensus::ConsensusResultCache>
          consensus_result_cache_;
      logger::LoggerPtr log_;
    };
  }  // namespace network
}  // namespace iroha

#endif  // IROHA_BLOCK_LOADER_SERVICE_HPP