[companion] Get rid of Peerset compatibility layer (#7355)

* Update `NetworkPeers` trait interface

* update lockfile for {"substrate"}

---------

Co-authored-by: parity-processbot <>
This commit is contained in:
Dmitry Markin
2023-08-02 16:37:12 +03:00
committed by GitHub
parent 367098bae5
commit 253c505edc
5 changed files with 217 additions and 190 deletions
+11 -3
View File
@@ -94,7 +94,11 @@ pub trait Network: Clone + Send + 'static {
) -> Result<(), String>;
/// Removes the peers for the protocol's peer set (both reserved and non-reserved).
async fn remove_from_peers_set(&mut self, protocol: ProtocolName, peers: Vec<PeerId>);
async fn remove_from_peers_set(
&mut self,
protocol: ProtocolName,
peers: Vec<PeerId>,
) -> Result<(), String>;
/// Send a request to a remote peer.
async fn start_request<AD: AuthorityDiscovery>(
@@ -129,8 +133,12 @@ impl Network for Arc<NetworkService<Block, Hash>> {
NetworkService::set_reserved_peers(&**self, protocol, multiaddresses)
}
async fn remove_from_peers_set(&mut self, protocol: ProtocolName, peers: Vec<PeerId>) {
NetworkService::remove_peers_from_reserved_set(&**self, protocol, peers);
async fn remove_from_peers_set(
&mut self,
protocol: ProtocolName,
peers: Vec<PeerId>,
) -> Result<(), String> {
NetworkService::remove_peers_from_reserved_set(&**self, protocol, peers)
}
fn report_peer(&self, who: PeerId, rep: ReputationChange) {
+7 -1
View File
@@ -117,7 +117,13 @@ impl Network for TestNetwork {
Ok(())
}
async fn remove_from_peers_set(&mut self, _protocol: ProtocolName, _: Vec<PeerId>) {}
async fn remove_from_peers_set(
&mut self,
_protocol: ProtocolName,
_: Vec<PeerId>,
) -> Result<(), String> {
Ok(())
}
async fn start_request<AD: AuthorityDiscovery>(
&self,
+7 -1
View File
@@ -105,7 +105,13 @@ impl Network for TestNetwork {
Ok(())
}
async fn remove_from_peers_set(&mut self, _protocol: ProtocolName, _: Vec<PeerId>) {}
async fn remove_from_peers_set(
&mut self,
_protocol: ProtocolName,
_: Vec<PeerId>,
) -> Result<(), String> {
Ok(())
}
async fn start_request<AD: AuthorityDiscovery>(
&self,
@@ -236,8 +236,13 @@ mod tests {
Ok(())
}
async fn remove_from_peers_set(&mut self, _protocol: ProtocolName, peers: Vec<PeerId>) {
async fn remove_from_peers_set(
&mut self,
_protocol: ProtocolName,
peers: Vec<PeerId>,
) -> Result<(), String> {
self.peers_set.retain(|elem| !peers.contains(elem));
Ok(())
}
async fn start_request<AD: AuthorityDiscovery>(