feat(client): add get_block_txids

Author: luisschwab

src/async.rs

@@ -466,6 +466,13 @@ impl<S: Sleeper> AsyncClient<S> {
         self.get_response_json(&path).await
     }
 
+    /// Get all [`Txid`]s that belong to a [`Block`] identified by it's [`BlockHash`].
+    pub async fn get_block_txids(&self, blockhash: &BlockHash) -> Result<Vec<Txid>, Error> {
+        let path = format!("/block/{blockhash}/txids");
+
+        self.get_response_json(&path).await
+    }
+
     /// Gets some recent block summaries starting at the tip or at `height` if
     /// provided.
     ///

src/blocking.rs

@@ -394,6 +394,13 @@ impl BlockingClient {
         self.get_response_json(&path)
     }
 
+    /// Get all [`Txid`]s that belong to a [`Block`] identified by it's [`BlockHash`].
+    pub fn get_block_txids(&self, blockhash: &BlockHash) -> Result<Vec<Txid>, Error> {
+        let path = format!("/block/{blockhash}/txids");
+
+        self.get_response_json(&path)
+    }
+
     /// Gets some recent block summaries starting at the tip or at `height` if
     /// provided.
     ///

src/lib.rs

@@ -988,6 +988,48 @@ mod test {
         assert_eq!(block_info_async.previousblockhash, None);
     }
 
+    #[cfg(all(feature = "blocking", feature = "async"))]
+    #[tokio::test]
+    async fn test_get_block_txids() {
+        let (blocking_client, async_client) = setup_clients().await;
+
+        let address = BITCOIND
+            .client
+            .new_address_with_type(AddressType::Legacy)
+            .unwrap();
+
+        // Create 5 transactions and mine a block.
+        let txids: Vec<_> = (0..5)
+            .map(|_| {
+                BITCOIND
+                    .client
+                    .send_to_address(&address, Amount::from_sat(1000))
+                    .unwrap()
+                    .txid()
+                    .unwrap()
+            })
+            .collect();
+
+        let _miner = MINER.lock().await;
+        generate_blocks_and_wait(1);
+
+        // Get the block hash at height 1.
+        let blockhash = blocking_client.get_block_hash(1).unwrap();
+
+        let txids_async = async_client.get_block_txids(&blockhash).await.unwrap();
+        let txids_blocking = blocking_client.get_block_txids(&blockhash).unwrap();
+
+        assert_eq!(txids_async, txids_blocking);
+
+        // Compare expected and received (skipping the coinbase TXID).
+        txids
+            .iter()
+            .zip(txids_async.iter().skip(1))
+            .for_each(|(expected_txid, received_txid)| {
+                assert_eq!(expected_txid, received_txid);
+            });
+    }
+
     #[cfg(all(feature = "blocking", feature = "async"))]
     #[tokio::test]
     async fn test_get_blocks() {