aljaz/breez-sdk-liquid
1
0
Fork 0
mirror of https://github.com/aljazceru/breez-sdk-liquid.git synced 2026-02-23 15:04:22 +01:00
Code Issues Packages Projects Releases Wiki Activity

Log persister error and assume no chain swaps

Browse Source
This commit is contained in:
Daniel Granhão
2025-07-15 11:19:39 +01:00
parent f72ec85658
commit 77ed5a043e
1 changed files with 38 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

61
lib/core/src/sdk.rs
View File

@@ -600,29 +600,36 @@ impl LiquidSdk {
}
};
// Get the Bitcoin tip and process a new block (only if chain swaps are used)
let (maybe_bitcoin_tip, is_new_bitcoin_block) =
if self.persister.has_chain_swaps().unwrap_or_default().not() {
info!("No known chain swaps, skipping bitcoin tip fetch");
(None, false)
} else {
let t0 = Instant::now();
let bitcoin_tip_res = self.bitcoin_chain_service.tip().await;
let duration_ms = Instant::now().duration_since(t0).as_millis();
info!("Fetched bitcoin tip at ({duration_ms} ms)");
let is_new_bitcoin_block = match &bitcoin_tip_res {
Ok(height) => {
debug!("Got Bitcoin tip: {height}");
let is_new_bitcoin_block = *height > *current_bitcoin_block;
*current_bitcoin_block = *height;
is_new_bitcoin_block
}
Err(e) => {
error!("Failed to fetch Bitcoin tip: {e}");
false
}
};
(bitcoin_tip_res.ok(), is_new_bitcoin_block)
let (maybe_bitcoin_tip, is_new_bitcoin_block) = if self
.persister
.has_chain_swaps()
.unwrap_or_else(|e| {
error!("Failed to check if there are chain swaps: {e} - proceeding as if not");
false
})
.not()
{
info!("No known chain swaps, skipping bitcoin tip fetch");
(None, false)
} else {
let t0 = Instant::now();
let bitcoin_tip_res = self.bitcoin_chain_service.tip().await;
let duration_ms = Instant::now().duration_since(t0).as_millis();
info!("Fetched bitcoin tip at ({duration_ms} ms)");
let is_new_bitcoin_block = match &bitcoin_tip_res {
Ok(height) => {
debug!("Got Bitcoin tip: {height}");
let is_new_bitcoin_block = *height > *current_bitcoin_block;
*current_bitcoin_block = *height;
is_new_bitcoin_block
}
Err(e) => {
error!("Failed to fetch Bitcoin tip: {e}");
false
}
};
(bitcoin_tip_res.ok(), is_new_bitcoin_block)
};
let maybe_chain_tips = if let Ok(liquid_tip) = liquid_tip_res {
self.persister
@@ -4032,7 +4039,15 @@ impl LiquidSdk {
None => ChainTips {
liquid_tip: self.liquid_chain_service.tip().await?,
bitcoin_tip: {
if self.persister.has_chain_swaps()?.not() {
if self
.persister
.has_chain_swaps()
.unwrap_or_else(|e| {
error!("Failed to check if there are chain swaps: {e} - proceeding as if not");
false
})
.not()
{
info!("No known chain swaps, skipping bitcoin tip fetch");
None
} else {