Merge pull request #76 from rustaceanrob/fee-filter-12-10

Add `broadcast_minimum` to `Client`

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "bdk_kyoto"
-version = "0.4.0"
+version = "0.5.0"
 authors = ["Rob <[email protected]>", "Bitcoin Dev Kit Developers"]
 description = "BDK blockchain integration using P2P light client Kyoto"
 license = "MIT OR Apache-2.0"

examples/wallet.rs

@@ -66,6 +66,10 @@ async fn main() -> anyhow::Result<()> {
             tracing::info!("Local chain tip: {}", wallet.local_chain().tip().height());
             let next = wallet.peek_address(KeychainKind::External, last_revealed + 1);
             tracing::info!("Next receiving address: {next}");
+            tracing::info!(
+                "Broadcast minimum fee rate: {}",
+                receiver.broadcast_minimum()
+            );
         }
     }
 }

src/lib.rs

@@ -168,6 +168,7 @@ use bdk_chain::{
 };
 use bdk_chain::{ConfirmationBlockTime, TxUpdate};
 
+pub use bdk_chain::bitcoin::FeeRate;
 pub use bdk_chain::local_chain::MissingGenesisError;
 
 pub extern crate kyoto;
@@ -197,6 +198,8 @@ pub struct EventReceiver<K> {
     chain: local_chain::LocalChain,
     // receive graph
     graph: IndexedTxGraph<ConfirmationBlockTime, KeychainTxOutIndex<K>>,
+    // the network minimum to broadcast a transaction
+    min_broadcast_fee: FeeRate,
 }
 
 impl<K> EventReceiver<K>
@@ -213,6 +216,7 @@ where
             receiver,
             chain: LocalChain::from_tip(cp)?,
             graph: IndexedTxGraph::new(index.clone()),
+            min_broadcast_fee: FeeRate::BROADCAST_MIN,
         })
     }
 
@@ -256,6 +260,11 @@ where
                     });
                     break;
                 }
+                NodeMessage::FeeFilter(fee_filter) => {
+                    if self.min_broadcast_fee < fee_filter {
+                        self.min_broadcast_fee = fee_filter;
+                    }
+                }
                 _ => (),
             }
         }
@@ -379,11 +388,21 @@ where
                 NodeMessage::TxBroadcastFailure(failure_payload) => {
                     return Some(Event::TxFailed(failure_payload));
                 }
+                NodeMessage::FeeFilter(fee_filter) => {
+                    if self.min_broadcast_fee < fee_filter {
+                        self.min_broadcast_fee = fee_filter;
+                    }
+                }
                 _ => continue,
             }
         }
         None
     }
+
+    /// The minimum fee required for a transaction to propagate to the connected peers.
+    pub fn broadcast_minimum(&self) -> FeeRate {
+        self.min_broadcast_fee
+    }
 }
 
 /// Handle dialog and state changes from a node with some arbitrary behavior.