feat: add get_tx_outspends

Author: luisschwab

src/async.rs

@@ -30,8 +30,8 @@ use reqwest::{header, Client, Response};
 
 use crate::api::AddressStats;
 use crate::{
-    BlockStatus, BlockSummary, Builder, Error, MerkleProof, OutputStatus, Tx, TxStatus, Utxo,
-    BASE_BACKOFF_MILLIS, RETRYABLE_ERROR_CODES,
+    BlockStatus, BlockSummary, Builder, Error, MerkleProof, OutputSpendStatus, OutputStatus, Tx,
+    TxStatus, Utxo, BASE_BACKOFF_MILLIS, RETRYABLE_ERROR_CODES,
 };
 
 #[derive(Debug, Clone)]
@@ -315,6 +315,12 @@ impl<S: Sleeper> AsyncClient<S> {
         self.get_opt_response_json(&format!("/tx/{txid}")).await
     }
 
+    /// Get the spend status of a [`Transaction`]'s outputs, given it's [`Txid`].
+    pub async fn get_tx_outspends(&self, txid: &Txid) -> Result<Vec<OutputSpendStatus>, Error> {
+        self.get_response_json(&format!("/tx/{txid}/outspends"))
+            .await
+    }
+
     /// Get a [`BlockHeader`] given a particular block hash.
     pub async fn get_header_by_hash(&self, block_hash: &BlockHash) -> Result<BlockHeader, Error> {
         self.get_response_hex(&format!("/block/{block_hash}/header"))

src/blocking.rs

@@ -31,8 +31,8 @@ use bitcoin::{
 
 use crate::api::AddressStats;
 use crate::{
-    BlockStatus, BlockSummary, Builder, Error, MerkleProof, OutputStatus, Tx, TxStatus, Utxo,
-    BASE_BACKOFF_MILLIS, RETRYABLE_ERROR_CODES,
+    BlockStatus, BlockSummary, Builder, Error, MerkleProof, OutputSpendStatus, OutputStatus, Tx,
+    TxStatus, Utxo, BASE_BACKOFF_MILLIS, RETRYABLE_ERROR_CODES,
 };
 
 #[derive(Debug, Clone)]
@@ -229,6 +229,11 @@ impl BlockingClient {
         self.get_opt_response_json(&format!("/tx/{txid}"))
     }
 
+    /// Get the spend status of a [`Transaction`]'s outputs, given it's [`Txid`].
+    pub fn get_tx_outspends(&self, txid: &Txid) -> Result<Vec<OutputSpendStatus>, Error> {
+        self.get_response_json(&format!("/tx/{txid}/outspends"))
+    }
+
     /// Get a [`BlockHeader`] given a particular block hash.
     pub fn get_header_by_hash(&self, block_hash: &BlockHash) -> Result<BlockHeader, Error> {
         self.get_response_hex(&format!("/block/{block_hash}/header"))

src/lib.rs

@@ -1065,4 +1065,36 @@ mod test {
         assert_ne!(address_utxos_async.len(), 0);
         assert_eq!(address_utxos_blocking, address_utxos_async);
     }
+
+    #[cfg(all(feature = "blocking", feature = "async"))]
+    #[tokio::test]
+    async fn test_get_tx_outspends() {
+        let (blocking_client, async_client) = setup_clients().await;
+
+        let address = BITCOIND
+            .client
+            .new_address_with_type(AddressType::Legacy)
+            .unwrap();
+
+        let txid = BITCOIND
+            .client
+            .send_to_address(&address, Amount::from_sat(21000))
+            .unwrap()
+            .txid()
+            .unwrap();
+
+        let _miner = MINER.lock().await;
+        generate_blocks_and_wait(1);
+
+        let txid_outspends_blocking = blocking_client.get_tx_outspends(&txid).unwrap();
+        let txid_outspends_async = async_client.get_tx_outspends(&txid).await.unwrap();
+
+        // Assert that there are 2 outputs: 21K sat and (coinbase - 21K sat).
+        assert_eq!(txid_outspends_blocking.len(), 2);
+        assert_eq!(txid_outspends_async.len(), 2);
+        assert_eq!(txid_outspends_blocking, txid_outspends_async);
+
+        // Assert that both outputs are returned as unspent (spend == false).
+        assert!(txid_outspends_blocking.iter().all(|output| !output.spent));
+    }
 }