Skip to content

Commit e052f56

Browse files
committed
fix: allow adding peers without overriding kind
1 parent 044db3e commit e052f56

4 files changed

Lines changed: 10 additions & 10 deletions

File tree

crates/net/network-api/src/lib.rs

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -115,14 +115,14 @@ pub trait Peers: PeersInfo {
115115
///
116116
/// If the peer already exists, then this will update its tracked info.
117117
fn add_peer(&self, peer: PeerId, tcp_addr: SocketAddr) {
118-
self.add_peer_kind(peer, PeerKind::Static, tcp_addr, None);
118+
self.add_peer_kind(peer, Some(PeerKind::Static), tcp_addr, None);
119119
}
120120

121121
/// Adds a peer to the peer set with TCP and UDP `SocketAddr`.
122122
///
123123
/// If the peer already exists, then this will update its tracked info.
124124
fn add_peer_with_udp(&self, peer: PeerId, tcp_addr: SocketAddr, udp_addr: SocketAddr) {
125-
self.add_peer_kind(peer, PeerKind::Static, tcp_addr, Some(udp_addr));
125+
self.add_peer_kind(peer, Some(PeerKind::Static), tcp_addr, Some(udp_addr));
126126
}
127127

128128
/// Adds a trusted [`PeerId`] to the peer set.
@@ -132,12 +132,12 @@ pub trait Peers: PeersInfo {
132132

133133
/// Adds a trusted peer to the peer set with TCP `SocketAddr`.
134134
fn add_trusted_peer(&self, peer: PeerId, tcp_addr: SocketAddr) {
135-
self.add_peer_kind(peer, PeerKind::Trusted, tcp_addr, None);
135+
self.add_peer_kind(peer, Some(PeerKind::Trusted), tcp_addr, None);
136136
}
137137

138138
/// Adds a trusted peer with TCP and UDP `SocketAddr` to the peer set.
139139
fn add_trusted_peer_with_udp(&self, peer: PeerId, tcp_addr: SocketAddr, udp_addr: SocketAddr) {
140-
self.add_peer_kind(peer, PeerKind::Trusted, tcp_addr, Some(udp_addr));
140+
self.add_peer_kind(peer, Some(PeerKind::Trusted), tcp_addr, Some(udp_addr));
141141
}
142142

143143
/// Adds a peer to the known peer set, with the given kind.
@@ -146,7 +146,7 @@ pub trait Peers: PeersInfo {
146146
fn add_peer_kind(
147147
&self,
148148
peer: PeerId,
149-
kind: PeerKind,
149+
kind: Option<PeerKind>,
150150
tcp_addr: SocketAddr,
151151
udp_addr: Option<SocketAddr>,
152152
);

crates/net/network-api/src/noop.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -125,7 +125,7 @@ where
125125
fn add_peer_kind(
126126
&self,
127127
_peer: PeerId,
128-
_kind: PeerKind,
128+
_kind: Option<PeerKind>,
129129
_tcp_addr: SocketAddr,
130130
_udp_addr: Option<SocketAddr>,
131131
) {

crates/net/network/src/network.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -325,7 +325,7 @@ impl<N: NetworkPrimitives> Peers for NetworkHandle<N> {
325325
fn add_peer_kind(
326326
&self,
327327
peer: PeerId,
328-
kind: PeerKind,
328+
kind: Option<PeerKind>,
329329
tcp_addr: SocketAddr,
330330
udp_addr: Option<SocketAddr>,
331331
) {
@@ -526,7 +526,7 @@ pub(crate) enum NetworkHandleMessage<N: NetworkPrimitives = EthNetworkPrimitives
526526
/// Marks a peer as trusted.
527527
AddTrustedPeerId(PeerId),
528528
/// Adds an address for a peer, including its ID, kind, and socket address.
529-
AddPeerAddress(PeerId, PeerKind, PeerAddr),
529+
AddPeerAddress(PeerId, Option<PeerKind>, PeerAddr),
530530
/// Removes a peer from the peerset corresponding to the given kind.
531531
RemovePeer(PeerId, PeerKind),
532532
/// Disconnects a connection to a peer if it exists, optionally providing a disconnect reason.

crates/net/network/src/state.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -308,8 +308,8 @@ impl<N: NetworkPrimitives> NetworkState<N> {
308308
}
309309

310310
/// Adds a peer and its address with the given kind to the peerset.
311-
pub(crate) fn add_peer_kind(&mut self, peer_id: PeerId, kind: PeerKind, addr: PeerAddr) {
312-
self.peers_manager.add_peer_kind(peer_id, Some(kind), addr, None)
311+
pub(crate) fn add_peer_kind(&mut self, peer_id: PeerId, kind: Option<PeerKind>, addr: PeerAddr) {
312+
self.peers_manager.add_peer_kind(peer_id, kind, addr, None)
313313
}
314314

315315
/// Connects a peer and its address with the given kind

0 commit comments

Comments
 (0)