Companion for paritytech/substrate#12264

node/network/protocol/Cargo.toml

@@ -13,6 +13,7 @@ polkadot-node-primitives = { path = "../../primitives" }
 polkadot-node-jaeger = { path = "../../jaeger" }
 parity-scale-codec = { version = "3.1.5", default-features = false, features = ["derive"] }
 sc-network = { git = "https://github.com/paritytech/substrate", branch = "master" }
+sc-network-common = { git = "https://github.com/paritytech/substrate", branch = "master" }
 sc-authority-discovery = { git = "https://github.com/paritytech/substrate", branch = "master" }
 strum = { version = "0.24", features = ["derive"] }
 futures = "0.3.21"

node/network/protocol/src/peer_set.rs

@@ -18,9 +18,9 @@
 
 use derive_more::Display;
 use polkadot_primitives::v2::Hash;
-use sc_network::{
+use sc_network_common::{
 	config::{NonDefaultSetConfig, SetConfig},
-	ProtocolName,
+	protocol::ProtocolName,
 };
 use std::{
 	collections::{hash_map::Entry, HashMap},
@@ -80,15 +80,15 @@ impl PeerSet {
 				notifications_protocol: protocol,
 				fallback_names,
 				max_notification_size,
-				set_config: sc_network::config::SetConfig {
+				set_config: sc_network_common::config::SetConfig {
 					// we allow full nodes to connect to validators for gossip
 					// to ensure any `MIN_GOSSIP_PEERS` always include reserved peers
 					// we limit the amount of non-reserved slots to be less
 					// than `MIN_GOSSIP_PEERS` in total
 					in_peers: super::MIN_GOSSIP_PEERS as u32 / 2 - 1,
 					out_peers: super::MIN_GOSSIP_PEERS as u32 / 2 - 1,
 					reserved_nodes: Vec::new(),
-					non_reserved_mode: sc_network::config::NonReservedPeerMode::Accept,
+					non_reserved_mode: sc_network_common::config::NonReservedPeerMode::Accept,
 				},
 			},
 			PeerSet::Collation => NonDefaultSetConfig {
@@ -101,9 +101,9 @@ impl PeerSet {
 					out_peers: 0,
 					reserved_nodes: Vec::new(),
 					non_reserved_mode: if is_authority == IsAuthority::Yes {
-						sc_network::config::NonReservedPeerMode::Accept
+						sc_network_common::config::NonReservedPeerMode::Accept
 					} else {
-						sc_network::config::NonReservedPeerMode::Deny
+						sc_network_common::config::NonReservedPeerMode::Deny
 					},
 				},
 			},
@@ -188,7 +188,7 @@ impl<T> IndexMut<PeerSet> for PerPeerSet<T> {
 pub fn peer_sets_info(
 	is_authority: IsAuthority,
 	peerset_protocol_names: &PeerSetProtocolNames,
-) -> Vec<sc_network::config::NonDefaultSetConfig> {
+) -> Vec<sc_network_common::config::NonDefaultSetConfig> {
 	PeerSet::iter()
 		.map(|s| s.get_info(is_authority, &peerset_protocol_names))
 		.collect()

node/service/src/lib.rs

@@ -893,7 +893,7 @@ where
 		grandpa_hard_forks,
 	));
 
-	let (network, system_rpc_tx, network_starter) =
+	let (network, system_rpc_tx, tx_handler_controller, network_starter) =
 		service::build_network(service::BuildNetworkParams {
 			config: &config,
 			client: client.clone(),
@@ -968,6 +968,7 @@ where
 		transaction_pool: transaction_pool.clone(),
 		task_manager: &mut task_manager,
 		system_rpc_tx,
+		tx_handler_controller,
 		telemetry: telemetry.as_mut(),
 	})?;
 

node/test/service/src/lib.rs

@@ -38,10 +38,13 @@ use polkadot_test_runtime::{
 use sc_chain_spec::ChainSpec;
 use sc_client_api::execution_extensions::ExecutionStrategies;
 use sc_network::{
-	config::{NetworkConfiguration, TransportConfig},
+	config::NetworkConfiguration,
 	multiaddr,
 };
-use sc_network_common::service::NetworkStateInfo;
+use sc_network_common::{
+    service::NetworkStateInfo,
+    config::TransportConfig,
+};
 use sc_service::{
 	config::{
 		DatabaseSource, KeystoreConfig, MultiaddrWithPeerId, WasmExecutionMethod,