Updated Reqwest

Cargo.toml

@@ -13,7 +13,7 @@ log = "0.4"
 regex = "1"
 structopt = "0.3"
 crates-index-diff = "7"
-reqwest = "0.9"
+reqwest = { version = "0.10.6", features = ["blocking"] } # TODO: Remove blocking when async is ready
 semver = "0.9"
 slug = "=0.1.1"
 env_logger = "0.7"

src/index/api.rs

@@ -40,17 +40,19 @@ impl RegistryCrateData {
     }
 }
 
-fn client() -> Result<reqwest::Client> {
+fn client() -> Result<reqwest::blocking::Client> {
     let headers = vec![
         (USER_AGENT, HeaderValue::from_static(APP_USER_AGENT)),
         (ACCEPT, HeaderValue::from_static("application/json")),
     ]
     .into_iter()
     .collect();
 
-    Ok(reqwest::Client::builder()
+    let client = reqwest::blocking::Client::builder()
         .default_headers(headers)
-        .build()?)
+        .build()?;
+
+    Ok(client)
 }
 
 /// Get release_time, yanked and downloads from the registry's API

src/test/mod.rs

@@ -6,9 +6,14 @@ use failure::Error;
 use log::error;
 use once_cell::unsync::OnceCell;
 use postgres::Connection;
-use reqwest::{Client, Method, RequestBuilder};
-use std::panic;
-use std::sync::{Arc, Mutex, MutexGuard};
+use reqwest::{
+    blocking::{Client, RequestBuilder},
+    Method,
+};
+use std::{
+    panic,
+    sync::{Arc, Mutex, MutexGuard},
+};
 
 pub(crate) fn wrapper(f: impl FnOnce(&TestEnvironment) -> Result<(), Error>) {
     let _ = dotenv::dotenv();

src/utils/github_updater.rs

@@ -77,10 +77,8 @@ fn get_github_fields(path: &str) -> Result<GitHubFields> {
     use serde_json::Value;
 
     let body = {
-        use reqwest::header::USER_AGENT;
-        use reqwest::{Client, StatusCode};
-        use std::env;
-        use std::io::Read;
+        use reqwest::{blocking::Client, header::USER_AGENT, StatusCode};
+        use std::{env, io::Read};
 
         let client = Client::new();
         let mut body = String::new();

src/utils/pubsubhubbub.rs

@@ -1,11 +1,14 @@
+use reqwest::{
+    blocking::{Client, Response},
+    Result,
+};
 use std::collections::HashMap;
 
-use reqwest::*;
-
 fn ping_hub(url: &str) -> Result<Response> {
     let mut params = HashMap::with_capacity(2);
     params.insert("hub.mode", "publish");
     params.insert("hub.url", "https://docs.rs/releases/feed");
+
     let client = Client::new();
     client.post(url).form(&params).send()
 }