aljaz/breez-sdk-liquid
1
0
Fork 0
mirror of https://github.com/aljazceru/breez-sdk-liquid.git synced 2026-01-28 18:34:26 +01:00
Code Issues Packages Projects Releases Wiki Activity

cleanup tip endpoint

Browse Source
This commit is contained in:
Roei Erez
2025-01-29 12:07:39 +02:00
parent fb37e7bccc
commit 461f54be38
1 changed files with 11 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
lib/core/src/chain/bitcoin.rs
View File

@@ -107,24 +107,27 @@ impl BitcoinChainService for HybridBitcoinChainService {
maybe_popped_header = Some(header)
}
match maybe_popped_header {
Some(popped_header) => {
let tip: HeaderNotification = popped_header.try_into()?;
*self.tip.lock().unwrap() = tip;
}
let new_tip = match maybe_popped_header {
Some(popped_header) => Some(popped_header.try_into()?),
None => {
// https://github.com/bitcoindevkit/rust-electrum-client/issues/124
// It might be that the client has reconnected and subscriptions don't persist
// across connections. Calling `client.ping()` won't help here because the
// successful retry will prevent us knowing about the reconnect.
if let Ok(header) = self.client.block_headers_subscribe_raw() {
let tip: HeaderNotification = header.try_into()?;
*self.tip.lock().unwrap() = tip;
Some(header.try_into()?)
} else {
None
}
}
};
let mut tip = self.tip.lock().unwrap();
if let Some(new_tip) = new_tip {
*tip = new_tip;
}
Ok(self.tip.lock().unwrap().clone())
Ok(tip.clone())
}
fn broadcast(&self, tx: &Transaction) -> Result<Txid> {