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:
    QuerySyncClient(const std::string &ip, size_t port);

    QuerySyncClient(const QuerySyncClient &);
    QuerySyncClient &operator=(QuerySyncClient);

    QuerySyncClient(QuerySyncClient &&) noexcept;
    QuerySyncClient &operator=(QuerySyncClient &&) noexcept;

    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::string ip_;
    size_t port_;
    std::unique_ptr<iroha::protocol::QueryService_v1::StubInterface> stub_;
  };

}  // namespace torii_utils

#endif  // TORII_UTILS_QUERY_CLIENT_HPP