5.1.1: add tls config

ehttp/Cargo.toml

@@ -49,9 +49,9 @@ serde_json = { version = "1.0", optional = true }
 
 # For compiling natively:
 [target.'cfg(not(target_arch = "wasm32"))'.dependencies]
-# ureq = { version = "2.0", default-features = false, features = ["gzip", "tls_native_certs"] }
-ureq = "2.0"
+ureq = { version = "2.0", default-features = false, features = ["native-tls"] }
 async-channel = { version = "2.0", optional = true }
+native-tls = "0.2.12"
 
 # For compiling to web:
 [target.'cfg(target_arch = "wasm32")'.dependencies]

ehttp/src/native.rs

@@ -1,4 +1,5 @@
 use crate::{Request, Response};
+use std::sync::Arc;
 
 #[cfg(feature = "native-async")]
 use async_channel::{Receiver, Sender};
@@ -23,7 +24,18 @@ use async_channel::{Receiver, Sender};
 /// * A browser extension blocked the request (e.g. ad blocker)
 /// * …
 pub fn fetch_blocking(request: &Request) -> crate::Result<Response> {
-    let mut req = ureq::request(&request.method, &request.url);
+    let tls_connector = Arc::new(
+        native_tls::TlsConnector::builder()
+            .danger_accept_invalid_hostnames(request.danger_accept_invalid_hostnames)
+            .danger_accept_invalid_certs(request.danger_accept_invalid_certs)
+            .build()
+            .unwrap(),
+    );
+
+    let mut req = ureq::builder()
+        .tls_connector(tls_connector)
+        .build()
+        .request(&request.method, &request.url);
 
     for (k, v) in &request.headers {
         req = req.set(k, v);

ehttp/src/streaming/native.rs

@@ -1,4 +1,5 @@
 use std::ops::ControlFlow;
+use std::sync::Arc;
 
 use crate::Request;
 
@@ -9,7 +10,18 @@ pub fn fetch_streaming_blocking(
     request: Request,
     on_data: Box<dyn Fn(crate::Result<Part>) -> ControlFlow<()> + Send>,
 ) {
-    let mut req = ureq::request(&request.method, &request.url);
+    let tls_connector = Arc::new(
+        native_tls::TlsConnector::builder()
+            .danger_accept_invalid_hostnames(request.danger_accept_invalid_hostnames)
+            .danger_accept_invalid_certs(request.danger_accept_invalid_certs)
+            .build()
+            .unwrap(),
+    );
+
+    let mut req = ureq::builder()
+        .tls_connector(tls_connector)
+        .build()
+        .request(&request.method, &request.url);
 
     for (k, v) in &request.headers {
         req = req.set(k, v);
@@ -54,7 +66,7 @@ pub fn fetch_streaming_blocking(
 
     let mut reader = resp.into_reader();
     loop {
-        let mut buf = vec![0; 2048];
+        let mut buf = vec![0; 5120];
         match reader.read(&mut buf) {
             Ok(n) if n > 0 => {
                 // clone data from buffer and clear it