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

move refund_non_cooperative location

Browse Source
This commit is contained in:
Roei Erez
2024-06-05 15:44:01 +03:00
parent c5a4d61753
commit 84e3c94ad1
1 changed files with 26 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files

52
lib/core/src/send_swap.rs
View File

@@ -353,6 +353,32 @@ impl SendSwapStateHandler {
}
}
async fn refund_non_cooperative(
&self,
swap: &SendSwap,
broadcast_fees_sat: Amount,
) -> Result<String, PaymentError> {
info!(
"Initiating non-cooperative refund for Send Swap {}",
&swap.id
);
let current_height = self.onchain_wallet.tip().await.height();
let output_address = self.onchain_wallet.next_unused_address().await?.to_string();
let refund_tx_id = self.swapper.refund_send_swap_non_cooperative(
swap,
broadcast_fees_sat,
&output_address,
current_height,
)?;
info!(
"Successfully broadcast non-cooperative refund for Send Swap {}, tx: {}",
swap.id, refund_tx_id
);
Ok(refund_tx_id)
}
fn validate_state_transition(
from_state: PaymentState,
to_state: PaymentState,
@@ -391,30 +417,4 @@ impl SendSwapStateHandler {
.then_some(())
.ok_or(PaymentError::InvalidPreimage)
}
async fn refund_non_cooperative(
&self,
swap: &SendSwap,
broadcast_fees_sat: Amount,
) -> Result<String, PaymentError> {
info!(
"Initiating non-cooperative refund for Send Swap {}",
&swap.id
);
let current_height = self.onchain_wallet.tip().await.height();
let output_address = self.onchain_wallet.next_unused_address().await?.to_string();
let refund_tx_id = self.swapper.refund_send_swap_non_cooperative(
swap,
broadcast_fees_sat,
&output_address,
current_height,
)?;
info!(
"Successfully broadcast non-cooperative refund for Send Swap {}, tx: {}",
swap.id, refund_tx_id
);
Ok(refund_tx_id)
}
}