aljaz/breez-sdk-liquid
1
0
Fork 0
mirror of https://github.com/aljazceru/breez-sdk-liquid.git synced 2026-01-21 06:54:20 +01:00
Code Issues Packages Projects Releases Wiki Activity

limit claim for local swaps

Browse Source
This commit is contained in:
Roei Erez
2025-02-28 11:17:18 +02:00
parent 33e5ac5a16
commit 2a2514cbe9
1 changed files with 14 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
lib/core/src/chain_swap.rs
View File

@@ -260,7 +260,7 @@ impl ChainSwapHandler {
..Default::default()
})?;
if swap.accept_zero_conf {
if swap.accept_zero_conf && swap.metadata.is_local {
self.claim(&id).await.map_err(|e| {
error!("Could not cooperate Chain Swap {id} claim: {e}");
anyhow!("Could not post claim details. Err: {e:?}")
@@ -304,10 +304,12 @@ impl ChainSwapHandler {
match verify_res {
Ok(_) => {
info!("Server lockup transaction was verified for incoming Chain Swap {}", swap.id);
self.claim(&id).await.map_err(|e| {
error!("Could not cooperate Chain Swap {id} claim: {e}");
anyhow!("Could not post claim details. Err: {e:?}")
})?;
if swap.metadata.is_local {
self.claim(&id).await.map_err(|e| {
error!("Could not cooperate Chain Swap {id} claim: {e}");
anyhow!("Could not post claim details. Err: {e:?}")
})?;
}
}
Err(e) => {
warn!("Server lockup transaction for incoming Chain Swap {} could not be verified. txid: {}, err: {}", swap.id, transaction.id, e);
@@ -613,7 +615,7 @@ impl ChainSwapHandler {
..Default::default()
})?;
if swap.accept_zero_conf {
if swap.accept_zero_conf && swap.metadata.is_local {
self.claim(&id).await.map_err(|e| {
error!("Could not cooperate Chain Swap {id} claim: {e}");
anyhow!("Could not post claim details. Err: {e:?}")
@@ -663,10 +665,12 @@ impl ChainSwapHandler {
server_lockup_tx_id: Some(transaction.id),
..Default::default()
})?;
self.claim(&id).await.map_err(|e| {
error!("Could not cooperate Chain Swap {id} claim: {e}");
anyhow!("Could not post claim details. Err: {e:?}")
})?;
if swap.metadata.is_local {
self.claim(&id).await.map_err(|e| {
error!("Could not cooperate Chain Swap {id} claim: {e}");
anyhow!("Could not post claim details. Err: {e:?}")
})?;
}
}
Some(claim_tx_id) => {
warn!("Claim tx for Chain Swap {id} was already broadcast: txid {claim_tx_id}")