yac_proposal_storage.hpp

Go to the documentation of this file.

#ifndef IROHA_YAC_PROPOSAL_STORAGE_HPP
#define IROHA_YAC_PROPOSAL_STORAGE_HPP

#include <memory>
#include <vector>

#include <boost/optional.hpp>
#include "consensus/yac/storage/storage_result.hpp"
#include "consensus/yac/storage/yac_block_storage.hpp"
#include "consensus/yac/storage/yac_common.hpp"
#include "consensus/yac/supermajority_checker.hpp"
#include "consensus/yac/yac_types.hpp"
#include "logger/logger_fwd.hpp"
#include "logger/logger_manager_fwd.hpp"

namespace iroha::consensus::yac {
  struct VoteMessage;

  class YacProposalStorage {
   private:
    // --------| private api |--------

    auto findStore(const YacHash &store_hash);

   public:
    // --------| public api |--------

    YacProposalStorage(
        Round store_round,
        PeersNumberType peers_in_round,
        std::shared_ptr<SupermajorityChecker> supermajority_checker,
        logger::LoggerManagerTreePtr log_manager);

    boost::optional<Answer> insert(VoteMessage vote);

    boost::optional<Answer> insert(std::vector<VoteMessage> messages);

    const Round &getStorageKey() const;

    boost::optional<Answer> getState() const;

   private:
    // --------| private api |--------

    bool shouldInsert(const VoteMessage &msg);

    bool checkProposalRound(const Round &vote_round);

    bool checkPeerUniqueness(const VoteMessage &msg);

    boost::optional<Answer> findRejectProof();

    // --------| fields |--------

    boost::optional<Answer> current_state_;

    std::vector<YacBlockStorage> block_storages_;

    Round storage_key_;

    PeersNumberType peers_in_round_;

    std::shared_ptr<SupermajorityChecker> supermajority_checker_;

    logger::LoggerManagerTreePtr log_manager_;

    logger::LoggerPtr log_;
  };
}  // namespace iroha::consensus::yac

#endif  // IROHA_YAC_PROPOSAL_STORAGE_HPP