yac_vote_storage.hpp

Go to the documentation of this file.

#ifndef IROHA_YAC_VOTE_STORAGE_HPP
#define IROHA_YAC_VOTE_STORAGE_HPP

#include <memory>
#include <unordered_map>
#include <vector>

#include <boost/optional.hpp>
#include "consensus/yac/outcome_messages.hpp"  // because messages passed by value
#include "consensus/yac/storage/storage_result.hpp"  // for Answer
#include "consensus/yac/storage/yac_common.hpp"      // for ProposalHash
#include "consensus/yac/storage/yac_proposal_storage.hpp"
#include "consensus/yac/yac_types.hpp"

namespace iroha {
  namespace consensus {
    namespace yac {

      enum class ProposalState {
        kNotSentNotProcessed,
        kSentNotProcessed,
        kSentProcessed
      };

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

        auto getProposalStorage(const Round &round);

        auto findProposalStorage(const VoteMessage &msg,
                                 PeersNumberType peers_in_round);

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

        boost::optional<Answer> store(std::vector<VoteMessage> state,
                                      PeersNumberType peers_in_round);

        bool isCommitted(const Round &round);

        ProposalState getProcessingState(const Round &round);

        void nextProcessingState(const Round &round);

       private:
        // --------| fields |--------

        std::vector<YacProposalStorage> proposal_storages_;

        std::unordered_map<Round, ProposalState, RoundTypeHasher>
            processing_state_;
      };

    }  // namespace yac
  }    // namespace consensus
}  // namespace iroha

#endif  // IROHA_YAC_VOTE_STORAGE_HPP