feat(client): add get_block_infos

Author: luisschwab

src/async.rs

@@ -577,6 +577,24 @@ impl<S: Sleeper> AsyncClient<S> {
         Ok(blocks)
     }
 
+    /// Get summaries about recent blocks as [`BlockInfo`]s,
+    /// starting at the tip, or at `height`, if provided.
+    ///
+    /// The maximum number of elements returned depends on the backend itself:
+    /// - Esplora returns `10`
+    /// - [mempool.space](https://mempool.space/docs/api) returns `15`
+    pub async fn get_block_infos(&self, height: Option<u32>) -> Result<Vec<BlockInfo>, Error> {
+        let path = match height {
+            Some(height) => format!("/blocks/{height}"),
+            None => "/blocks".to_string(),
+        };
+        let blocks: Vec<BlockInfo> = self.get_response_json(&path).await?;
+        if blocks.is_empty() {
+            return Err(Error::InvalidResponse);
+        }
+        Ok(blocks)
+    }
+
     /// Get all UTXOs locked to an address.
     pub async fn get_address_utxos(&self, address: &Address) -> Result<Vec<Utxo>, Error> {
         let path = format!("/address/{address}/utxo");

src/blocking.rs

@@ -511,6 +511,24 @@ impl BlockingClient {
         Ok(blocks)
     }
 
+    /// Get summaries about recent blocks as [`BlockInfo`]s,
+    /// starting at the tip, or at `height`, if provided.
+    ///
+    /// The maximum number of elements returned depends on the backend itself:
+    /// - Esplora returns `10`
+    /// - [mempool.space](https://mempool.space/docs/api) returns `15`
+    pub fn get_block_infos(&self, height: Option<u32>) -> Result<Vec<BlockInfo>, Error> {
+        let path = match height {
+            Some(height) => format!("/blocks/{height}"),
+            None => "/blocks".to_string(),
+        };
+        let blocks: Vec<BlockInfo> = self.get_response_json(&path)?;
+        if blocks.is_empty() {
+            return Err(Error::InvalidResponse);
+        }
+        Ok(blocks)
+    }
+
     /// Get all UTXOs locked to an address.
     pub fn get_address_utxos(&self, address: &Address) -> Result<Vec<Utxo>, Error> {
         let path = format!("/address/{address}/utxo");

src/lib.rs

@@ -1036,6 +1036,41 @@ mod test {
         assert_eq!(blocks_genesis, blocks_genesis_async);
     }
 
+    #[cfg(all(feature = "blocking", feature = "async"))]
+    #[tokio::test]
+    async fn test_get_block_infos() {
+        let (blocking_client, async_client) = setup_clients().await;
+        
+        let start_height = BITCOIND.client.get_block_count().unwrap().0;
+        
+        let blocks_blocking_0 = blocking_client.get_block_infos(None).unwrap();
+        let blocks_async_0 = async_client.get_block_infos(None).await.unwrap();
+        assert_eq!(blocks_blocking_0[0].height, start_height as u32);
+        assert_eq!(blocks_blocking_0, blocks_async_0);
+        
+        generate_blocks_and_wait(10);
+        
+        let blocks_blocking_1 = blocking_client.get_block_infos(None).unwrap();
+        let blocks_async_1 = async_client.get_block_infos(None).await.unwrap();
+        assert_eq!(blocks_blocking_1, blocks_async_1);
+        assert_ne!(blocks_blocking_0, blocks_blocking_1);
+        
+        let blocks_blocking_2 = blocking_client
+            .get_block_infos(Some(start_height as u32))
+            .unwrap();
+        let blocks_async_3 = async_client
+            .get_block_infos(Some(start_height as u32))
+            .await
+            .unwrap();
+        assert_eq!(blocks_blocking_2, blocks_async_3);
+        assert_eq!(blocks_blocking_2[0].height, start_height as u32);
+        assert_eq!(blocks_blocking_2, blocks_blocking_0);
+        
+        let blocks_blocking_genesis = blocking_client.get_block_infos(Some(0)).unwrap();
+        let blocks_async_genesis = async_client.get_block_infos(Some(0)).await.unwrap();
+        assert_eq!(blocks_blocking_genesis, blocks_async_genesis);
+    }
+
     #[cfg(all(feature = "blocking", feature = "async"))]
     #[tokio::test]
     async fn test_get_tx_with_http_header() {