rocksdb_block_storage.hpp

Go to the documentation of this file.

#ifndef IROHA_ROCKSDB_BLOCK_STORAGE_HPP
#define IROHA_ROCKSDB_BLOCK_STORAGE_HPP

#include "ametsuchi/block_storage.hpp"

#include "interfaces/iroha_internal/block_json_converter.hpp"
#include "logger/logger_fwd.hpp"

namespace iroha::ametsuchi {
  struct RocksDBContext;

  class RocksDbBlockStorage : public BlockStorage {
   public:
    RocksDbBlockStorage(
        std::shared_ptr<RocksDBContext> db_context,
        std::shared_ptr<shared_model::interface::BlockJsonConverter>
            json_converter,
        logger::LoggerPtr log);

    bool insert(
        std::shared_ptr<const shared_model::interface::Block> block) override;

    boost::optional<std::unique_ptr<shared_model::interface::Block>> fetch(
        shared_model::interface::types::HeightType height) const override;

    size_t size() const override;

    void reload() override;

    void clear() override;

    expected::Result<void, std::string> forEach(
        FunctionType function) const override;

   private:
    std::shared_ptr<RocksDBContext> db_context_;
    std::shared_ptr<shared_model::interface::BlockJsonConverter>
        json_converter_;
    logger::LoggerPtr log_;
  };

}  // namespace iroha::ametsuchi

#endif  // IROHA_ROCKSDB_BLOCK_STORAGE_HPP