peer_communication_service.hpp

Go to the documentation of this file.

#ifndef IROHA_PEER_COMMUNICATION_SERVICE_HPP
#define IROHA_PEER_COMMUNICATION_SERVICE_HPP

#include <rxcpp/rx-observable-fwd.hpp>
#include "network/ordering_gate_common.hpp"
#include "simulator/verified_proposal_creator_common.hpp"
#include "synchronizer/synchronizer_common.hpp"

namespace shared_model {
  namespace interface {
    class Proposal;
    class TransactionBatch;
  }  // namespace interface
}  // namespace shared_model

namespace iroha {
  namespace network {

    class PeerCommunicationService {
     public:
      virtual void propagate_batch(
          std::shared_ptr<shared_model::interface::TransactionBatch> batch)
          const = 0;

      virtual rxcpp::observable<OrderingEvent> onProposal() const = 0;

      virtual rxcpp::observable<simulator::VerifiedProposalCreatorEvent>
      onVerifiedProposal() const = 0;

      virtual rxcpp::observable<synchronizer::SynchronizationEvent>
      onSynchronization() const = 0;

      virtual ~PeerCommunicationService() = default;
    };

  }  // namespace network
}  // namespace iroha

#endif  // IROHA_PEER_COMMUNICATION_SERVICE_HPP