Companion for paritytech/substrate#12828 (#6380)

* Companion for paritytech/substrate#12828

* Pass sync service

* Fix test

* Fix tests again

* update lockfile for {"substrate"}

* cargo fmt

---------

Co-authored-by: parity-processbot <>
This commit is contained in:
Aaro Altonen
2023-03-06 19:46:27 +02:00
committed by GitHub
parent ed6fa5499c
commit ce9fbe73d9
7 changed files with 222 additions and 196 deletions
+2 -3
View File
@@ -145,14 +145,13 @@ where
loop {
match network_stream.next().await {
None => return Err(Error::EventStreamConcluded),
Some(NetworkEvent::Dht(_)) |
Some(NetworkEvent::SyncConnected { .. }) |
Some(NetworkEvent::SyncDisconnected { .. }) => {},
Some(NetworkEvent::Dht(_)) => {},
Some(NetworkEvent::NotificationStreamOpened {
remote: peer,
protocol,
role,
negotiated_fallback,
received_handshake: _,
}) => {
let role = ObservedRole::from(role);
let (peer_set, version) = {
@@ -195,6 +195,7 @@ impl TestNetworkHandle {
protocol: self.protocol_names.get_main_name(peer_set),
negotiated_fallback: None,
role: role.into(),
received_handshake: vec![],
})
.await;
}
@@ -173,6 +173,7 @@ impl TestNetworkHandle {
protocol: self.peerset_protocol_names.get_main_name(peer_set),
negotiated_fallback: None,
role: role.into(),
received_handshake: vec![],
})
.await;
}