pending_transaction_storage_init.hpp

Go to the documentation of this file.

#ifndef IROHA_PENDING_TRANSACTION_STORAGE_INIT_HPP
#define IROHA_PENDING_TRANSACTION_STORAGE_INIT_HPP

#include <memory>

#include <rxcpp/rx-lite.hpp>
#include "interfaces/common_objects/types.hpp"

namespace shared_model {
  namespace interface {
    class TransactionBatch;
  }
}  // namespace shared_model

namespace iroha {

  class MstProcessor;
  class MstState;
  class PendingTransactionStorage;

  namespace network {
    class PeerCommunicationService;
  }

  class PendingTransactionStorageInit {
   public:
    PendingTransactionStorageInit();

    std::shared_ptr<PendingTransactionStorage>
    createPendingTransactionsStorage();

    void setMstSubscriptions(const MstProcessor &mst_processor);

    void setFinalizedTxsSubscription(
        rxcpp::observable<shared_model::interface::types::HashType>
            finalized_txs);

    ~PendingTransactionStorageInit();

   protected:
    rxcpp::composite_subscription pending_storage_lifetime;
    rxcpp::subjects::subject<std::shared_ptr<iroha::MstState>> updated_batches;
    rxcpp::subjects::subject<
        std::shared_ptr<shared_model::interface::TransactionBatch>>
        prepared_batch;
    rxcpp::subjects::subject<
        std::shared_ptr<shared_model::interface::TransactionBatch>>
        expired_batch;
    rxcpp::subjects::subject<
        std::pair<shared_model::interface::types::AccountIdType,
                  shared_model::interface::types::HashType>>
        prepared_txs;
    rxcpp::subjects::subject<shared_model::interface::types::HashType>
        finalized_txs;
  };
}  // namespace iroha

#endif  // IROHA_PENDING_TRANSACTION_STORAGE_INIT_HPP