Merge pull request #3 from rustaceanrob/26-1-25-taproot-dn-client

Add `estimate_smart_fee` endpoint

Author: rustaceanrob

src/lib.rs

@@ -2,7 +2,9 @@
 #![warn(missing_docs)]
 use std::{borrow::Cow, io::Cursor, net::SocketAddr};
 
-use bitcoin::{Block, BlockHash, bip158::BlockFilter, block::Header, consensus::Decodable};
+use bitcoin::{
+    Block, BlockHash, FeeRate, bip158::BlockFilter, block::Header, consensus::Decodable,
+};
 use models::{Html, ServerStatus, TapTweaks};
 
 /// Errors that may occur when querying.
@@ -19,8 +21,8 @@ pub struct Endpoint<'e>(Cow<'e, str>);
 impl<'e> Endpoint<'e> {
     /// The original `block-dn` server hosted at `block-dn.org`.
     pub const BLOCK_DN_ORG: Self = Self(Cow::Borrowed("https://block-dn.org"));
-    // Taproot-specific filters hosted by `2140.dev`.
-    // pub const TAPROOT_DN: Self = Self(Cow::Borrowed("https://taprootdn.xyz"));
+    /// Server with additional capabilities hosted by `2140.dev`.
+    pub const DEV_2140: Self = Self(Cow::Borrowed("https://taprootdn.xyz"));
     /// Local host at port 8080.
     pub const LOCAL_HOST: Self = Self(Cow::Borrowed("https://127.0.0.1:8080"));
 
@@ -170,6 +172,23 @@ impl<'e> Client<'e> {
         let block = bitcoin::consensus::deserialize::<Block>(response.as_bytes())?;
         Ok(block)
     }
+
+    /// Get the fee rate estimated for inclusion in the target block. Only available on
+    /// [`Endpoint::DEV_2140`].
+    pub fn estimate_smart_fee(&self, conf_target: u32) -> Result<FeeRate, Error> {
+        let route = self
+            .endpoint
+            .append_route(format!("fees/estimate-fee/{conf_target}"));
+        let response = bitreq::get(route).with_timeout(self.timeout.0).send()?;
+        let sats_vb: [u8; 8] = response.as_bytes().try_into().map_err(|_| {
+            Error::Decoder(bitcoin::consensus::encode::Error::ParseFailed(
+                "cannot fit response into 8 byte little endian.",
+            ))
+        })?;
+        Ok(FeeRate::from_sat_per_vb_unchecked(u64::from_le_bytes(
+            sats_vb,
+        )))
+    }
 }
 
 #[cfg(test)]

tests/client.rs

@@ -1,4 +1,4 @@
-use block_dn_client::{Builder, Client, Timeout};
+use block_dn_client::{Builder, Client, Endpoint, Timeout};
 
 fn default_client() -> Client<'static> {
     Builder::default().build()
@@ -50,3 +50,9 @@ fn test_block() {
             .is_ok()
     )
 }
+
+#[test]
+fn test_estimate_fee() {
+    let client = Builder::new().endpoint(Endpoint::DEV_2140).build();
+    assert!(client.estimate_smart_fee(1).is_ok());
+}