feat(async): persist headers on AsyncClient

And add a test to verify that both async
and blocking clients were built with headers.

Author: luisschwab

src/async.rs

@@ -45,6 +45,9 @@ pub struct AsyncClient<S = DefaultSleeper> {
     max_retries: usize,
     /// Marker for the type of sleeper used
     marker: PhantomData<S>,
+    #[allow(unused)]
+    /// HTTP headers to append on every request made to Esplora server.
+    pub(crate) headers: HashMap<String, String>, // TODO: remove this when `bitreq` is implemented
 }
 
 impl<S: Sleeper> AsyncClient<S> {
@@ -62,6 +65,8 @@ impl<S: Sleeper> AsyncClient<S> {
             client_builder = client_builder.timeout(core::time::Duration::from_secs(timeout));
         }
 
+        // TODO: remove this when `bitreq` is implemented
+        let headers = builder.headers.clone();
         if !builder.headers.is_empty() {
             let mut headers = header::HeaderMap::new();
             for (k, v) in builder.headers {
@@ -78,6 +83,7 @@ impl<S: Sleeper> AsyncClient<S> {
             url: builder.base_url,
             client: client_builder.build()?,
             max_retries: builder.max_retries,
+            headers,
             marker: PhantomData,
         })
     }
@@ -87,6 +93,7 @@ impl<S: Sleeper> AsyncClient<S> {
         AsyncClient {
             url,
             client,
+            headers: HashMap::new(),
             max_retries: crate::DEFAULT_MAX_RETRIES,
             marker: PhantomData,
         }

src/lib.rs

@@ -493,6 +493,21 @@ mod test {
         );
     }
 
+    #[cfg(all(feature = "blocking", feature = "async"))]
+    #[tokio::test]
+    async fn test_build_client_with_headers() {
+        let env = TestEnv::new();
+        let headers: HashMap<String, String> = [(
+            "Authorization".to_string(),
+            "Basic QWxhZGRpbjpvcGVuIHNlc2FtZQ==".to_string(),
+        )]
+        .into();
+        let (blocking_client, async_client) = env.setup_clients_with_headers(headers.clone());
+
+        assert_eq!(blocking_client.headers, headers);
+        assert_eq!(async_client.headers, headers);
+    }
+
     #[cfg(all(feature = "blocking", feature = "async"))]
     #[tokio::test]
     async fn test_get_tx() {