LBRYFoundation/LBRY-Vault
1
0
Fork 0
mirror of https://github.com/LBRYFoundation/LBRY-Vault.git synced 2025-09-01 01:35:20 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

lnworker: set invoice status if htlcs are received from previous session

Browse source
This commit is contained in:
ThomasV 2020-03-05 10:51:22 +01:00
parent bf4a9d7909
commit 7f3542f080
1 changed files with 10 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
electrum/lnworker.py
View file

@ -1201,16 +1201,22 @@ class LNWallet(LNWorker):
def payment_failed(self, chan, payment_hash: bytes, reason): def payment_failed(self, chan, payment_hash: bytes, reason):
self.set_payment_status(payment_hash, PR_UNPAID) self.set_payment_status(payment_hash, PR_UNPAID)
f = self.pending_payments[payment_hash] f = self.pending_payments.get(payment_hash)
if not f.cancelled(): if f and not f.cancelled():
f.set_result((False, None, reason)) f.set_result((False, None, reason))
else:
self.logger.info('received unexpected payment_failed, probably from previous session')
self.network.trigger_callback('invoice_status', payment_hash.hex())
def payment_sent(self, chan, payment_hash: bytes): def payment_sent(self, chan, payment_hash: bytes):
self.set_payment_status(payment_hash, PR_PAID) self.set_payment_status(payment_hash, PR_PAID)
preimage = self.get_preimage(payment_hash) preimage = self.get_preimage(payment_hash)
f = self.pending_payments[payment_hash] f = self.pending_payments.get(payment_hash)
if not f.cancelled(): if f and not f.cancelled():
f.set_result((True, preimage, None)) f.set_result((True, preimage, None))
else:
self.logger.info('received unexpected payment_sent, probably from previous session')
self.network.trigger_callback('invoice_status', payment_hash.hex())
self.network.trigger_callback('ln_payment_completed', payment_hash, chan.channel_id) self.network.trigger_callback('ln_payment_completed', payment_hash, chan.channel_id)
def payment_received(self, chan, payment_hash: bytes): def payment_received(self, chan, payment_hash: bytes):