highperfocused/lnbits
1
0
Fork 0
mirror of https://github.com/lnbits/lnbits.git synced 2025-10-09 20:12:34 +02:00
Code Issues Packages Projects Releases Wiki Activity

fix: lntips payment lookup error handling (#1374)

Browse Source
This commit is contained in:
calle
2023-01-18 12:02:32 +01:00
committed by GitHub
parent 2b3b8cd85e
commit 9d3290cd9a
1 changed files with 25 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

44
lnbits/wallets/lntips.py
View File

@@ -113,31 +113,37 @@ class LnTipsWallet(Wallet):
return PaymentResponse(True, checking_id, fee_msat, preimage, None) return PaymentResponse(True, checking_id, fee_msat, preimage, None)
async def get_invoice_status(self, checking_id: str) -> PaymentStatus: async def get_invoice_status(self, checking_id: str) -> PaymentStatus:
async with httpx.AsyncClient() as client: try:
r = await client.post( async with httpx.AsyncClient() as client:
f"{self.endpoint}/api/v1/invoicestatus/{checking_id}", r = await client.post(
headers=self.auth, f"{self.endpoint}/api/v1/invoicestatus/{checking_id}",
) headers=self.auth,
)
if r.is_error or len(r.text) == 0: if r.is_error or len(r.text) == 0:
raise Exception
data = r.json()
return PaymentStatus(data["paid"])
except:
return PaymentStatus(None) return PaymentStatus(None)
data = r.json()
return PaymentStatus(data["paid"])
async def get_payment_status(self, checking_id: str) -> PaymentStatus: async def get_payment_status(self, checking_id: str) -> PaymentStatus:
async with httpx.AsyncClient() as client: try:
r = await client.post( async with httpx.AsyncClient() as client:
url=f"{self.endpoint}/api/v1/paymentstatus/{checking_id}", r = await client.post(
headers=self.auth, url=f"{self.endpoint}/api/v1/paymentstatus/{checking_id}",
) headers=self.auth,
)
if r.is_error: if r.is_error:
raise Exception
data = r.json()
paid_to_status = {False: None, True: True}
return PaymentStatus(paid_to_status[data.get("paid")])
except:
return PaymentStatus(None) return PaymentStatus(None)
data = r.json()
paid_to_status = {False: None, True: True}
return PaymentStatus(paid_to_status[data.get("paid")])
async def paid_invoices_stream(self) -> AsyncGenerator[str, None]: async def paid_invoices_stream(self) -> AsyncGenerator[str, None]:
last_connected = None last_connected = None