diff --git a/electrum/gui/qt/channel_details.py b/electrum/gui/qt/channel_details.py index ad2b2e277296..2d440fae3e2f 100644 --- a/electrum/gui/qt/channel_details.py +++ b/electrum/gui/qt/channel_details.py @@ -83,8 +83,8 @@ def move(self, fro: str, to: str, payment_hash: bytes): dest_mapping = self.keyname_rows[to] dest_mapping[payment_hash] = len(dest_mapping) - htlc_fulfilled = QtCore.pyqtSignal(str, bytes, bytes) - htlc_failed = QtCore.pyqtSignal(str, bytes, bytes) + htlc_fulfilled = QtCore.pyqtSignal(str, bytes, Channel, int) + htlc_failed = QtCore.pyqtSignal(str, bytes, Channel, int) htlc_added = QtCore.pyqtSignal(str, Channel, UpdateAddHtlc, Direction) state_changed = QtCore.pyqtSignal(str, Abstract_Wallet, AbstractChannel) @@ -103,16 +103,16 @@ def on_htlc_added(self, evtname, chan, htlc, direction): mapping[htlc.payment_hash] = len(mapping) self.folders['inflight'].appendRow(self.make_htlc_item(htlc, direction)) - @QtCore.pyqtSlot(str, bytes, bytes) - def on_htlc_fulfilled(self, evtname, payment_hash, chan_id): - if chan_id != self.chan.channel_id: + @QtCore.pyqtSlot(str, bytes, Channel, int) + def on_htlc_fulfilled(self, evtname, payment_hash, chan, htlc_id): + if chan.channel_id != self.chan.channel_id: return self.move('inflight', 'settled', payment_hash) self.update() - @QtCore.pyqtSlot(str, bytes, bytes) - def on_htlc_failed(self, evtname, payment_hash, chan_id): - if chan_id != self.chan.channel_id: + @QtCore.pyqtSlot(str, bytes, Channel, int) + def on_htlc_failed(self, evtname, payment_hash, chan, htlc_id): + if chan.channel_id != self.chan.channel_id: return self.move('inflight', 'failed', payment_hash) self.update() diff --git a/electrum/lnworker.py b/electrum/lnworker.py index 601261538089..6b1bde00d909 100644 --- a/electrum/lnworker.py +++ b/electrum/lnworker.py @@ -1847,8 +1847,8 @@ def set_payment_status(self, payment_hash: bytes, status: int) -> None: info = info._replace(status=status) self.save_payment_info(info) - def htlc_fulfilled(self, chan, payment_hash: bytes, htlc_id:int): - util.trigger_callback('htlc_fulfilled', payment_hash, chan.channel_id) + def htlc_fulfilled(self, chan: Channel, payment_hash: bytes, htlc_id: int): + util.trigger_callback('htlc_fulfilled', payment_hash, chan, htlc_id) q = self.sent_htlcs.get(payment_hash) if q: route, payment_secret, amount_msat, bucket_msat, amount_receiver_msat = self.sent_htlcs_routes[(payment_hash, chan.short_channel_id, htlc_id)] @@ -1870,7 +1870,7 @@ def htlc_failed( error_bytes: Optional[bytes], failure_message: Optional['OnionRoutingFailure']): - util.trigger_callback('htlc_failed', payment_hash, chan.channel_id) + util.trigger_callback('htlc_failed', payment_hash, chan, htlc_id) q = self.sent_htlcs.get(payment_hash) if q: # detect if it is part of a bucket