synchronizer_common.hpp

Go to the documentation of this file.

#ifndef IROHA_SYNCHRONIZER_COMMON_HPP
#define IROHA_SYNCHRONIZER_COMMON_HPP

#include <utility>

#include <rxcpp/rx.hpp>

#include "ametsuchi/ledger_state.hpp"
#include "consensus/round.hpp"
#include "interfaces/iroha_internal/block.hpp"

namespace iroha {
  namespace synchronizer {

    using Chain =
        rxcpp::observable<std::shared_ptr<shared_model::interface::Block>>;

    enum class SynchronizationOutcomeType { kCommit, kReject, kNothing };

    struct SynchronizationEvent {
      // TODO andrei 08.11.2018 IR-1852 Rework blocks collection from
      // synchronizer with iterable
      Chain synced_blocks;
      SynchronizationOutcomeType sync_outcome;
      consensus::Round round;
      std::shared_ptr<iroha::LedgerState> ledger_state;
    };

  }  // namespace synchronizer
}  // namespace iroha

#endif  // IROHA_SYNCHRONIZER_COMMON_HPP