query_service.hpp

Go to the documentation of this file.

#ifndef TORII_QUERY_SERVICE_HPP
#define TORII_QUERY_SERVICE_HPP

#include <unordered_map>
#include "endpoint.grpc.pb.h"
#include "endpoint.pb.h"
#include "qry_responses.pb.h"

#include "backend/protobuf/queries/proto_blocks_query.hpp"
#include "backend/protobuf/queries/proto_query.hpp"
#include "builders/protobuf/transport_builder.hpp"
#include "cache/cache.hpp"
#include "logger/logger_fwd.hpp"
#include "torii/processor/query_processor.hpp"

namespace shared_model {
  namespace interface {
    template <typename Interface, typename Transport>
    class AbstractTransportFactory;
  }
}  // namespace shared_model

namespace iroha {
  namespace torii {
    class QueryService : public iroha::protocol::QueryService_v1::Service {
     public:
      using QueryFactoryType =
          shared_model::interface::AbstractTransportFactory<
              shared_model::interface::Query,
              iroha::protocol::Query>;
      using BlocksQueryFactoryType =
          shared_model::interface::AbstractTransportFactory<
              shared_model::interface::BlocksQuery,
              iroha::protocol::BlocksQuery>;

      QueryService(
          std::shared_ptr<iroha::torii::QueryProcessor> query_processor,
          std::shared_ptr<QueryFactoryType> query_factory,
          std::shared_ptr<BlocksQueryFactoryType> blocks_query_factory,
          logger::LoggerPtr log);

      QueryService(const QueryService &) = delete;
      QueryService &operator=(const QueryService &) = delete;

      void Find(iroha::protocol::Query const &request,
                iroha::protocol::QueryResponse &response);

      grpc::Status Find(grpc::ServerContext *context,
                        const iroha::protocol::Query *request,
                        iroha::protocol::QueryResponse *response) override;

      grpc::Status FetchCommits(
          grpc::ServerContext *context,
          const iroha::protocol::BlocksQuery *request,
          grpc::ServerWriter<::iroha::protocol::BlockQueryResponse> *writer)
          override;

     private:
      std::shared_ptr<iroha::torii::QueryProcessor> query_processor_;
      std::shared_ptr<QueryFactoryType> query_factory_;
      std::shared_ptr<BlocksQueryFactoryType> blocks_query_factory_;

      // TODO 18.02.2019 lebdron: IR-336 Replace cache
      iroha::cache::Cache<shared_model::crypto::Hash,
                          int,
                          shared_model::crypto::Hash::Hasher>
          cache_;

      logger::LoggerPtr log_;
    };
  }  // namespace torii
}  // namespace iroha

#endif  // TORII_QUERY_SERVICE_HPP