mst_processor.hpp

Go to the documentation of this file.

#ifndef IROHA_MST_PROPAGATOR_HPP
#define IROHA_MST_PROPAGATOR_HPP

#include <memory>
#include <mutex>

#include <rxcpp/rx-observable-fwd.hpp>
#include "logger/logger_fwd.hpp"
#include "multi_sig_transactions/mst_types.hpp"

namespace iroha {

  class MstProcessor {
   public:
    // ---------------------------| user interface |----------------------------

    void propagateBatch(const DataType &batch);

    bool batchInStorage(const DataType &batch) const;

    rxcpp::observable<std::shared_ptr<MstState>> onStateUpdate() const;

    rxcpp::observable<DataType> onPreparedBatches() const;

    rxcpp::observable<DataType> onExpiredBatches() const;

    virtual ~MstProcessor() = default;

   protected:
    explicit MstProcessor(logger::LoggerPtr log);

    logger::LoggerPtr log_;

   private:
    // ------------------------| inheritance interface |------------------------

    virtual auto propagateBatchImpl(const DataType &batch)
        -> decltype(propagateBatch(batch)) = 0;

    virtual auto onStateUpdateImpl() const -> decltype(onStateUpdate()) = 0;

    virtual auto onPreparedBatchesImpl() const
        -> decltype(onPreparedBatches()) = 0;

    virtual auto onExpiredBatchesImpl() const
        -> decltype(onExpiredBatches()) = 0;

    virtual bool batchInStorageImpl(const DataType &batch) const = 0;
  };
}  // namespace iroha

#endif  // IROHA_MST_PROPAGATOR_HPP