Skip to content

Commit 3c9fcae

Browse files
committed
test: remove redundant network_protocol_versioning_send test
1 parent d105416 commit 3c9fcae

File tree

1 file changed

+1
-59
lines changed
  • polkadot/node/network/bridge/src/tx

1 file changed

+1
-59
lines changed

polkadot/node/network/bridge/src/tx/tests.rs

+1-59
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@ use codec::DecodeAll;
3030
use polkadot_node_network_protocol::{
3131
peer_set::PeerSetProtocolNames,
3232
request_response::{outgoing::Requests, ReqProtocolNames},
33-
v1 as protocol_v1, v2 as protocol_v2, v3 as protocol_v3, ObservedRole, Versioned,
33+
v1 as protocol_v1, v3 as protocol_v3, ObservedRole, Versioned,
3434
};
3535
use polkadot_node_subsystem::{FromOrchestra, OverseerSignal};
3636
use polkadot_node_subsystem_test_helpers::TestSubsystemContextHandle;
@@ -369,61 +369,3 @@ fn send_messages_to_peers() {
369369
virtual_overseer
370370
});
371371
}
372-
373-
#[test]
374-
fn network_protocol_versioning_send() {
375-
test_harness(|test_harness| async move {
376-
let TestHarness { mut network_handle, mut virtual_overseer } = test_harness;
377-
378-
let peer_ids: Vec<_> = (0..2).map(|_| PeerId::random()).collect();
379-
let peers = [(peer_ids[0], PeerSet::Collation), (peer_ids[1], PeerSet::Collation)];
380-
381-
for &(peer_id, peer_set) in &peers {
382-
network_handle
383-
.connect_peer(peer_id, peer_set, ObservedRole::Full)
384-
.timeout(TIMEOUT)
385-
.await
386-
.expect("Timeout does not occur");
387-
}
388-
389-
// send a collation protocol message.
390-
391-
{
392-
let collator_protocol_message = protocol_v2::CollatorProtocolMessage::Declare(
393-
Sr25519Keyring::Alice.public().into(),
394-
0_u32.into(),
395-
dummy_collator_signature(),
396-
);
397-
398-
let msg =
399-
protocol_v2::CollationProtocol::CollatorProtocol(collator_protocol_message.clone());
400-
401-
let receivers = vec![peer_ids[0], peer_ids[1]];
402-
403-
virtual_overseer
404-
.send(FromOrchestra::Communication {
405-
msg: NetworkBridgeTxMessage::SendCollationMessages(vec![(
406-
receivers.clone(),
407-
Versioned::V2(msg.clone()),
408-
)]),
409-
})
410-
.await;
411-
412-
for peer in &receivers {
413-
assert_eq!(
414-
network_handle
415-
.next_network_action()
416-
.timeout(TIMEOUT)
417-
.await
418-
.expect("Timeout does not occur"),
419-
NetworkAction::WriteNotification(
420-
*peer,
421-
PeerSet::Collation,
422-
WireMessage::ProtocolMessage(msg.clone()).encode(),
423-
)
424-
);
425-
}
426-
}
427-
virtual_overseer
428-
});
429-
}

0 commit comments

Comments
 (0)