consensus_init.hpp

Go to the documentation of this file.

#ifndef IROHA_CONSENSUS_INIT_HPP
#define IROHA_CONSENSUS_INIT_HPP

#include <memory>

#include "ametsuchi/peer_query_factory.hpp"
#include "consensus/consensus_block_cache.hpp"
#include "consensus/yac/consensus_outcome_type.hpp"
#include "consensus/yac/consistency_model.hpp"
#include "consensus/yac/outcome_messages.hpp"
#include "consensus/yac/timer.hpp"
#include "consensus/yac/transport/impl/network_impl.hpp"
#include "consensus/yac/yac_gate.hpp"
#include "consensus/yac/yac_hash_provider.hpp"
#include "consensus/yac/yac_peer_orderer.hpp"
#include "cryptography/keypair.hpp"
#include "logger/logger_manager_fwd.hpp"
#include "network/block_loader.hpp"
#include "network/impl/async_grpc_client.hpp"
#include "simulator/block_creator.hpp"

namespace iroha {
  namespace network {
    class GenericClientFactory;
  }
  namespace consensus {
    namespace yac {

      class YacInit {
       public:
        std::shared_ptr<YacGate> initConsensusGate(
            Round initial_round,
            // TODO 30.01.2019 lebdron: IR-262 Remove PeerQueryFactory
            std::shared_ptr<ametsuchi::PeerQueryFactory> peer_query_factory,
            boost::optional<shared_model::interface::types::PeerList>
                alternative_peers,
            std::shared_ptr<const LedgerState> ledger_state,
            std::shared_ptr<simulator::BlockCreator> block_creator,
            std::shared_ptr<network::BlockLoader> block_loader,
            const shared_model::crypto::Keypair &keypair,
            std::shared_ptr<consensus::ConsensusResultCache> block_cache,
            std::chrono::milliseconds vote_delay_milliseconds,
            std::shared_ptr<
                iroha::network::AsyncGrpcClient<google::protobuf::Empty>>
                async_call,
            ConsistencyModel consistency_model,
            const logger::LoggerManagerTreePtr &consensus_log_manager,
            std::chrono::milliseconds delay,
            std::shared_ptr<iroha::network::GenericClientFactory>
                client_factory);

        std::shared_ptr<NetworkImpl> getConsensusNetwork() const;

       private:
        auto createTimer(std::chrono::milliseconds delay_milliseconds);

        bool initialized_{false};
        std::shared_ptr<NetworkImpl> consensus_network_;
      };
    }  // namespace yac
  }    // namespace consensus
}  // namespace iroha

#endif  // IROHA_CONSENSUS_INIT_HPP