6 #ifndef IROHA_TRANSACTION_PROCESSOR_STUB_HPP 7 #define IROHA_TRANSACTION_PROCESSOR_STUB_HPP 13 #include <rxcpp/rx.hpp> 34 std::shared_ptr<network::PeerCommunicationService> pcs,
35 std::shared_ptr<MstProcessor> mst_processor,
36 std::shared_ptr<iroha::torii::StatusBus> status_bus,
37 std::shared_ptr<shared_model::interface::TxStatusFactory>
42 std::shared_ptr<shared_model::interface::TransactionBatch>
43 transaction_batch)
const override;
47 std::shared_ptr<network::PeerCommunicationService> pcs_;
50 std::shared_ptr<MstProcessor> mst_processor_;
52 std::shared_ptr<iroha::torii::StatusBus> status_bus_;
55 rxcpp::subjects::subject<
56 std::shared_ptr<shared_model::interface::TransactionResponse>>
60 std::vector<shared_model::interface::types::HashType> current_txs_hashes_;
63 std::shared_ptr<shared_model::interface::TxStatusFactory> status_factory_;
71 enum class TxStatusType {
81 kEnoughSignaturesCollected
89 void publishStatus(TxStatusType tx_status,
99 void publishEnoughSignaturesStatus(
106 #endif // IROHA_TRANSACTION_PROCESSOR_STUB_HPP Definition: transaction_processor_impl.hpp:24
Definition: transaction_processor.hpp:23
Definition: command_client.hpp:16
std::shared_ptr< spdlog::logger > Logger
Definition: logger.hpp:26
Definition: block_query.hpp:16
hash256_t hash(const T &pb)
Definition: pb_common.hpp:43
Definition: stateful_validator_common.hpp:30
Logger log(const std::string &tag)
Definition: logger.cpp:48
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"))
Definition: transaction_processor_impl.cpp:45
std::vector< std::shared_ptr< Transaction >> SharedTxsCollectionType
Definition: transaction_sequence_common.hpp:27
void batchHandle(std::shared_ptr< shared_model::interface::TransactionBatch > transaction_batch) const override
Definition: transaction_processor_impl.cpp:135