transaction_processor_impl.hpp

Go to the documentation of this file.

#ifndef IROHA_TRANSACTION_PROCESSOR_STUB_HPP
#define IROHA_TRANSACTION_PROCESSOR_STUB_HPP

#include "torii/processor/transaction_processor.hpp"

#include <mutex>

#include <rxcpp/rx.hpp>
#include "interfaces/common_objects/transaction_sequence_common.hpp"
#include "interfaces/iroha_internal/tx_status_factory.hpp"
#include "interfaces/transaction_responses/tx_response.hpp"
#include "logger/logger.hpp"
#include "multi_sig_transactions/mst_processor.hpp"
#include "network/peer_communication_service.hpp"
#include "torii/status_bus.hpp"

namespace iroha {
  namespace torii {
    class TransactionProcessorImpl : public TransactionProcessor {
     public:
      TransactionProcessorImpl(
          std::shared_ptr<network::PeerCommunicationService> pcs,
          std::shared_ptr<MstProcessor> mst_processor,
          std::shared_ptr<iroha::torii::StatusBus> status_bus,
          std::shared_ptr<shared_model::interface::TxStatusFactory>
              status_factory,
          logger::Logger log = logger::log("TxProcessor"));

      void batchHandle(
          std::shared_ptr<shared_model::interface::TransactionBatch>
              transaction_batch) const override;

     private:
      // connections
      std::shared_ptr<network::PeerCommunicationService> pcs_;

      // processing
      std::shared_ptr<MstProcessor> mst_processor_;

      std::shared_ptr<iroha::torii::StatusBus> status_bus_;

      // internal
      rxcpp::subjects::subject<
          std::shared_ptr<shared_model::interface::TransactionResponse>>
          notifier_;

      // keeps hashes of transaction, which were committed during this round
      std::vector<shared_model::interface::types::HashType> current_txs_hashes_;

      // creates transaction status
      std::shared_ptr<shared_model::interface::TxStatusFactory> status_factory_;

      logger::Logger log_;

      // TODO: [IR-1665] Akvinikym 29.08.18: Refactor method publishStatus(..)
      enum class TxStatusType {
        kStatelessFailed,
        kStatelessValid,
        kStatefulFailed,
        kStatefulValid,
        kRejected,
        kCommitted,
        kMstExpired,
        kNotReceived,
        kMstPending,
        kEnoughSignaturesCollected
      };
      void publishStatus(TxStatusType tx_status,
                         const shared_model::crypto::Hash &hash,
                         const validation::CommandError &cmd_error =
                             validation::CommandError{}) const;

      void publishEnoughSignaturesStatus(
          const shared_model::interface::types::SharedTxsCollectionType &txs)
          const;
    };
  }  // namespace torii
}  // namespace iroha

#endif  // IROHA_TRANSACTION_PROCESSOR_STUB_HPP