expose Kademlia replication factor in node CLI

client/cli/src/params/network_params.rs

@@ -28,7 +28,7 @@ use sc_service::{
 	config::{Multiaddr, MultiaddrWithPeerId},
 	ChainSpec, ChainType,
 };
-use std::{borrow::Cow, path::PathBuf};
+use std::{borrow::Cow, path::PathBuf, num::NonZeroUsize};
 
 /// Parameters used to create the network configuration.
 #[derive(Debug, Clone, Args)]
@@ -127,6 +127,10 @@ pub struct NetworkParams {
 	#[arg(long)]
 	pub kademlia_disjoint_query_paths: bool,
 
+	/// Kademlia replication factor.
+	#[arg(long)]
+	pub kademlia_replication_factor: Option<NonZeroUsize>,
+
 	/// Join the IPFS network and serve transactions over bitswap protocol.
 	#[arg(long)]
 	pub ipfs_server: bool,
@@ -238,6 +242,7 @@ impl NetworkParams {
 			enable_dht_random_walk: !self.reserved_only,
 			allow_non_globals_in_dht,
 			kademlia_disjoint_query_paths: self.kademlia_disjoint_query_paths,
+			kademlia_replication_factor: self.kademlia_replication_factor,
 			yamux_window_size: None,
 			ipfs_server: self.ipfs_server,
 			sync_mode: self.sync.into(),

client/network/src/config.rs

@@ -50,7 +50,7 @@ use std::{
 	net::Ipv4Addr,
 	path::{Path, PathBuf},
 	pin::Pin,
-	str::{self, FromStr},
+	str::{self, FromStr}, num::NonZeroUsize,
 };
 
 pub use libp2p::{
@@ -605,6 +605,9 @@ pub struct NetworkConfiguration {
 	/// the presence of potentially adversarial nodes.
 	pub kademlia_disjoint_query_paths: bool,
 
+	/// None will end up using default Kadmelia value.
+	pub kademlia_replication_factor: Option<NonZeroUsize>,
+
 	/// Enable serving block data over IPFS bitswap.
 	pub ipfs_server: bool,
 
@@ -657,6 +660,7 @@ impl NetworkConfiguration {
 			enable_dht_random_walk: true,
 			allow_non_globals_in_dht: false,
 			kademlia_disjoint_query_paths: false,
+			kademlia_replication_factor: None,
 			yamux_window_size: None,
 			ipfs_server: false,
 		}

client/network/src/discovery.rs

@@ -103,6 +103,7 @@ pub struct DiscoveryConfig {
 	enable_mdns: bool,
 	kademlia_disjoint_query_paths: bool,
 	kademlia_protocols: Vec<Vec<u8>>,
+	kademlia_replication_factor: Option<NonZeroUsize>,
 }
 
 impl DiscoveryConfig {
@@ -118,6 +119,7 @@ impl DiscoveryConfig {
 			enable_mdns: false,
 			kademlia_disjoint_query_paths: false,
 			kademlia_protocols: Vec::new(),
+			kademlia_replication_factor: None,
 		}
 	}
 
@@ -184,6 +186,11 @@ impl DiscoveryConfig {
 		self
 	}
 
+	pub fn with_kademlia_replication_factor(&mut self, value: NonZeroUsize) -> &mut Self {
+		self.kademlia_replication_factor = Some(value);
+		self
+	}
+
 	/// Create a `DiscoveryBehaviour` from this config.
 	pub fn finish(self) -> DiscoveryBehaviour {
 		let Self {
@@ -196,10 +203,16 @@ impl DiscoveryConfig {
 			enable_mdns,
 			kademlia_disjoint_query_paths,
 			kademlia_protocols,
+			kademlia_replication_factor,
 		} = self;
 
 		let kademlia = if !kademlia_protocols.is_empty() {
 			let mut config = KademliaConfig::default();
+
+			if let Some(replication_factor) = kademlia_replication_factor {
+				config.set_replication_factor(replication_factor);
+			}
+
 			config.set_protocol_names(kademlia_protocols.into_iter().map(Into::into).collect());
 			// By default Kademlia attempts to insert all peers into its routing table once a
 			// dialing attempt succeeds. In order to control which peer is added, disable the

client/network/src/service.rs

@@ -287,6 +287,10 @@ where
 					params.network_config.kademlia_disjoint_query_paths,
 				);
 
+				if let Some(kademlia_replication_factor) = params.network_config.kademlia_replication_factor {
+					config.with_kademlia_replication_factor(kademlia_replication_factor);
+				}
+
 				match params.network_config.transport {
 					TransportConfig::MemoryOnly => {
 						config.with_mdns(false);