block_loader.hpp

Go to the documentation of this file.

#ifndef IROHA_BLOCK_LOADER_HPP
#define IROHA_BLOCK_LOADER_HPP

#include <memory>
#include <rxcpp/rx-observable-fwd.hpp>

#include "interfaces/common_objects/types.hpp"
#include "interfaces/iroha_internal/block.hpp"

namespace iroha {
  namespace network {
    class BlockLoader {
     public:
      virtual rxcpp::observable<std::shared_ptr<shared_model::interface::Block>>
      retrieveBlocks(const shared_model::interface::types::HeightType height,
                     shared_model::interface::types::PublicKeyHexStringView
                         peer_pubkey) = 0;

      virtual boost::optional<std::shared_ptr<shared_model::interface::Block>>
      retrieveBlock(
          shared_model::interface::types::PublicKeyHexStringView peer_pubkey,
          shared_model::interface::types::HeightType block_height) = 0;

      virtual ~BlockLoader() = default;
    };
  }  // namespace network
}  // namespace iroha

#endif  // IROHA_BLOCK_LOADER_HPP