Migrated Exit Manager and QueryExitDebts to async await.

Removed the futures based http client in these handlers and replaced them with the async http client 'awc'
althea-net · Sep 2, 2021 · 093e1ab · 093e1ab
1 parent ddf1674
commit 093e1ab
Show file tree

Hide file tree

Showing 7 changed files with 407 additions and 410 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/rita_client/Cargo.toml b/rita_client/Cargo.toml
@@ -35,6 +35,8 @@ sodiumoxide = "0.2"
 clu = { path = "../clu" }
 web30 = {git = "https://github.com/althea-net/web30", rev = "a600b8b8ebf2c49badee6b65ac90a56bbdad4ab9"}
 actix = "0.7"
+awc = "3.0.0-beta.7"
+actix-async = {package="actix", version = "0.12"}
 actix-web = { version = "0.7", default_features = false, features= ["ssl"] }
 clarity = "0.4"
 

diff --git a/rita_client/src/dashboard/prices.rs b/rita_client/src/dashboard/prices.rs
@@ -1,5 +1,5 @@
 use crate::traffic_watcher::GetExitDestPrice;
-use crate::traffic_watcher::TrafficWatcher;
+use crate::traffic_watcher::TrafficWatcherActor;
 
 use actix::SystemService;
 use actix_web::Path;
@@ -47,7 +47,7 @@ pub fn get_prices(_req: HttpRequest) -> Box<dyn Future<Item = Json<Prices>, Erro
     debug!("/prices GET hit");
 
     let payment = settings::get_rita_client().payment;
-    let f = TrafficWatcher::from_registry().send(GetExitDestPrice);
+    let f = TrafficWatcherActor::from_registry().send(GetExitDestPrice);
     let b = f.from_err().and_then(move |exit_dest_price| {
         let exit_dest_price = exit_dest_price.unwrap();
         let simulated_tx_fee = payment.simulated_transaction_fee;