interactive_query_cli.hpp

Go to the documentation of this file.

#ifndef IROHA_CLI_INTERACTIVE_QUERY_CLI_HPP
#define IROHA_CLI_INTERACTIVE_QUERY_CLI_HPP

#include <memory>
#include <unordered_map>

#include "interactive/interactive_common_cli.hpp"
#include "logger/logger_fwd.hpp"
#include "logger/logger_manager_fwd.hpp"
#include "model/generators/query_generator.hpp"

namespace iroha {
  namespace model {
    class ModelCryptoProvider;
    struct Query;
  }  // namespace model
}  // namespace iroha

namespace iroha_cli {
  namespace interactive {
    class InteractiveQueryCli {
     public:
      InteractiveQueryCli(
          const std::string &account_id,
          const std::string &default_peer_ip,
          int default_port,
          uint64_t query_counter,
          const std::shared_ptr<iroha::model::ModelCryptoProvider> &provider,
          logger::LoggerManagerTreePtr response_handler_log_manager,
          logger::LoggerPtr pb_qry_factory_log,
          logger::LoggerPtr json_qry_factory_log,
          logger::LoggerPtr log);
      void run();

     private:
      using QueryName = std::string;
      using QueryParams = std::vector<std::string>;

      // Menu for Queries
      MenuPoints menu_points_;
      void create_queries_menu();

      // Menu for Query result
      MenuPoints result_points_;

      void create_result_menu();

      // ------ Query handlers -----------
      const std::string GET_ACC = "get_acc";
      const std::string GET_ACC_AST = "get_acc_ast";
      const std::string GET_ACC_AST_TX = "get_acc_ast_tx";
      const std::string GET_ACC_TX = "get_acc_tx";
      const std::string GET_TX = "get_tx";
      const std::string GET_ACC_SIGN = "get_acc_sign";
      const std::string GET_ROLES = "get_roles";
      const std::string GET_AST_INFO = "get_ast_info";
      const std::string GET_ROLE_PERM = "get_role_perm";

      // ------  Query parsers ---------
      using QueryHandler = std::shared_ptr<iroha::model::Query> (
          InteractiveQueryCli::*)(QueryParams);
      std::unordered_map<QueryName, QueryHandler> query_handlers_;
      // Descriptions of queries
      DescriptionMap description_map_;

      // Parameters descriptions of queries
      ParamsMap query_params_map_;

      bool parseQuery(std::string line);
      //  --- Specific Query parsers ---
      std::shared_ptr<iroha::model::Query> parseGetAccount(QueryParams params);
      std::shared_ptr<iroha::model::Query> parseGetAccountAssets(
          QueryParams params);
      std::shared_ptr<iroha::model::Query> parseGetAccountAssetTransactions(
          QueryParams params);
      std::shared_ptr<iroha::model::Query> parseGetAccountTransactions(
          QueryParams params);
      std::shared_ptr<iroha::model::Query> parseGetTransactions(
          QueryParams params);
      std::shared_ptr<iroha::model::Query> parseGetSignatories(
          QueryParams params);
      std::shared_ptr<iroha::model::Query> parseGetRoles(QueryParams params);
      std::shared_ptr<iroha::model::Query> parseGetRolePermissions(
          QueryParams params);
      std::shared_ptr<iroha::model::Query> parseGetAssetInfo(
          QueryParams params);

      // ------ Result parsers -------
      using ResultHandler = bool (InteractiveQueryCli::*)(QueryParams);
      std::unordered_map<QueryName, ResultHandler> result_handlers_;

      // Parameters descriptions of result commands
      ParamsMap result_params_map_;

      bool parseResult(std::string line);
      // ---- Specific Result handlers
      bool parseSendToIroha(QueryParams line);
      bool parseSaveFile(QueryParams line);

      // Current context for query forming
      MenuContext current_context_;

      // ------- Query data -----------
      // Creator account id
      std::string creator_;
      // Default Iroha peer address
      std::string default_peer_ip_;
      int default_port_;

      // Local query counter of account creator_
      uint64_t counter_;

      // Local time
      uint64_t local_time_;

      // Processed query
      std::shared_ptr<iroha::model::Query> query_;

      // Query generator for new queries
      iroha::model::generators::QueryGenerator generator_;

      // Crypto provider
      std::shared_ptr<iroha::model::ModelCryptoProvider> provider_;

      logger::LoggerManagerTreePtr response_handler_log_manager_;

      logger::LoggerPtr pb_qry_factory_log_;

      logger::LoggerPtr json_qry_factory_log_;

      logger::LoggerPtr log_;
    };
  }  // namespace interactive
}  // namespace iroha_cli
#endif  // IROHA_CLI_INTERACTIVE_QUERY_CLI_HPP