query_client.hpp

Go to the documentation of this file.

#ifndef TORII_UTILS_QUERY_CLIENT_HPP
#define TORII_UTILS_QUERY_CLIENT_HPP

#include <endpoint.grpc.pb.h>
#include <endpoint.pb.h>
#include <memory>
#include <thread>

namespace torii_utils {

  class QuerySyncClient {
   public:
    using Service = iroha::protocol::QueryService_v1;

    QuerySyncClient(std::shared_ptr<Service::StubInterface> stub);

    grpc::Status Find(const iroha::protocol::Query &query,
                      iroha::protocol::QueryResponse &response) const;

    std::vector<iroha::protocol::BlockQueryResponse> FetchCommits(
        const iroha::protocol::BlocksQuery &blocks_query) const;

   private:
    void swap(QuerySyncClient &lhs, QuerySyncClient &rhs);

    std::shared_ptr<Service::StubInterface> stub_;
  };

}  // namespace torii_utils

#endif  // TORII_UTILS_QUERY_CLIENT_HPP