test: propagate errors to users

Author: vladimirfomene

.github/workflows/cont_integration.yml

@@ -16,7 +16,7 @@ jobs:
     strategy:
       matrix:
         rust:
-          - version: 1.65.0 # STABLE
+          - version: stable # STABLE
             clippy: true
           - version: 1.57.0 # MSRV
         features:
@@ -51,11 +51,20 @@ jobs:
     - name: pin dependencies
       if: matrix.rust.version == '1.57.0'
       run: |
-        cargo update -p log --precise 0.4.18 
+        cargo update -p tokio --precise 1.29.1
+        cargo update -p reqwest --precise 0.11.18
+        cargo update -p rustls:0.20.9 --precise 0.20.8
+        cargo update -p rustix --precise 0.38.6
         cargo update -p rustls:0.21.7 --precise 0.21.1
-        cargo update -p time:0.3.15 --precise 0.3.13
         cargo update -p hyper-rustls:0.24.1 --precise 0.24.0
-        cargo update -p tempfile:3.7.0 --precise 3.6.0
+        cargo update -p rustls-webpki:0.100.3 --precise 0.100.1
+        cargo update -p rustls-webpki:0.101.6 --precise 0.101.1
+        cargo update -p tempfile --precise 3.6.0
+        cargo update -p h2 --precise 0.3.20
+        cargo update -p flate2:1.0.27 --precise 1.0.26
+        cargo update -p cc --precise 1.0.81
+        cargo update -p tokio-util --precise 0.7.8
+        cargo update -p time:0.3.15 --precise 0.3.13
     - name: Build
       run: cargo build --features ${{ matrix.features }} --no-default-features
     - name: Clippy

src/lib.rs

@@ -550,6 +550,41 @@ mod test {
         assert_eq!(expected, block_async);
     }
 
+    #[cfg(all(feature = "blocking", feature = "async"))]
+    #[tokio::test]
+    async fn test_that_errors_are_propagated() {
+        let (blocking_client, async_client) = setup_clients().await;
+
+        let address = BITCOIND
+            .client
+            .get_new_address(Some("test"), Some(AddressType::Legacy))
+            .unwrap()
+            .assume_checked();
+        let txid = BITCOIND
+            .client
+            .send_to_address(
+                &address,
+                Amount::from_sat(1000),
+                None,
+                None,
+                None,
+                None,
+                None,
+                None,
+            )
+            .unwrap();
+        let _miner = MINER.lock().await;
+        generate_blocks_and_wait(1);
+
+        let tx = blocking_client.get_tx(&txid).unwrap();
+        let async_res = async_client.broadcast(tx.as_ref().unwrap()).await;
+        let blocking_res = blocking_client.broadcast(tx.as_ref().unwrap());
+        assert!(async_res.is_err());
+        assert_eq!(async_res.unwrap_err().to_string(),"HttpResponse { status: 400, message: \"sendrawtransaction RPC error: {\\\"code\\\":-27,\\\"message\\\":\\\"Transaction already in block chain\\\"}\" }");
+        assert!(blocking_res.is_err());
+        assert_eq!(blocking_res.unwrap_err().to_string(),"HttpResponse { status: 400, message: \"sendrawtransaction RPC error: {\\\"code\\\":-27,\\\"message\\\":\\\"Transaction already in block chain\\\"}\" }");
+    }
+
     #[cfg(all(feature = "blocking", feature = "async"))]
     #[tokio::test]
     async fn test_get_block_by_hash_not_existing() {