Add MempoolClient::get_difficulty_adjustment

Author: yukibtc

src/client.rs

@@ -4,7 +4,7 @@ use reqwest::{Client, Response};
 use url::Url;
 
 use crate::error::Error;
-use crate::response::Prices;
+use crate::response::{DifficultyAdjustment, Prices};
 
 /// Mempool Space client
 pub struct MempoolClient {
@@ -31,7 +31,14 @@ impl MempoolClient {
         }
     }
 
-    /// Returns bitcoin latest price denominated in main currencies.
+    /// Get details about difficulty adjustment.
+    pub async fn get_difficulty_adjustment(&self) -> Result<DifficultyAdjustment, Error> {
+        let url: Url = self.url.join("/api/v1/difficulty-adjustment")?;
+        let response: Response = self.client.get(url).send().await?;
+        Ok(response.json().await?)
+    }
+
+    /// Get bitcoin latest price denominated in main currencies.
     pub async fn get_prices(&self) -> Result<Prices, Error> {
         let url: Url = self.url.join("/api/v1/prices")?;
         let response: Response = self.client.get(url).send().await?;

src/response.rs

@@ -3,7 +3,7 @@
 use serde::{Deserialize, Serialize};
 
 /// Prices
-#[derive(Debug, Serialize, Deserialize)]
+#[derive(Debug, Clone, Copy, PartialEq, Eq, PartialOrd, Ord, Hash, Serialize, Deserialize)]
 pub struct Prices {
     /// Timestamp
     pub time: u64,
@@ -29,3 +29,38 @@ pub struct Prices {
     #[serde(rename = "JPY")]
     pub jpy: u32,
 }
+
+/// Bitcoin difficulty adjustment information
+#[derive(Debug, Clone, Copy, PartialEq, PartialOrd, Serialize, Deserialize)]
+pub struct DifficultyAdjustment {
+    /// Progress percentage towards next difficulty adjustment
+    #[serde(rename = "progressPercent")]
+    pub progress_percent: f64,
+    /// Difficulty change percentage
+    #[serde(rename = "difficultyChange")]
+    pub difficulty_change: f64,
+    /// Estimated timestamp for next retarget
+    #[serde(rename = "estimatedRetargetDate")]
+    pub estimated_retarget_date: u64,
+    /// Number of blocks remaining until retarget
+    #[serde(rename = "remainingBlocks")]
+    pub remaining_blocks: u32,
+    /// Estimated time remaining in seconds
+    #[serde(rename = "remainingTime")]
+    pub remaining_time: u64,
+    /// Previous retarget percentage change
+    #[serde(rename = "previousRetarget")]
+    pub previous_retarget: f64,
+    /// Block height of next retarget
+    #[serde(rename = "nextRetargetHeight")]
+    pub next_retarget_height: u32,
+    /// Average time between blocks
+    #[serde(rename = "timeAvg")]
+    pub time_avg: u64,
+    /// Adjusted average time between blocks
+    #[serde(rename = "adjustedTimeAvg")]
+    pub adjusted_time_avg: u64,
+    /// Time offset
+    #[serde(rename = "timeOffset")]
+    pub time_offset: i64,
+}