Added cert validation parameters to all functions

main
Mauro D 2023-04-19 09:57:16 +00:00
parent 998e1ca79c
commit 953959f344
4 changed files with 5 additions and 1 deletions

View File

@ -56,6 +56,7 @@ impl Client {
Client::handle_error( Client::handle_error(
HttpClient::builder() HttpClient::builder()
.timeout(Duration::from_millis(self.timeout())) .timeout(Duration::from_millis(self.timeout()))
.danger_accept_invalid_certs(self.accept_invalid_certs)
.redirect(self.redirect_policy()) .redirect(self.redirect_policy())
.default_headers(headers) .default_headers(headers)
.build()? .build()?

View File

@ -65,6 +65,7 @@ impl Client {
&Client::handle_error( &Client::handle_error(
HttpClient::builder() HttpClient::builder()
.timeout(Duration::from_millis(self.timeout())) .timeout(Duration::from_millis(self.timeout()))
.danger_accept_invalid_certs(self.accept_invalid_certs)
.redirect(self.redirect_policy()) .redirect(self.redirect_policy())
.default_headers(self.headers().clone()) .default_headers(self.headers().clone())
.build()? .build()?

View File

@ -64,7 +64,7 @@ pub struct Client {
headers: header::HeaderMap, headers: header::HeaderMap,
default_account_id: String, default_account_id: String,
timeout: u64, timeout: u64,
accept_invalid_certs: bool, pub(crate) accept_invalid_certs: bool,
#[cfg(feature = "websockets")] #[cfg(feature = "websockets")]
pub(crate) authorization: String, pub(crate) authorization: String,
@ -309,6 +309,7 @@ impl Client {
&Client::handle_error( &Client::handle_error(
HttpClient::builder() HttpClient::builder()
.timeout(Duration::from_millis(DEFAULT_TIMEOUT_MS)) .timeout(Duration::from_millis(DEFAULT_TIMEOUT_MS))
.danger_accept_invalid_certs(self.accept_invalid_certs)
.redirect(self.redirect_policy()) .redirect(self.redirect_policy())
.default_headers(self.headers.clone()) .default_headers(self.headers.clone())
.build()? .build()?

View File

@ -74,6 +74,7 @@ impl Client {
let mut stream = Client::handle_error( let mut stream = Client::handle_error(
reqwest::Client::builder() reqwest::Client::builder()
.connect_timeout(Duration::from_millis(self.timeout())) .connect_timeout(Duration::from_millis(self.timeout()))
.danger_accept_invalid_certs(self.accept_invalid_certs)
.redirect(self.redirect_policy()) .redirect(self.redirect_policy())
.default_headers(headers) .default_headers(headers)
.build()? .build()?