Replace reqwest with http and hyper, and tower

Cargo.toml

@@ -17,7 +17,6 @@ keywords = ["github", "github-api"]
 targets = ["x86_64-unknown-linux-gnu"]
 
 [dependencies]
-reqwest = { version = "0.11.10", default-features = false, features = ["json"] }
 serde = { version = "1.0.126", features = ["derive"] }
 serde_json = "1.0.64"
 serde_path_to_error = "0.1.4"
@@ -33,33 +32,40 @@ arc-swap = "1.3.0"
 base64 = "0.21.0"
 bytes = "1.0.1"
 jsonwebtoken = "8"
-futures-core = { version = "0.3.15", optional = true }
-futures-util = { version = "0.3.15", optional = true }
+futures = { version = "0.3.15" }
 secrecy = "0.8.0"
 cfg-if = "1.0.0"
 either = "1.8.0"
-tracing = "0.1"
+hyper = { version = "0.14.13", features = ["client", "http1", "stream", "tcp"] }
+http = "0.2.5"
+tower-http = { version = "0.3.2", features = ["map-response-body", "trace"] }
+hyper-timeout = {version = "0.4.1", optional = true }
+http-body = "0.4.5"
+tower = { version = "0.4.13", default-features = false, features = ["util", "buffer"] }
+hyper-rustls = { version = "0.23.2", optional = true }
+tracing = { version = "0.1.37", features = ["log"], optional = true }
+serde_urlencoded = "0.7.1"
+pin-project = "1.0.12"
+tokio = { version = "1.17.0", default-features = false, optional = true }
+futures-core = { version = "0.3.15", optional = true }
+futures-util = { version = "0.3.15", optional = true }
+hyper-tls = { version = "0.5.0", optional = true }
+reqwest = { version = "0.11.10", default-features = false, features = ["json"] }
 
+rustls-pemfile = { version = "1.0.0", optional = true }
 [dev-dependencies]
 tokio = { version = "1.17.0", default-features = false, features = [
     "macros",
     "rt-multi-thread",
     "time",
 ] }
+tokio-test = "0.4.2"
 wiremock = "0.5.3"
 
 [features]
-default = ["native-tls"]
-rustls = ["rustls-tls"]  # Legacy support (<=0.17.0)
-
-# Enables native-tls specific functionality not available by default.
-native-tls = ["reqwest/native-tls"]
-native-tls-alpn = ["reqwest/native-tls-alpn"]
-native-tls-vendored = ["reqwest/native-tls-vendored"]
-
-rustls-tls = ["reqwest/rustls-tls"]
-rustls-tls-manual-roots = ["reqwest/rustls-tls-manual-roots"]
-rustls-tls-webpki-roots = ["reqwest/rustls-tls-webpki-roots"]
-rustls-tls-native-roots = ["reqwest/rustls-tls-native-roots"]
+default = ["tls", "timeout", "tracing", "retry"]
 
-stream = ["futures-core", "futures-util", "reqwest/stream"]
+retry = ["tower/retry", "futures-util"]
+tls = ["hyper-tls"]
+timeout = ["hyper-timeout", "tokio", "tower/timeout"]
+stream = ["futures-core", "futures-util", "hyper/stream"]

README.md

@@ -125,14 +125,13 @@ the request.
 
 ```rust
 let octocrab = octocrab::instance();
-let response =  octocrab
-    ._get("https://api.github.com/organizations", None::<&()>)
+let response = octocrab
+    ._get("https://api.github.com/organizations")
     .await?;
 
-// You can also use `Octocrab::absolute_url` if you want to still to go to
-// the same base.
+// You can also use `Uri::builder().authority("<my custom base>").path_and_query("<my custom path>")` if you want to customize the base uri and path.
 let response =  octocrab
-    ._get(octocrab.absolute_url("/organizations")?, None::<&()>)
+    ._get(Uri::builder().path_and_query("/organizations").build().expect("valid uri"))
     .await?;
 ```
 

examples/custom_client.rs

@@ -0,0 +1,41 @@
+use http::header::USER_AGENT;
+use http::Uri;
+use hyper_tls::HttpsConnector;
+
+use octocrab::service::middleware::base_uri::BaseUriLayer;
+use octocrab::service::middleware::extra_headers::ExtraHeadersLayer;
+use octocrab::{AuthState, OctocrabBuilder};
+use std::sync::Arc;
+
+#[tokio::main]
+async fn main() -> octocrab::Result<()> {
+    let client = hyper::Client::builder().build(HttpsConnector::new());
+    let octocrab = OctocrabBuilder::new_empty()
+        .with_service(client)
+        .with_layer(&BaseUriLayer::new(Uri::from_static(
+            "https://api.github.com",
+        )))
+        .with_layer(&ExtraHeadersLayer::new(Arc::new(vec![(
+            USER_AGENT,
+            "octocrab".parse().unwrap(),
+        )])))
+        .with_auth(AuthState::None)
+        .build()
+        .unwrap();
+
+    let repo = octocrab.repos("rust-lang", "rust").get().await?;
+
+    let repo_metrics = octocrab
+        .repos("rust-lang", "rust")
+        .get_community_profile_metrics()
+        .await?;
+
+    println!(
+        "{} has {} stars and {}% health percentage",
+        repo.full_name.unwrap(),
+        repo.stargazers_count.unwrap_or(0),
+        repo_metrics.health_percentage
+    );
+
+    Ok(())
+}

examples/device_flow.rs

@@ -1,12 +1,12 @@
 use either::Either;
-use reqwest::header::ACCEPT;
+use http::header::ACCEPT;
 use std::time::Duration;
 
 #[tokio::main]
 async fn main() -> octocrab::Result<()> {
     let client_id = secrecy::Secret::from(std::env::var("GITHUB_CLIENT_ID").unwrap());
     let crab = octocrab::Octocrab::builder()
-        .base_url("https://github.com")?
+        .base_uri("https://github.com")?
         .add_header(ACCEPT, "application/json".to_string())
         .build()?;
 
@@ -41,5 +41,5 @@ async fn main() -> octocrab::Result<()> {
     };
 
     println!("Authorization succeeded with access to {:?}", auth.scope);
-    return Ok(());
+    Ok(())
 }

examples/get_content.rs

@@ -12,10 +12,7 @@ async fn main() -> octocrab::Result<()> {
         .send()
         .await?;
 
-    println!(
-        "{} files/dirs in the repo root",
-        content.items.into_iter().count()
-    );
+    println!("{} files/dirs in the repo root", content.items.len());
 
     Ok(())
 }

examples/github_app_authentication.rs

@@ -18,6 +18,6 @@ async fn main() -> octocrab::Result<()> {
 }
 
 fn read_env_var(var_name: &str) -> String {
-    let err = format!("Missing environment variable: {}", var_name);
+    let err = format!("Missing environment variable: {var_name}");
     std::env::var(var_name).expect(&err)
 }

examples/github_app_authentication_manual.rs

@@ -46,6 +46,6 @@ async fn main() -> octocrab::Result<()> {
 }
 
 fn read_env_var(var_name: &str) -> String {
-    let err = format!("Missing environment variable: {}", var_name);
+    let err = format!("Missing environment variable: {var_name}");
     std::env::var(var_name).expect(&err)
 }

examples/paging_results.rs

@@ -17,7 +17,7 @@ async fn main() -> octocrab::Result<()> {
         prs.extend(new_page.take_items());
 
         for pr in prs.drain(..) {
-            println!("{:?}", pr);
+            println!("{pr:?}");
         }
 
         current_page = new_page;

examples/print_license.rs

@@ -5,7 +5,7 @@ async fn main() -> octocrab::Result<()> {
         .license()
         .await?;
 
-    println!("{:#?}", license);
+    println!("{license:#?}");
 
     Ok(())
 }

examples/print_pr_diff.rs

@@ -5,7 +5,7 @@ async fn main() -> octocrab::Result<()> {
         .get_diff(72033)
         .await?;
 
-    println!("{}", diff);
+    println!("{diff}");
 
     Ok(())
 }

examples/search_issues.rs

@@ -10,8 +10,8 @@ async fn main() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
         .send()
         .await
     {
-        Ok(page) => println!("{:#?}", page),
-        Err(error) => println!("{:#?}", error),
+        Ok(page) => println!("{page:#?}"),
+        Err(error) => println!("{error:#?}"),
     }
 
     Ok(())

examples/update_pull_request_branch.rs

@@ -20,7 +20,7 @@ async fn main() -> octocrab::Result<()> {
         .update_branch(200)
         .await?;
 
-    println!("Result of pull request update: {}", update,);
+    println!("Result of pull request update: {update}",);
 
     Ok(())
 }