feat: add get_mempool_txids

Author: luisschwab

src/async.rs

@@ -464,6 +464,13 @@ impl<S: Sleeper> AsyncClient<S> {
         self.get_response_json("/mempool").await
     }
 
+    /// Get the full list of transaction IDs in the mempool.
+    ///
+    /// The order of the txids is arbitrary and does not match bitcoind's.
+    pub async fn get_mempool_txids(&self) -> Result<Vec<Txid>, Error> {
+        self.get_response_json("/mempool/txids").await
+    }
+
     /// Get an map where the key is the confirmation target (in number of
     /// blocks) and the value is the estimated feerate (in sat/vB).
     pub async fn get_fee_estimates(&self) -> Result<HashMap<u16, f64>, Error> {

src/blocking.rs

@@ -321,6 +321,13 @@ impl BlockingClient {
         self.get_response_json("/mempool")
     }
 
+    /// Get the full list of transaction IDs in the mempool.
+    ///
+    /// The order of the txids is arbitrary and does not match bitcoind's.
+    pub fn get_mempool_txids(&self) -> Result<Vec<Txid>, Error> {
+        self.get_response_json("/mempool/txids")
+    }
+
     /// Get an map where the key is the confirmation target (in number of
     /// blocks) and the value is the estimated feerate (in sat/vB).
     pub fn get_fee_estimates(&self) -> Result<HashMap<u16, f64>, Error> {

src/lib.rs

@@ -906,6 +906,47 @@ mod test {
         }
     }
 
+    #[cfg(all(feature = "blocking", feature = "async"))]
+    #[tokio::test]
+    async fn test_get_mempool_txids() {
+        let (blocking_client, async_client) = setup_clients().await;
+
+        let address = BITCOIND
+            .client
+            .new_address_with_type(AddressType::Legacy)
+            .unwrap();
+
+        let _miner = MINER.lock().await;
+
+        let mut expected_txids = Vec::new();
+        for _ in 0..5 {
+            let txid = BITCOIND
+                .client
+                .send_to_address(&address, Amount::from_sat(1000))
+                .unwrap()
+                .txid()
+                .unwrap();
+            expected_txids.push(txid);
+        }
+
+        // Sleep for 5 seconds so the transaction has time to propagate to electrs' mempool.
+        tokio::time::sleep(tokio::time::Duration::from_secs(5)).await;
+
+        let txids_blocking = blocking_client.get_mempool_txids().unwrap();
+        let txids_async = async_client.get_mempool_txids().await.unwrap();
+
+        assert_eq!(txids_blocking, txids_async);
+        assert!(txids_blocking.len() >= 5);
+
+        for expected_txid in &expected_txids {
+            assert!(
+                txids_blocking.contains(expected_txid),
+                "Txid {} not found in mempool",
+                expected_txid
+            );
+        }
+    }
+
     #[cfg(all(feature = "blocking", feature = "async"))]
     #[tokio::test]
     async fn test_get_fee_estimates() {