command_service_transport_grpc.hpp

Go to the documentation of this file.

#ifndef TORII_COMMAND_SERVICE_TRANSPORT_GRPC_HPP
#define TORII_COMMAND_SERVICE_TRANSPORT_GRPC_HPP

#include "torii/command_service.hpp"

#include <rxcpp/rx-lite.hpp>
#include "endpoint.grpc.pb.h"
#include "endpoint.pb.h"
#include "interfaces/common_objects/transaction_sequence_common.hpp"
#include "interfaces/iroha_internal/abstract_transport_factory.hpp"
#include "logger/logger_fwd.hpp"

namespace iroha {
  namespace torii {
    class StatusBus;
  }
}  // namespace iroha

namespace shared_model {
  namespace interface {
    class TxStatusFactory;
    class TransactionBatchParser;
    class TransactionBatchFactory;
  }  // namespace interface
}  // namespace shared_model

namespace iroha {
  namespace torii {
    class CommandServiceTransportGrpc
        : public iroha::protocol::CommandService_v1::Service {
     public:
      using TransportFactoryType =
          shared_model::interface::AbstractTransportFactory<
              shared_model::interface::Transaction,
              iroha::protocol::Transaction>;

      struct ConsensusGateEvent {};

      CommandServiceTransportGrpc(
          std::shared_ptr<CommandService> command_service,
          std::shared_ptr<iroha::torii::StatusBus> status_bus,
          std::shared_ptr<shared_model::interface::TxStatusFactory>
              status_factory,
          std::shared_ptr<TransportFactoryType> transaction_factory,
          std::shared_ptr<shared_model::interface::TransactionBatchParser>
              batch_parser,
          std::shared_ptr<shared_model::interface::TransactionBatchFactory>
              transaction_batch_factory,
          rxcpp::observable<ConsensusGateEvent> consensus_gate_objects,
          int maximum_rounds_without_update,
          logger::LoggerPtr log);

      grpc::Status Torii(grpc::ServerContext *context,
                         const iroha::protocol::Transaction *request,
                         google::protobuf::Empty *response) override;

      grpc::Status ListTorii(grpc::ServerContext *context,
                             const iroha::protocol::TxList *request,
                             google::protobuf::Empty *response) override;

      grpc::Status Status(grpc::ServerContext *context,
                          const iroha::protocol::TxStatusRequest *request,
                          iroha::protocol::ToriiResponse *response) override;

      grpc::Status StatusStream(
          grpc::ServerContext *context,
          const iroha::protocol::TxStatusRequest *request,
          grpc::ServerWriter<iroha::protocol::ToriiResponse> *response_writer)
          override;

     private:
      shared_model::interface::types::SharedTxsCollectionType
      deserializeTransactions(const iroha::protocol::TxList *request);

      std::shared_ptr<CommandService> command_service_;
      std::shared_ptr<iroha::torii::StatusBus> status_bus_;
      std::shared_ptr<shared_model::interface::TxStatusFactory> status_factory_;
      std::shared_ptr<TransportFactoryType> transaction_factory_;
      std::shared_ptr<shared_model::interface::TransactionBatchParser>
          batch_parser_;
      std::shared_ptr<shared_model::interface::TransactionBatchFactory>
          batch_factory_;
      logger::LoggerPtr log_;

      rxcpp::observable<ConsensusGateEvent> consensus_gate_objects_;
      const int maximum_rounds_without_update_;
    };
  }  // namespace torii
}  // namespace iroha

#endif  // TORII_COMMAND_SERVICE_TRANSPORT_GRPC_HPP