Skip to content
This repository has been archived by the owner on Nov 15, 2023. It is now read-only.

Make network_config_path an Option #5661

Merged
merged 5 commits into from
Apr 17, 2020
Merged
Show file tree
Hide file tree
Changes from 4 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion client/cli/src/commands/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -173,7 +173,7 @@ macro_rules! substrate_cli_subcommands {
&self,
chain_spec: &::std::boxed::Box<dyn ::sc_service::ChainSpec>,
is_dev: bool,
net_config_dir: &::std::path::PathBuf,
net_config_dir: Option<::std::path::PathBuf>,
cecton marked this conversation as resolved.
Show resolved Hide resolved
client_id: &str,
node_name: &str,
node_key: ::sc_service::config::NodeKeyConfig,
Expand Down
4 changes: 2 additions & 2 deletions client/cli/src/config.rs
Original file line number Diff line number Diff line change
Expand Up @@ -110,7 +110,7 @@ pub trait CliConfiguration: Sized {
&self,
chain_spec: &Box<dyn ChainSpec>,
is_dev: bool,
net_config_dir: &PathBuf,
net_config_dir: Option<PathBuf>,
client_id: &str,
node_name: &str,
node_key: NodeKeyConfig,
Expand Down Expand Up @@ -405,7 +405,7 @@ pub trait CliConfiguration: Sized {
network: self.network_config(
&chain_spec,
is_dev,
&net_config_dir,
Some(net_config_dir),
client_id.as_str(),
self.node_name()?.as_str(),
node_key,
Expand Down
4 changes: 2 additions & 2 deletions client/cli/src/params/network_params.rs
Original file line number Diff line number Diff line change
Expand Up @@ -100,7 +100,7 @@ impl NetworkParams {
&self,
chain_spec: &Box<dyn ChainSpec>,
is_dev: bool,
net_config_path: &PathBuf,
net_config_path: Option<PathBuf>,
client_id: &str,
node_name: &str,
node_key: NodeKeyConfig,
Expand All @@ -117,7 +117,7 @@ impl NetworkParams {

NetworkConfiguration {
boot_nodes,
net_config_path: net_config_path.clone(),
net_config_path,
reserved_nodes: self.reserved_nodes.clone(),
non_reserved_mode: if self.reserved_only {
NonReservedPeerMode::Deny
Expand Down
10 changes: 5 additions & 5 deletions client/network/src/config.rs
Original file line number Diff line number Diff line change
Expand Up @@ -315,7 +315,7 @@ impl From<multiaddr::Error> for ParseErr {
#[derive(Clone, Debug)]
pub struct NetworkConfiguration {
/// Directory path to store network-specific configuration. None means nothing will be saved.
pub net_config_path: PathBuf,
pub net_config_path: Option<PathBuf>,
/// Multiaddresses to listen for incoming connections.
pub listen_addresses: Vec<Multiaddr>,
/// Multiaddresses to advertise. Detected automatically if empty.
Expand Down Expand Up @@ -351,10 +351,10 @@ impl NetworkConfiguration {
node_name: SN,
client_version: SV,
node_key: NodeKeyConfig,
net_config_path: &PathBuf,
net_config_path: Option<PathBuf>,
) -> Self {
NetworkConfiguration {
net_config_path: net_config_path.clone(),
net_config_path,
listen_addresses: Vec::new(),
public_addresses: Vec::new(),
boot_nodes: Vec::new(),
Expand Down Expand Up @@ -384,7 +384,7 @@ impl NetworkConfiguration {
"test-node",
"test-client",
Default::default(),
&std::env::current_dir().expect("current directory must exist"),
None,
);

config.listen_addresses = vec![
Expand All @@ -402,7 +402,7 @@ impl NetworkConfiguration {
"test-node",
"test-client",
Default::default(),
&std::env::current_dir().expect("current directory must exist"),
None,
);

config.listen_addresses = vec![
Expand Down
4 changes: 3 additions & 1 deletion client/network/src/service.rs
Original file line number Diff line number Diff line change
Expand Up @@ -184,7 +184,9 @@ impl<B: BlockT + 'static, H: ExHashT> NetworkWorker<B, H> {
pub fn new(params: Params<B, H>) -> Result<NetworkWorker<B, H>, Error> {
let (to_worker, from_worker) = tracing_unbounded("mpsc_network_worker");

fs::create_dir_all(&params.network_config.net_config_path)?;
if let Some(path) = params.network_config.net_config_path {
fs::create_dir_all(&path)?;
}

// List of multiaddresses that we know in the network.
let mut known_addresses = Vec::new();
Expand Down
4 changes: 2 additions & 2 deletions client/network/test/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -607,7 +607,7 @@ pub trait TestNetFactory: Sized {
"test-node",
"test-client",
Default::default(),
&std::env::current_dir().expect("current directory must exist"),
None,
);
network_config.transport = TransportConfig::MemoryOnly;
network_config.listen_addresses = vec![listen_addr.clone()];
Expand Down Expand Up @@ -683,7 +683,7 @@ pub trait TestNetFactory: Sized {
"test-node",
"test-client",
Default::default(),
&std::env::current_dir().expect("current directory must exist"),
None,
);
network_config.transport = TransportConfig::MemoryOnly;
network_config.listen_addresses = vec![listen_addr.clone()];
Expand Down
5 changes: 2 additions & 3 deletions client/service/test/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -143,12 +143,11 @@ fn node_config<G: RuntimeGenesis + 'static, E: ChainSpecExtension + Clone + 'sta
{
let root = root.path().join(format!("node-{}", index));

let net_config_path = root.join("network");

let mut network_config = NetworkConfiguration::new(
format!("Node {}", index),
"network/test/0.1",
Default::default(), &net_config_path,
Default::default(),
None,
);

network_config.listen_addresses.push(
Expand Down
2 changes: 1 addition & 1 deletion utils/browser/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -49,7 +49,7 @@ where
format!("{} (Browser)", name),
"unknown",
Default::default(),
&std::path::PathBuf::new(),
None,
);
network.boot_nodes = chain_spec.boot_nodes().to_vec();
network.transport = TransportConfig::Normal {
Expand Down