build(deps): Update hyper to 1.1

This builds and should work, further testing might be needed to make sure there are no regressions.

Cargo.toml

@@ -22,7 +22,7 @@ repldb = ["database"]
 database = ["dep:sea-orm", "dep:sea-query", "dep:migration", "dep:entity"]
 replspace = []
 fun-stuff = ["dep:chrono", "dep:chrono-tz"]
-verify_connections = ["dep:hyper", "dep:hyper-tls"]
+verify_connections = ["dep:hyper", "dep:hyper-tls", "dep:hyper-util", "dep:http-body-util"]
 
 [dependencies]
 goval = { path = "protobuf", package = "protobuf" }
@@ -54,6 +54,8 @@ migration = { path = "migration", optional = true}
 entity = { path = "entity", optional = true}
 sea-query = { version = "0.28.5", optional = true }
 pasetors = { version = "0.6.7", default-features = false, features = ["v2"] }
-hyper = { version = "0.14.26", features = ["http1", "http2", "client"], optional = true }
-hyper-tls = { version = "0.5.0", optional = true }
+hyper = { version = "1.1.0", features = ["http1", "http2", "client"], optional = true }
+hyper-util = { version = "0.1.2", features = ["client", "client-legacy", "http1", "http2"], optional = true }
+hyper-tls = { version = "0.6.0", optional = true }
+http-body-util = { version = "0.1.0", optional = true }
 anyhow = "1.0.71"

src/parse_paseto.rs

@@ -41,15 +41,23 @@ fn parse_noverify(input: &str) -> Result<(Vec<u8>, bool)> {
 
 #[cfg(feature = "verify_connections")]
 async fn init_keys() -> Result<std::collections::HashMap<String, String>> {
+    use http_body_util::{BodyExt, Collected};
+    use hyper_tls::HttpsConnector;
+    use hyper_util::client::legacy::{connect::HttpConnector, Client};
+    use hyper_util::rt::TokioExecutor;
+
     let key_get = std::env::var("HOMEVAL_PASETO_KEY_URL")?;
 
-    let https = hyper_tls::HttpsConnector::new();
-    let client = hyper::Client::builder().build::<_, hyper::Body>(https);
+    let https = HttpsConnector::new();
+    let client: Client<HttpsConnector<HttpConnector>, Collected<_>> =
+        Client::builder(TokioExecutor::new())
+            .build::<HttpsConnector<HttpConnector>, Collected<prost::bytes::Bytes>>(https);
+
+    let mut _body = client.get(hyper::Uri::try_from(key_get)?).await?;
 
-    let _body = client.get(hyper::Uri::try_from(key_get)?).await?;
-    let body = hyper::body::to_bytes(_body).await?.to_vec();
+    let body = _body.body_mut().collect().await?.to_bytes();
 
-    Ok(serde_json::from_slice(body.as_slice())?)
+    Ok(serde_json::from_slice(&body)?)
 }
 
 #[cfg(feature = "verify_connections")]