git.delta.rocks / unique-network / refs/commits / e6ed5f4e38db

43type FullBackend = sc_service::TFullBackend<Block>;43type FullBackend = sc_service::TFullBackend<Block>;
4444
45/// Full client dependencies.45/// Full client dependencies.
46pub struct FullDeps<C, P, SC> {46pub struct FullDeps<C, P> {
47	/// The client instance to use.47	/// The client instance to use.
48	pub client: Arc<C>,48	pub client: Arc<C>,
49	/// Transaction pool instance.49	/// Transaction pool instance.
50	pub pool: Arc<P>,50	pub pool: Arc<P>,
51	/// The SelectChain Strategy
52	pub select_chain: SC,
53	/// Whether to deny unsafe calls51	/// Whether to deny unsafe calls
54	pub deny_unsafe: DenyUnsafe,52	pub deny_unsafe: DenyUnsafe,
55
56	/// Runtime identification (read from the chain spec)
57	pub runtime_id: RuntimeId,
58	/// Executor params for PoV estimating53	/// Executor params for PoV estimating
59	#[cfg(feature = "pov-estimate")]54	#[cfg(feature = "pov-estimate")]
60	pub exec_params: uc_rpc::pov_estimate::ExecutorParams,55	pub exec_params: uc_rpc::pov_estimate::ExecutorParams,
64}59}
6560
66/// Instantiate all Full RPC extensions.61/// Instantiate all Full RPC extensions.
67pub fn create_full<C, P, SC, R, B>(62pub fn create_full<C, P, R, B>(
68	io: &mut RpcModule<()>,63	io: &mut RpcModule<()>,
69	deps: FullDeps<C, P, SC>,64	deps: FullDeps<C, P>,
70) -> Result<(), Box<dyn std::error::Error + Send + Sync>>65) -> Result<(), Box<dyn std::error::Error + Send + Sync>>
71where66where
72	C: ProvideRuntimeApi<Block> + StorageProvider<Block, B> + AuxStore,67	C: ProvideRuntimeApi<Block> + StorageProvider<Block, B> + AuxStore,
93	let FullDeps {88	let FullDeps {
94		client,89		client,
95		pool,90		pool,
96		select_chain: _,
97		deny_unsafe,91		deny_unsafe,
98
99		runtime_id: _,
10092
101		#[cfg(feature = "pov-estimate")]93		#[cfg(feature = "pov-estimate")]
102		exec_params,94		exec_params,

--- a/node/cli/src/service.rs
+++ b/node/cli/src/service.rs
@@ -36,8 +36,8 @@
 use cumulus_client_consensus_common::ParachainBlockImport as TParachainBlockImport;
 use cumulus_client_consensus_proposer::Proposer;
 use cumulus_client_service::{
-	build_relay_chain_interface, prepare_node_config, start_relay_chain_tasks, DARecoveryProfile,
-	StartRelayChainTasksParams,
+	build_relay_chain_interface, prepare_node_config, start_relay_chain_tasks,
+	CollatorSybilResistance, DARecoveryProfile, StartRelayChainTasksParams,
 };
 use cumulus_primitives_core::ParaId;
 use cumulus_primitives_parachain_inherent::ParachainInherentData;
@@ -85,10 +85,7 @@
 use cumulus_primitives_core::PersistedValidationData;
 use cumulus_test_relay_sproof_builder::RelayStateSproofBuilder;
 
-use crate::{
-	chain_spec::RuntimeIdentification,
-	rpc::{create_eth, create_full, EthDeps, FullDeps},
-};
+use crate::rpc::{create_eth, create_full, EthDeps, FullDeps};
 
 /// Unique native executor instance.
 #[cfg(feature = "unique-runtime")]
@@ -428,10 +425,6 @@
 	)
 	.await
 	.map_err(|e| sc_service::Error::Application(Box::new(e) as Box<_>))?;
-
-	// Aura is sybil-resistant, collator-selection is generally too.
-	let block_announce_validator =
-		cumulus_client_network::AssumeSybilResistance::allow_seconded_messages();
 
 	let validator = parachain_config.role.is_authority();
 	let prometheus_registry = parachain_config.prometheus_registry().cloned();
@@ -439,23 +432,19 @@
 	let import_queue_service = params.import_queue.service();
 
 	let (network, system_rpc_tx, tx_handler_controller, start_network, sync_service) =
-		sc_service::build_network(sc_service::BuildNetworkParams {
-			config: &parachain_config,
+		cumulus_client_service::build_network(cumulus_client_service::BuildNetworkParams {
+			parachain_config: &parachain_config,
 			net_config,
 			client: client.clone(),
 			transaction_pool: transaction_pool.clone(),
+			para_id,
 			spawn_handle: task_manager.spawn_handle(),
+			relay_chain_interface: relay_chain_interface.clone(),
 			import_queue: params.import_queue,
-			block_announce_validator_builder: Some(Box::new(|_| {
-				Box::new(block_announce_validator)
-			})),
-			warp_sync_params: None,
-			block_relay: None,
-		})?;
-
-	let select_chain = params.select_chain.clone();
-
-	let runtime_id = parachain_config.chain_spec.runtime_id();
+			// Aura is sybil-resistant, collator-selection is generally too.
+			sybil_resistance_level: CollatorSybilResistance::Resistant,
+		})
+		.await?;
 
 	// Frontier
 	let fee_history_cache: FeeHistoryCache = Arc::new(Mutex::new(BTreeMap::new()));
@@ -508,9 +497,7 @@
 				fee_history_cache,
 				eth_block_data_cache,
 				network,
-				runtime_id,
 				transaction_pool,
-				select_chain,
 				overrides,
 			);
 
@@ -521,7 +508,6 @@
 
 			let full_deps = FullDeps {
 				client: client.clone(),
-				runtime_id,
 
 				#[cfg(feature = "pov-estimate")]
 				exec_params: uc_rpc::pov_estimate::ExecutorParams {
@@ -536,10 +522,9 @@
 
 				deny_unsafe,
 				pool: transaction_pool.clone(),
-				select_chain,
 			};
 
-			create_full::<_, _, _, Runtime, _>(&mut rpc_handle, full_deps)?;
+			create_full::<_, _, Runtime, _>(&mut rpc_handle, full_deps)?;
 
 			let eth_deps = EthDeps {
 				client,
@@ -1044,8 +1029,6 @@
 	#[cfg(feature = "pov-estimate")]
 	let rpc_backend = backend.clone();
 
-	let runtime_id = config.chain_spec.runtime_id();
-
 	// Frontier
 	let fee_history_cache: FeeHistoryCache = Arc::new(Mutex::new(BTreeMap::new()));
 	let fee_history_limit = 2048;
@@ -1097,9 +1080,7 @@
 				fee_history_cache,
 				eth_block_data_cache,
 				network,
-				runtime_id,
 				transaction_pool,
-				select_chain,
 				overrides,
 			);
 
@@ -1109,8 +1090,6 @@
 			let mut rpc_module = RpcModule::new(());
 
 			let full_deps = FullDeps {
-				runtime_id,
-
 				#[cfg(feature = "pov-estimate")]
 				exec_params: uc_rpc::pov_estimate::ExecutorParams {
 					wasm_method: config.wasm_method,
@@ -1125,10 +1104,9 @@
 				deny_unsafe,
 				client: client.clone(),
 				pool: transaction_pool.clone(),
-				select_chain,
 			};
 
-			create_full::<_, _, _, Runtime, _>(&mut rpc_module, full_deps)?;
+			create_full::<_, _, Runtime, _>(&mut rpc_module, full_deps)?;
 
 			let eth_deps = EthDeps {
 				client,