postgres_block_query.hpp

Go to the documentation of this file.

#ifndef IROHA_POSTGRES_BLOCK_QUERY_HPP
#define IROHA_POSTGRES_BLOCK_QUERY_HPP

#include "ametsuchi/block_query.hpp"

#include <soci/soci.h>
#include "ametsuchi/block_storage.hpp"
#include "logger/logger_fwd.hpp"

namespace iroha {
  namespace ametsuchi {

    class PostgresBlockQuery : public BlockQuery {
     public:
      PostgresBlockQuery(soci::session &sql,
                         BlockStorage &block_storage,
                         logger::LoggerPtr log);

      PostgresBlockQuery(std::unique_ptr<soci::session> sql,
                         BlockStorage &block_storage,
                         logger::LoggerPtr log);

      BlockResult getBlock(
          shared_model::interface::types::HeightType height) override;

      shared_model::interface::types::HeightType getTopBlockHeight() override;

      std::optional<TxCacheStatusType> checkTxPresence(
          const shared_model::crypto::Hash &hash) override;

     private:
      std::unique_ptr<soci::session> psql_;
      soci::session &sql_;
      BlockStorage &block_storage_;
      logger::LoggerPtr log_;
    };
  }  // namespace ametsuchi
}  // namespace iroha

#endif  // IROHA_POSTGRES_BLOCK_QUERY_HPP