From 953959f344dd759553f76de653cbf6c085aa35c4 Mon Sep 17 00:00:00 2001
From: Mauro D <mauro@stalw.art>
Date: Wed, 19 Apr 2023 09:57:16 +0000
Subject: [PATCH] Added cert validation parameters to all functions

---
 src/blob/download.rs       | 1 +
 src/blob/upload.rs         | 1 +
 src/client.rs              | 3 ++-
 src/event_source/stream.rs | 1 +
 4 files changed, 5 insertions(+), 1 deletion(-)

diff --git a/src/blob/download.rs b/src/blob/download.rs
index 3a53ab0..5369d1c 100644
--- a/src/blob/download.rs
+++ b/src/blob/download.rs
@@ -56,6 +56,7 @@ impl Client {
         Client::handle_error(
             HttpClient::builder()
                 .timeout(Duration::from_millis(self.timeout()))
+                .danger_accept_invalid_certs(self.accept_invalid_certs)
                 .redirect(self.redirect_policy())
                 .default_headers(headers)
                 .build()?
diff --git a/src/blob/upload.rs b/src/blob/upload.rs
index 74b6a69..47e4ce9 100644
--- a/src/blob/upload.rs
+++ b/src/blob/upload.rs
@@ -65,6 +65,7 @@ impl Client {
             &Client::handle_error(
                 HttpClient::builder()
                     .timeout(Duration::from_millis(self.timeout()))
+                    .danger_accept_invalid_certs(self.accept_invalid_certs)
                     .redirect(self.redirect_policy())
                     .default_headers(self.headers().clone())
                     .build()?
diff --git a/src/client.rs b/src/client.rs
index 1742f11..360de2b 100644
--- a/src/client.rs
+++ b/src/client.rs
@@ -64,7 +64,7 @@ pub struct Client {
     headers: header::HeaderMap,
     default_account_id: String,
     timeout: u64,
-    accept_invalid_certs: bool,
+    pub(crate) accept_invalid_certs: bool,
 
     #[cfg(feature = "websockets")]
     pub(crate) authorization: String,
@@ -309,6 +309,7 @@ impl Client {
             &Client::handle_error(
                 HttpClient::builder()
                     .timeout(Duration::from_millis(DEFAULT_TIMEOUT_MS))
+                    .danger_accept_invalid_certs(self.accept_invalid_certs)
                     .redirect(self.redirect_policy())
                     .default_headers(self.headers.clone())
                     .build()?
diff --git a/src/event_source/stream.rs b/src/event_source/stream.rs
index 1fdf7a7..ab5747a 100644
--- a/src/event_source/stream.rs
+++ b/src/event_source/stream.rs
@@ -74,6 +74,7 @@ impl Client {
         let mut stream = Client::handle_error(
             reqwest::Client::builder()
                 .connect_timeout(Duration::from_millis(self.timeout()))
+                .danger_accept_invalid_certs(self.accept_invalid_certs)
                 .redirect(self.redirect_policy())
                 .default_headers(headers)
                 .build()?