mst_transport.hpp

Go to the documentation of this file.

#ifndef IROHA_MST_TRANSPORT_HPP
#define IROHA_MST_TRANSPORT_HPP

#include <memory>

#include <rxcpp/rx-observable-fwd.hpp>
#include "interfaces/common_objects/peer.hpp"
#include "interfaces/common_objects/string_view_types.hpp"

namespace iroha {

  class MstState;

  namespace network {

    class MstTransportNotification {
     public:
      virtual void onNewState(
          shared_model::interface::types::PublicKeyHexStringView from,
          MstState &&new_state) = 0;

      virtual ~MstTransportNotification() = default;
    };

    class MstTransport {
     public:
      virtual void subscribe(
          std::shared_ptr<MstTransportNotification> notification) = 0;

      virtual rxcpp::observable<bool> sendState(
          std::shared_ptr<shared_model::interface::Peer const> to,
          MstState const &providing_state) = 0;

      virtual ~MstTransport() = default;
    };
  }  // namespace network
}  // namespace iroha
#endif  // IROHA_MST_TRANSPORT_HPP