storage.hpp

Go to the documentation of this file.

#ifndef IROHA_AMETSUCHI_H
#define IROHA_AMETSUCHI_H

#include <vector>

#include <rxcpp/rx-observable-fwd.hpp>
#include "ametsuchi/block_query_factory.hpp"
#include "ametsuchi/mutable_factory.hpp"
#include "ametsuchi/peer_query_factory.hpp"
#include "ametsuchi/query_executor_factory.hpp"
#include "ametsuchi/setting_query_factory.hpp"
#include "ametsuchi/temporary_factory.hpp"
#include "common/result_fwd.hpp"

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

namespace iroha {

  namespace ametsuchi {

    class BlockStorageFactory;
    class BlockQuery;
    class WsvQuery;

    class Storage : public TemporaryFactory,
                    public MutableFactory,
                    public PeerQueryFactory,
                    public BlockQueryFactory,
                    public QueryExecutorFactory,
                    public SettingQueryFactory {
     public:
      virtual std::shared_ptr<WsvQuery> getWsvQuery() const = 0;

      virtual std::shared_ptr<BlockQuery> getBlockQuery() const = 0;

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

      virtual expected::Result<std::unique_ptr<CommandExecutor>, std::string>
      createCommandExecutor() = 0;

      virtual expected::Result<void, std::string> insertPeer(
          const shared_model::interface::Peer &peer) = 0;

      using MutableFactory::createMutableStorage;

      virtual std::unique_ptr<MutableStorage> createMutableStorage(
          std::shared_ptr<CommandExecutor> command_executor,
          BlockStorageFactory &storage_factory) = 0;

      virtual rxcpp::observable<
          std::shared_ptr<const shared_model::interface::Block>>
      on_commit() = 0;

      virtual void resetPeers() = 0;

      virtual expected::Result<void, std::string> dropBlockStorage() = 0;

      virtual boost::optional<std::shared_ptr<const iroha::LedgerState>>
      getLedgerState() const = 0;

      virtual void freeConnections() = 0;

      virtual ~Storage() = default;
    };

  }  // namespace ametsuchi

}  // namespace iroha

#endif  // IROHA_AMETSUCHI_H