feat(tor): add new AsyncTorClient

- feat(tor): add new async client, `AsyncTorClient`, which uses
  `arti-client` to establish Tor connections, and `hyper` as HTTP client
  over custom Tor anonymized data stream.
- feat(tor): implements the common methods: `get_response`,
  `get_response_json`, `get_response_hex` and their `opt` versions too.

feat(tor): wip

wip 2

Author: oleonardolima

Cargo.toml

@@ -23,6 +23,22 @@ hex = { version = "0.2", package = "hex-conservative" }
 log = "^0.4"
 minreq = { version = "2.11.0", features = ["json-using-serde"], optional = true }
 reqwest = { version = "0.11",  features = ["json"], default-features = false, optional = true }
+arti-client = { version = "0.21.0", default-features = false, optional = true }
+tor-rtcompat = { version = "0.21.0", default-features = false, optional = true }
+hyper = { version = "1.4.1", features = ["client", "http1"], default-features = false, optional = true }
+hyper-util = { version = "0.1.7", features = ["tokio"], default-features = false, optional = true }
+tokio = { version = "1.38.1", optional = true }
+http-body-util = { version = "0.1.2", optional = true}
+http = { version = "1.1.0", optional = true }
+serde_json = { version = "1.0.127"}
+
+tokio-rustls = { version = "0.26.0", default-features = false, features = [
+    "logging",
+    "tls12",
+    "ring",
+] }
+webpki-roots = { version = "0.26.3" }
+rustls-pki-types = { version = "1.8.0" }
 
 [dev-dependencies]
 serde_json = "1.0"
@@ -31,14 +47,33 @@ electrsd = { version = "0.28.0", features = ["legacy", "esplora_a33e97e1", "bitc
 lazy_static = "1.4.0"
 
 [features]
-default = ["blocking", "async", "async-https"]
+default = ["blocking", "async", "async-https", "async-tor"]
 blocking = ["minreq", "minreq/proxy"]
 blocking-https = ["blocking", "minreq/https"]
 blocking-https-rustls = ["blocking", "minreq/https-rustls"]
 blocking-https-native = ["blocking", "minreq/https-native"]
 blocking-https-bundled = ["blocking", "minreq/https-bundled"]
+
 async = ["reqwest", "reqwest/socks"]
 async-https = ["async", "reqwest/default-tls"]
 async-https-native = ["async", "reqwest/native-tls"]
 async-https-rustls = ["async", "reqwest/rustls-tls"]
 async-https-rustls-manual-roots = ["async", "reqwest/rustls-tls-manual-roots"]
+
+async-tor = [
+    "dep:arti-client",
+    "arti-client/tokio",
+    "arti-client/onion-service-client",
+    "arti-client/native-tls",
+
+    "dep:tor-rtcompat",
+    "tor-rtcompat/tokio",
+
+    "dep:hyper",
+    "dep:hyper-util",
+    "dep:tokio",
+    "dep:http-body-util",
+    "dep:http"
+    ]
+async-tor-https-native = ["async-tor", "arti-client/native-tls"]
+async-tor-https-rustls = ["async-tor", "arti-client/rustls"]

examples/tor.rs

@@ -0,0 +1,24 @@
+use std::str::FromStr;
+
+use bitcoin::Txid;
+use esplora_client::{r#async_tor::AsyncTorClient, Builder};
+
+extern crate esplora_client;
+
+#[tokio::main]
+async fn main() {
+    // let client = Client::new("tcp://electrum.blockstream.info:50001").unwrap();
+    // let res = client.server_features();
+    // println!("{:#?}", res);
+
+    let builder = Builder::new("https://mempool.space/api");
+    let client = AsyncTorClient::from_builder(builder).await.unwrap();
+
+    // let client = AsyncClient::from_builder(builder).unwrap();
+
+    let tx_id =
+        Txid::from_str("4a5e1e4baab89f3a32518a88c31bc87f618f76673e2cc77ab2127b7afdeda33b").unwrap();
+    let tx = client.get_tx(&tx_id).await.unwrap().unwrap();
+
+    println!("{:?}", tx);
+}

src/async.rs

@@ -11,6 +11,7 @@
 
 //! Esplora by way of `reqwest` HTTP client.
 
+use core::str;
 use std::collections::HashMap;
 use std::str::FromStr;
 
@@ -84,7 +85,9 @@ impl AsyncClient {
     /// [`bitcoin::consensus::Decodable`] deserialization.
     async fn get_response<T: Decodable>(&self, path: &str) -> Result<T, Error> {
         let url = format!("{}{}", self.url, path);
-        let response = self.client.get(url).send().await?;
+        let request = self.client.get(url);
+        println!("{:?}", request);
+        let response = request.send().await?;
 
         match response.status().is_success() {
             true => Ok(deserialize::<T>(&response.bytes().await?)?),