From 9d5d5827520bb735afa99b527079e3af0803247e Mon Sep 17 00:00:00 2001 From: SomberNight Date: Wed, 22 Nov 2023 16:59:24 +0000 Subject: [PATCH] swaps: forward swap: (fix) propagate channels parameter --- electrum/submarine_swaps.py | 13 ++++++++----- 1 file changed, 8 insertions(+), 5 deletions(-) diff --git a/electrum/submarine_swaps.py b/electrum/submarine_swaps.py index e23da0660..bb48f4acf 100644 --- a/electrum/submarine_swaps.py +++ b/electrum/submarine_swaps.py @@ -418,6 +418,7 @@ class SwapManager(Logger): their_pubkey=None, invoice=None, prepay=None, + channels=None, ): """ if invoice is None, create a hold invoice """ if prepay: @@ -433,7 +434,7 @@ class SwapManager(Logger): message='Submarine swap', expiry=300, fallback_address=None, - channels=None, + channels=channels, ) # add payment info to lnworker self.lnworker.add_payment_info_for_hold_invoice(payment_hash, invoice_amount_sat) @@ -446,7 +447,7 @@ class SwapManager(Logger): message='Submarine swap mining fees', expiry=300, fallback_address=None, - channels=None, + channels=channels, ) self.lnworker.bundle_payments([payment_hash, prepay_hash]) self.prepayments[prepay_hash] = payment_hash @@ -565,7 +566,7 @@ class SwapManager(Logger): assert self.lnwatcher swap, invoice = await self.request_normal_swap(lightning_amount_sat, expected_onchain_amount_sat, channels=channels) tx = self.create_funding_tx(swap, tx, password) - return await self.wait_for_htlcs_and_broadcast(swap, invoice, tx, channels=channels) + return await self.wait_for_htlcs_and_broadcast(swap, invoice, tx) async def request_normal_swap(self, lightning_amount_sat, expected_onchain_amount_sat, channels=None): amount_msat = lightning_amount_sat * 1000 @@ -612,10 +613,12 @@ class SwapManager(Logger): our_privkey=refund_privkey, their_pubkey=claim_pubkey, invoice=invoice, - prepay=False) + prepay=False, + channels=channels, + ) return swap, invoice - async def wait_for_htlcs_and_broadcast(self, swap, invoice, tx, channels=None): + async def wait_for_htlcs_and_broadcast(self, swap, invoice, tx): payment_hash = swap.payment_hash refund_pubkey = ECPrivkey(swap.privkey).get_public_key_bytes(compressed=True) async def callback(payment_hash):