mutable_storage.hpp

Go to the documentation of this file.

#ifndef IROHA_MUTABLE_STORAGE_HPP
#define IROHA_MUTABLE_STORAGE_HPP

#include <functional>

#include <rxcpp/rx-observable-fwd.hpp>
#include "ametsuchi/block_storage.hpp"
#include "ametsuchi/ledger_state.hpp"
#include "common/result.hpp"
#include "interfaces/common_objects/types.hpp"

namespace shared_model {
  namespace interface {
    class Block;
  }  // namespace interface
}  // namespace shared_model

namespace iroha {
  struct LedgerState;

  namespace ametsuchi {

    class WsvQuery;

    class MutableStorage {
     public:
      using MutableStoragePredicate = std::function<bool(
          std::shared_ptr<const shared_model::interface::Block>,
          const LedgerState &)>;

      struct CommitResult {
        std::shared_ptr<const LedgerState> ledger_state;
        std::unique_ptr<BlockStorage> block_storage;
      };

      virtual bool apply(
          std::shared_ptr<const shared_model::interface::Block> block) = 0;

      virtual bool apply(
          rxcpp::observable<std::shared_ptr<shared_model::interface::Block>>
              blocks,
          MutableStoragePredicate predicate) = 0;

      virtual expected::Result<MutableStorage::CommitResult, std::string>
      commit() && = 0;

      virtual ~MutableStorage() = default;
    };

  }  // namespace ametsuchi
}  // namespace iroha

#endif  // IROHA_MUTABLE_STORAGE_HPP