diff --git a/applications/tari_base_node/src/config.rs b/applications/tari_base_node/src/config.rs index 187f5d0391..f327119644 100644 --- a/applications/tari_base_node/src/config.rs +++ b/applications/tari_base_node/src/config.rs @@ -112,6 +112,10 @@ pub struct BaseNodeConfig { impl Default for BaseNodeConfig { fn default() -> Self { + let p2p = P2pConfig { + datastore_path: PathBuf::from("peer_db/base_node"), + ..Default::default() + }; Self { override_from: None, network: Network::LocalNet, @@ -119,7 +123,7 @@ impl Default for BaseNodeConfig { identity_file: PathBuf::from("config/base_node_id.json"), use_libtor: false, tor_identity_file: PathBuf::from("config/tor_id.json"), - p2p: P2pConfig::default(), + p2p, db_type: DatabaseType::Lmdb, lmdb: Default::default(), data_dir: PathBuf::from("data/base_node"), diff --git a/applications/tari_validator_node/src/comms.rs b/applications/tari_validator_node/src/comms.rs index 2bccc1537a..dce7dd44ba 100644 --- a/applications/tari_validator_node/src/comms.rs +++ b/applications/tari_validator_node/src/comms.rs @@ -50,13 +50,13 @@ pub async fn build_service_and_comms_stack( ) -> Result<(ServiceHandles, SubscriptionFactory), ExitError> { let (publisher, peer_message_subscriptions) = pubsub_connector(100, 50); - let mut transport_config = config.validator_node.p2p.transport.clone(); - transport_config.tor.identity = load_from_json(&config.validator_node.tor_identity_file) + let mut p2p_config = config.validator_node.p2p.clone(); + p2p_config.transport.tor.identity = load_from_json(&config.validator_node.tor_identity_file) .map_err(|e| ExitError::new(ExitCode::ConfigError, e))?; let mut handles = StackBuilder::new(shutdown.clone()) .add_initializer(P2pInitializer::new( - config.validator_node.p2p.clone(), + p2p_config.clone(), config.peer_seeds.clone(), // TODO: configurable Network::Dibbler, @@ -73,7 +73,7 @@ pub async fn build_service_and_comms_stack( let comms = setup_p2p_rpc(config, comms, &handles, mempool, db_factory, asset_processor); - let comms = spawn_comms_using_transport(comms, transport_config) + let comms = spawn_comms_using_transport(comms, p2p_config.transport.clone()) .await .map_err(|e| ExitError::new(ExitCode::ConfigError, format!("Could not spawn using transport: {}", e)))?; diff --git a/applications/tari_validator_node/src/config.rs b/applications/tari_validator_node/src/config.rs index 4eb2251dba..8169a10ca5 100644 --- a/applications/tari_validator_node/src/config.rs +++ b/applications/tari_validator_node/src/config.rs @@ -84,6 +84,11 @@ impl ValidatorNodeConfig { impl Default for ValidatorNodeConfig { fn default() -> Self { + let p2p = P2pConfig { + datastore_path: PathBuf::from("peer_db/validator_node"), + ..Default::default() + }; + Self { override_from: None, identity_file: PathBuf::from("validator_node_id.json"), @@ -98,7 +103,7 @@ impl Default for ValidatorNodeConfig { data_dir: PathBuf::from("/data/validator_node"), committee_management_confirmation_time: 10, committee_management_polling_interval: 5, - p2p: P2pConfig::default(), + p2p, grpc_address: Some("/ip4/127.0.0.1/tcp/18144".parse().unwrap()), } } diff --git a/base_layer/wallet/src/config.rs b/base_layer/wallet/src/config.rs index 49d1cc9c8d..0e0f44afd6 100644 --- a/base_layer/wallet/src/config.rs +++ b/base_layer/wallet/src/config.rs @@ -78,9 +78,13 @@ pub struct WalletConfig { impl Default for WalletConfig { fn default() -> Self { + let p2p = P2pConfig { + datastore_path: PathBuf::from("peer_db/wallet"), + ..Default::default() + }; Self { override_from: None, - p2p: Default::default(), + p2p, transaction_service_config: Default::default(), output_manager_service_config: Default::default(), buffer_size: 100,