peers_state.hpp

Go to the documentation of this file.

#pragma once
 
#include "common/util.hpp"
#include "config/config.hpp"
#include "libp2p/Common.h"
#include "libp2p/Host.h"
#include "network/tarcap/packet_types.hpp"
#include "network/tarcap/stats/time_period_packets_stats.hpp"
#include "network/tarcap/taraxa_peer.hpp"
 
namespace taraxa::network::tarcap {
 
class PeersState {
 public:
  using PeersMap = std::unordered_map<dev::p2p::NodeID, std::shared_ptr<TaraxaPeer>>;
 
  PeersState(std::weak_ptr<dev::p2p::Host> host, const FullNodeConfig& conf);
 
  std::shared_ptr<TaraxaPeer> getPeer(const dev::p2p::NodeID& node_id) const;
  std::shared_ptr<TaraxaPeer> getPendingPeer(const dev::p2p::NodeID& node_id) const;
 
  std::pair<std::shared_ptr<TaraxaPeer>, std::string> getPacketSenderPeer(const dev::p2p::NodeID& node_id,
                                                                          SubprotocolPacketType packet_type) const;
 
  PeersMap getAllPeers() const;
  std::vector<dev::p2p::NodeID> getAllPendingPeersIDs() const;
  size_t getPeersCount() const;
  std::shared_ptr<TaraxaPeer> addPendingPeer(const dev::p2p::NodeID& node_id, const std::string& address);
  void erasePeer(const dev::p2p::NodeID& node_id);
  std::shared_ptr<TaraxaPeer> setPeerAsReadyToSendMessages(dev::p2p::NodeID const& node_id,
                                                           std::shared_ptr<TaraxaPeer> peer);
 
  void set_peer_malicious(const dev::p2p::NodeID& peer_id);
 
  bool is_peer_malicious(const dev::p2p::NodeID& peer_id);
 
 public:
  const std::weak_ptr<dev::p2p::Host> host_;
 
 private:
  mutable std::shared_mutex peers_mutex_;
  PeersMap peers_;
  PeersMap pending_peers_;
 
  ThreadSafeMap<dev::p2p::NodeID, std::chrono::steady_clock::time_point> malicious_peers_;
  const FullNodeConfig kConf;
};
 
}  // namespace taraxa::network::tarcap