From cf2e9daf9e749e813a688fa2bdd256bb9e7b78cb Mon Sep 17 00:00:00 2001 From: David Craven Date: Wed, 12 Aug 2020 18:41:44 +0200 Subject: [PATCH] Fix port number. --- client/src/lib.rs | 18 ++++++++++-------- src/lib.rs | 2 +- 2 files changed, 11 insertions(+), 9 deletions(-) diff --git a/client/src/lib.rs b/client/src/lib.rs index a335b11c48..2dabb6aee2 100644 --- a/client/src/lib.rs +++ b/client/src/lib.rs @@ -218,8 +218,8 @@ pub struct SubxtClientConfig { pub chain_spec: C, /// Role of the node. pub role: Role, - /// Enable telemetry. - pub enable_telemetry: bool, + /// Enable telemetry on the given port. + pub telemetry: Option, } impl SubxtClientConfig { @@ -238,10 +238,12 @@ impl SubxtClientConfig { wasm_external_transport: None, use_yamux_flow_control: true, }; - let telemetry_endpoints = if self.enable_telemetry { - let endpoints = - TelemetryEndpoints::new(vec![("/ip4/127.0.0.1/tcp/99000/ws".into(), 0)]) - .expect("valid config; qed"); + let telemetry_endpoints = if let Some(port) = self.telemetry { + let endpoints = TelemetryEndpoints::new(vec![( + format!("/ip4/127.0.0.1/tcp/{}/ws", port), + 0, + )]) + .expect("valid config; qed"); Some(endpoints) } else { None @@ -356,7 +358,7 @@ mod tests { keystore: KeystoreConfig::InMemory, chain_spec, role: Role::Light, - enable_telemetry: false, + telemetry: None, }; let client = ClientBuilder::::new() .set_client( @@ -389,7 +391,7 @@ mod tests { keystore: KeystoreConfig::InMemory, chain_spec: test_node::chain_spec::development_config().unwrap(), role: Role::Authority(AccountKeyring::Alice), - enable_telemetry: false, + telemetry: None, }; let client = ClientBuilder::::new() .set_client( diff --git a/src/lib.rs b/src/lib.rs index b790083cd8..b98755625f 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -588,7 +588,7 @@ mod tests { }, chain_spec: test_node::chain_spec::development_config().unwrap(), role: Role::Authority(key), - enable_telemetry: false, + telemetry: None, }; let client = ClientBuilder::new() .set_client(