peer_communication_service_impl.hpp

Go to the documentation of this file.

#ifndef IROHA_PEER_COMMUNICATION_SERVICE_IMPL_HPP
#define IROHA_PEER_COMMUNICATION_SERVICE_IMPL_HPP

#include "network/peer_communication_service.hpp"

#include "logger/logger.hpp"

namespace iroha {
  namespace simulator {
    class VerifiedProposalCreator;
  }  // namespace simulator

  namespace synchronizer {
    class Synchronizer;
  }  // namespace synchronizer

  namespace network {
    class OrderingGate;

    class PeerCommunicationServiceImpl : public PeerCommunicationService {
     public:
      PeerCommunicationServiceImpl(
          std::shared_ptr<OrderingGate> ordering_gate,
          std::shared_ptr<synchronizer::Synchronizer> synchronizer,
          std::shared_ptr<simulator::VerifiedProposalCreator> proposal_creator,
          logger::Logger log = logger::log("PCS"));

      void propagate_batch(
          std::shared_ptr<shared_model::interface::TransactionBatch> batch)
          const override;

      rxcpp::observable<OrderingEvent> onProposal() const override;

      rxcpp::observable<simulator::VerifiedProposalCreatorEvent>
      onVerifiedProposal() const override;

      rxcpp::observable<synchronizer::SynchronizationEvent> on_commit()
          const override;

     private:
      std::shared_ptr<OrderingGate> ordering_gate_;
      std::shared_ptr<synchronizer::Synchronizer> synchronizer_;
      std::shared_ptr<simulator::VerifiedProposalCreator> proposal_creator_;
      logger::Logger log_;
    };
  }  // namespace network
}  // namespace iroha

#endif  // IROHA_PEER_COMMUNICATION_SERVICE_IMPL_HPP