transaction_packet_handler.hpp

Go to the documentation of this file.

#pragma once
 
#include "common/packet_handler.hpp"
#include "transaction/transaction.hpp"
 
namespace taraxa {
class TransactionManager;
enum class TransactionStatus;
}  // namespace taraxa
 
namespace taraxa::network::tarcap {
 
class TestState;
 
class TransactionPacketHandler : public PacketHandler {
 public:
  TransactionPacketHandler(const FullNodeConfig& conf, std::shared_ptr<PeersState> peers_state,
                           std::shared_ptr<TimePeriodPacketsStats> packets_stats,
                           std::shared_ptr<TransactionManager> trx_mgr, const addr_t& node_addr,
                           const std::string& logs_prefix = "TRANSACTION_PH");
 
  void sendTransactions(std::shared_ptr<TaraxaPeer> peer,
                        std::pair<SharedTransactions, std::vector<trx_hash_t>>&& transactions);
 
  void periodicSendTransactions(std::vector<SharedTransactions>&& transactions);
 
  // Packet type that is processed by this handler
  static constexpr SubprotocolPacketType kPacketType_ = SubprotocolPacketType::TransactionPacket;
 
  // 2 items: hashes and transactions
  static constexpr uint32_t kTransactionPacketItemCount = 2;
 
 private:
  virtual void validatePacketRlpFormat(const threadpool::PacketData& packet_data) const override;
  virtual void process(const threadpool::PacketData& packet_data, const std::shared_ptr<TaraxaPeer>& peer) override;
 
 protected:
  std::vector<std::pair<std::shared_ptr<TaraxaPeer>, std::pair<SharedTransactions, std::vector<trx_hash_t>>>>
  transactionsToSendToPeers(std::vector<SharedTransactions>&& transactions);
 
  std::pair<uint32_t, std::pair<SharedTransactions, std::vector<trx_hash_t>>> transactionsToSendToPeer(
      std::shared_ptr<TaraxaPeer> peer, const std::vector<SharedTransactions>& transactions,
      uint32_t account_start_index);
 
  std::shared_ptr<TransactionManager> trx_mgr_;
 
  std::atomic<uint64_t> received_trx_count_{0};
  std::atomic<uint64_t> unique_received_trx_count_{0};
};
 
}  // namespace taraxa::network::tarcap