diff --git a/bin/dnetview/src/rpc.rs b/bin/dnetview/src/rpc.rs index ab3969a60..7c450544a 100644 --- a/bin/dnetview/src/rpc.rs +++ b/bin/dnetview/src/rpc.rs @@ -33,7 +33,7 @@ pub struct RpcConnect { impl RpcConnect { pub async fn new(url: Url, name: String) -> Result { - let rpc_client = RpcClient::new(url).await?; + let rpc_client = RpcClient::new(url, None).await?; Ok(Self { name, rpc_client }) } diff --git a/bin/drk/src/main.rs b/bin/drk/src/main.rs index 4c47914b4..6af6222e0 100644 --- a/bin/drk/src/main.rs +++ b/bin/drk/src/main.rs @@ -464,7 +464,7 @@ pub struct Drk { impl Drk { async fn new(endpoint: Url) -> Result { - let rpc_client = RpcClient::new(endpoint).await?; + let rpc_client = RpcClient::new(endpoint, None).await?; Ok(Self { rpc_client }) } diff --git a/bin/drk/src/rpc_airdrop.rs b/bin/drk/src/rpc_airdrop.rs index 33316d339..e5164c433 100644 --- a/bin/drk/src/rpc_airdrop.rs +++ b/bin/drk/src/rpc_airdrop.rs @@ -37,7 +37,7 @@ impl Drk { amount: f64, address: PublicKey, ) -> Result { - let rpc_client = RpcClient::new(faucet_endpoint).await?; + let rpc_client = RpcClient::new(faucet_endpoint, None).await?; // First we request a VDF challenge from the faucet let params = json!([format!("{}", address)]); diff --git a/bin/drk/src/rpc_blockchain.rs b/bin/drk/src/rpc_blockchain.rs index ce2b7be14..aa3ee475b 100644 --- a/bin/drk/src/rpc_blockchain.rs +++ b/bin/drk/src/rpc_blockchain.rs @@ -60,7 +60,7 @@ impl Drk { let subscriber = Subscriber::new(); let subscription = subscriber.clone().subscribe().await; - let rpc_client = RpcClient::new(endpoint).await?; + let rpc_client = RpcClient::new(endpoint, None).await?; let req = JsonRequest::new("blockchain.subscribe_blocks", json!([])); task::spawn(async move { rpc_client.subscribe(req, subscriber).await.unwrap() }); @@ -305,7 +305,7 @@ impl Drk { let subscriber = Subscriber::new(); let subscription = subscriber.clone().subscribe().await; - let rpc_client = RpcClient::new(endpoint).await?; + let rpc_client = RpcClient::new(endpoint, None).await?; let req = JsonRequest::new("blockchain.subscribe_err_txs", json!([])); task::spawn(async move { rpc_client.subscribe(req, subscriber).await.unwrap() }); diff --git a/bin/fud/fu/src/main.rs b/bin/fud/fu/src/main.rs index d8cd71527..1f989bb2c 100644 --- a/bin/fud/fu/src/main.rs +++ b/bin/fud/fu/src/main.rs @@ -137,7 +137,7 @@ async fn main() -> Result<()> { let log_config = get_log_config(args.verbose); TermLogger::init(log_level, log_config, TerminalMode::Mixed, ColorChoice::Auto)?; - let rpc_client = RpcClient::new(args.endpoint).await?; + let rpc_client = RpcClient::new(args.endpoint, None).await?; let fu = Fu { rpc_client }; match args.command { diff --git a/bin/genev/genev-cli/src/main.rs b/bin/genev/genev-cli/src/main.rs index ee652ba64..bf186b9ed 100644 --- a/bin/genev/genev-cli/src/main.rs +++ b/bin/genev/genev-cli/src/main.rs @@ -70,7 +70,7 @@ async fn main() -> Result<()> { let log_config = get_log_config(args.verbose); TermLogger::init(log_level, log_config, TerminalMode::Mixed, ColorChoice::Auto)?; - let rpc_client = RpcClient::new(args.endpoint).await?; + let rpc_client = RpcClient::new(args.endpoint, None).await?; let gen = Gen { rpc_client }; match args.command { diff --git a/bin/tau/tau-cli/src/main.rs b/bin/tau/tau-cli/src/main.rs index 583e7861b..27e4505c5 100644 --- a/bin/tau/tau-cli/src/main.rs +++ b/bin/tau/tau-cli/src/main.rs @@ -168,7 +168,7 @@ async fn main() -> Result<()> { let log_config = get_log_config(args.verbose); TermLogger::init(log_level, log_config, TerminalMode::Mixed, ColorChoice::Auto)?; - let rpc_client = RpcClient::new(args.endpoint).await?; + let rpc_client = RpcClient::new(args.endpoint, None).await?; let tau = Tau { rpc_client }; let mut filters = args.filters.clone();