use reqwest

Cargo.toml

@@ -29,8 +29,7 @@ cached = "0.30"
 tracing-subscriber = { version = "0.3", features = ["fmt", "local-time"] }
 time = { version = "0.3", features = ["macros", "local-offset"] }
 dashmap = "5.2"
-hyper = { version = "0.14", features = ["client", "http1"] }
-hyper-tls = { version = "0.5", features = ["vendored"] }
+reqwest = { version = "0.11", features = ["native-tls-vendored"] }
 chrono = "0.4"
 xml-rs = "0.8"
 async-recursion = "1.0.0"

src/error.rs

@@ -27,8 +27,8 @@ pub enum RCError {
     PB(#[from] prost::DecodeError),
     #[error("rq error, {0}")]
     RQ(#[from] RQError),
-    #[error("hyper error, {0}")]
-    Hyper(#[from] hyper::Error),
+    #[error("reqwest error, {0}")]
+    Reqwest(#[from] reqwest::Error),
     #[error("base64 decode error, {0}")]
     Base64Decode(#[from] base64::DecodeError),
     #[error("invalid uri error, {0}")]

src/util/uri_reader.rs

@@ -1,4 +1,5 @@
-use hyper::{Body, Client, Request};
+use std::time::Duration;
+
 use tokio::io::AsyncReadExt;
 
 use crate::error::{RCError, RCResult};
@@ -17,13 +18,16 @@ pub async fn get_binary(uri: &str) -> RCResult<Vec<u8>> {
 }
 
 pub async fn http_get(uri: &str) -> RCResult<Vec<u8>> {
-    let cli = Client::builder().build::<_, Body>(hyper_tls::HttpsConnector::new());
-    let req = Request::builder().uri(uri).body(Body::empty())?;
-    let resp = cli.request(req).await?;
-    hyper::body::to_bytes(resp.into_body())
+    reqwest::Client::builder()
+        .timeout(Duration::from_secs(60))
+        .build()?
+        .get(uri)
+        .send()
+        .await?
+        .bytes()
         .await
         .map(|b| b.to_vec())
-        .map_err(crate::error::RCError::Hyper)
+        .map_err(RCError::from)
 }
 
 pub async fn read_binary_file(path: &str) -> RCResult<Vec<u8>> {