join threads

Cargo.toml

@@ -6,14 +6,14 @@ edition = "2018"
 default-run = "guntrader"
 
 [dependencies]
-reqwest = "0.9.24"
+reqwest = { version = "*", features = ["blocking"] }
 select = "0.4.3"
 chrono = { version = "0.4.10", features = ["serde"] }
 parse_duration = "1.0.1"
-serde = "1.0.104"
-serde_derive = "1.0.104"
-serde_json = "1.0.44"
-rocket = "0.4.2"
+serde = "*"
+serde_derive = "*"
+serde_json = "*"
+rocket = "*"
 lazy_static = "*"
 url = "*"
 urldecode = "0.1.1"

src/query.rs

@@ -144,7 +144,7 @@ fn auction_details(auction: &Auction) -> Auction {
         return updated_auction;
     }
 
-    let client = reqwest::Client::builder()
+    let client = reqwest::blocking::Client::builder()
         // .timeout(Some(core::time::Duration::from_secs(10)))
         .build()
         .unwrap();
@@ -152,9 +152,9 @@ fn auction_details(auction: &Auction) -> Auction {
 
     match client.get(&auction.url).send() {
         Ok(mut resp) => {
-            if !resp.status().is_success() {
-                println!("ERR {:?}", resp.text());
-            }
+            // if !resp.status().is_success() {
+            //     println!("ERR {:?}", &resp.text());
+            // }
 
             let text = resp.text().unwrap_or("".to_string());
 
@@ -206,7 +206,7 @@ fn auctions_from_url(url: &str) -> HashMap<String, Auction> {
     let mut auctions = HashMap::new();
     // dbg!(&url);
 
-    let client = reqwest::Client::builder()
+    let client = reqwest::blocking::Client::builder()
         // .timeout(Some(core::time::Duration::from_secs(8)))
         .build()
         .unwrap();

src/server.rs

@@ -22,7 +22,7 @@ lazy_static! {
 
 
 pub fn proxy(url: &str) -> Vec<u8> {
-    match reqwest::get(url) {
+    match reqwest::blocking::get(url) {
         Ok(mut resp) => {
             // println!("resp = {:?}", resp);
             let mut buf: Vec<u8> = vec![];