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 {
  namespace consensus {
    namespace 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 yac
  }    // namespace consensus
}  // namespace iroha
#endif  // IROHA_YAC_PROPOSAL_STORAGE_HPP