query_processor.hpp

Go to the documentation of this file.

#ifndef IROHA_QUERY_PROCESSOR_HPP
#define IROHA_QUERY_PROCESSOR_HPP

#include <rxcpp/rx-observable-fwd.hpp>

#include <memory>
#include <string>

#include "common/result_fwd.hpp"

namespace shared_model {
  namespace interface {
    class Query;
    class BlocksQuery;
    class QueryResponse;
    class BlockQueryResponse;
  }  // namespace interface
}  // namespace shared_model

namespace iroha {
  namespace torii {

    class QueryProcessor {
     public:
      virtual iroha::expected::Result<
          std::unique_ptr<shared_model::interface::QueryResponse>,
          std::string>
      queryHandle(const shared_model::interface::Query &qry) = 0;
      virtual rxcpp::observable<
          std::shared_ptr<shared_model::interface::BlockQueryResponse>>
      blocksQueryHandle(const shared_model::interface::BlocksQuery &qry) = 0;

      virtual ~QueryProcessor(){};
    };
  }  // namespace torii
}  // namespace iroha

#endif  // IROHA_QUERY_PROCESSOR_HPP