yac_gate_impl.hpp

Go to the documentation of this file.

#ifndef IROHA_YAC_GATE_IMPL_HPP
#define IROHA_YAC_GATE_IMPL_HPP

#include "consensus/yac/yac_gate.hpp"

#include <memory>

#include <rxcpp/rx-lite.hpp>
#include "consensus/consensus_block_cache.hpp"
#include "consensus/yac/consensus_outcome_type.hpp"
#include "consensus/yac/impl/consensus_outcome_delay.hpp"
#include "consensus/yac/yac_hash_provider.hpp"
#include "logger/logger_fwd.hpp"

namespace iroha {

  namespace simulator {
    class BlockCreator;
  }

  namespace network {
    class BlockLoader;
  }

  namespace consensus {
    namespace yac {

      struct CommitMessage;
      class YacPeerOrderer;

      class YacGateImpl : public YacGate {
       public:
        YacGateImpl(
            std::shared_ptr<HashGate> hash_gate,
            std::shared_ptr<YacPeerOrderer> orderer,
            boost::optional<ClusterOrdering> alternative_order,
            std::shared_ptr<YacHashProvider> hash_provider,
            std::shared_ptr<simulator::BlockCreator> block_creator,
            std::shared_ptr<consensus::ConsensusResultCache>
                consensus_result_cache,
            logger::LoggerPtr log,
            std::function<std::chrono::milliseconds(ConsensusOutcomeType)>
                delay_func =
                    ConsensusOutcomeDelay(std::chrono::milliseconds(0)));
        void vote(const simulator::BlockCreatorEvent &event) override;

        rxcpp::observable<GateObject> onOutcome() override;

        void stop() override;

       private:
        void copySignatures(const CommitMessage &commit);

        rxcpp::observable<GateObject> handleCommit(const CommitMessage &msg);
        rxcpp::observable<GateObject> handleReject(const RejectMessage &msg);
        rxcpp::observable<GateObject> handleFuture(const FutureMessage &msg);

        logger::LoggerPtr log_;

        boost::optional<std::shared_ptr<shared_model::interface::Block>>
            current_block_;
        YacHash current_hash_;
        boost::optional<ClusterOrdering> alternative_order_;
        std::shared_ptr<const LedgerState> current_ledger_state_;

        rxcpp::observable<GateObject> published_events_;
        std::shared_ptr<YacPeerOrderer> orderer_;
        std::shared_ptr<YacHashProvider> hash_provider_;
        std::shared_ptr<simulator::BlockCreator> block_creator_;
        std::shared_ptr<consensus::ConsensusResultCache>
            consensus_result_cache_;
        std::shared_ptr<HashGate> hash_gate_;
      };

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

#endif  // IROHA_YAC_GATE_IMPL_HPP