Mirror/robosats
1
0
Fork 0
mirror of https://github.com/RoboSats/robosats.git synced 2025-01-31 02:21:35 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Add stray locked htlc handler (#410)

Browse Source
This commit is contained in:
Reckless_Satoshi 2023-04-06 10:59:50 +00:00 committed by GitHub
parent be060dff34
commit ee8becebd9
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 25 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
api/management/commands/follow_invoices.py
View File

@ -29,11 +29,11 @@ class Command(BaseCommand):
try: try:
self.follow_hold_invoices() self.follow_hold_invoices()
except Exception as e: except Exception as e:
self.stdout.write(str(e)) self.stderr.write(str(e))
try: try:
self.send_payments() self.send_payments()
except Exception as e: except Exception as e:
self.stdout.write(str(e)) self.stderr.write(str(e))
def follow_hold_invoices(self): def follow_hold_invoices(self):
"""Follows and updates LNpayment objects """Follows and updates LNpayment objects
@ -90,15 +90,15 @@ class Command(BaseCommand):
# If it fails at finding the invoice: it has been canceled. # If it fails at finding the invoice: it has been canceled.
# In RoboSats DB we make a distinction between cancelled and returned (LND does not) # In RoboSats DB we make a distinction between cancelled and returned (LND does not)
if "unable to locate invoice" in str(e): if "unable to locate invoice" in str(e):
self.stdout.write(str(e)) self.stderr.write(str(e))
hold_lnpayment.status = LNPayment.Status.CANCEL hold_lnpayment.status = LNPayment.Status.CANCEL
# LND restarted. # LND restarted.
if "wallet locked, unlock it" in str(e): if "wallet locked, unlock it" in str(e):
self.stdout.write(str(timezone.now()) + " :: Wallet Locked") self.stderr.write(str(timezone.now()) + " :: Wallet Locked")
# Other write to logs # Other write to logs
else: else:
self.stdout.write(str(e)) self.stderr.write(str(e))
new_status = LNPayment.Status(hold_lnpayment.status).label new_status = LNPayment.Status(hold_lnpayment.status).label
@ -175,7 +175,7 @@ class Command(BaseCommand):
for lnpayment in queryset: for lnpayment in queryset:
# Checks that this onchain payment is part of an order with a settled escrow # Checks that this onchain payment is part of an order with a settled escrow
if not hasattr(lnpayment, "order_paid_LN"): if not hasattr(lnpayment, "order_paid_LN"):
self.stdout.write(f"Ln payment {str(lnpayment)} has no parent order!") self.stderr.write(f"Ln payment {str(lnpayment)} has no parent order!")
return return
order = lnpayment.order_paid_LN order = lnpayment.order_paid_LN
if ( if (
@ -194,7 +194,7 @@ class Command(BaseCommand):
for onchainpayment in queryset: for onchainpayment in queryset:
# Checks that this onchain payment is part of an order with a settled escrow # Checks that this onchain payment is part of an order with a settled escrow
if not hasattr(onchainpayment, "order_paid_TX"): if not hasattr(onchainpayment, "order_paid_TX"):
self.stdout.write( self.stderr.write(
f"Onchain payment {str(onchainpayment)} has no parent order!" f"Onchain payment {str(onchainpayment)} has no parent order!"
) )
return return
@ -213,7 +213,7 @@ class Command(BaseCommand):
onchainpayment.save() onchainpayment.save()
else: else:
self.stdout.write( self.stderr.write(
f"Onchain payment {str(onchainpayment)} for order {str(order)} escrow is not settled!" f"Onchain payment {str(onchainpayment)} for order {str(order)} escrow is not settled!"
) )
@ -244,13 +244,27 @@ class Command(BaseCommand):
Logics.trade_escrow_received(lnpayment.order_escrow) Logics.trade_escrow_received(lnpayment.order_escrow)
return return
# A locked invoice that has no order attached is an inconsistency (must be due to internal error).
# This has been rarely observed in the experimental coordinator, but the invoice must be cancelled otherwise
# it will take until CLTV expiry height to unlock (risking force closure).
else:
self.stderr.write(
f"Weird! bond with hash {lnpayment.payment_hash} was locked, yet it is not related to any order. It will be instantly cancelled."
)
LNNode.cancel_return_hold_invoice(lnpayment.payment_hash)
lnpayment.status = LNPayment.Status.RETNED
lnpayment.save()
return
except Exception as e: except Exception as e:
self.stdout.write(str(e)) self.stderr.write(
f"Exception when handling newly LOCKED invoice with hash {lnpayment.payment_hash}: {str(e)}"
)
# If the LNPayment goes to CANCEL from INVGEN, the invoice had expired # If the LNPayment goes to CANCEL from INVGEN, the invoice had expired
# If it goes to CANCEL from LOCKED the bond was unlocked. Order had expired in both cases. # If it goes to CANCEL from LOCKED the bond was unlocked. Order had expired in both cases.
# Testing needed for end of time trades! # Testing needed for end of time trades!
if lnpayment.status == LNPayment.Status.CANCEL: elif lnpayment.status == LNPayment.Status.CANCEL:
if hasattr(lnpayment, "order_made"): if hasattr(lnpayment, "order_made"):
Logics.order_expires(lnpayment.order_made) Logics.order_expires(lnpayment.order_made)
return return
@ -265,5 +279,5 @@ class Command(BaseCommand):
# TODO If a lnpayment goes from LOCKED to INVGEN. Totally weird # TODO If a lnpayment goes from LOCKED to INVGEN. Totally weird
# halt the order # halt the order
if lnpayment.status == LNPayment.Status.INVGEN: elif lnpayment.status == LNPayment.Status.INVGEN:
pass pass