mirrors/lnbits-legend
1
0
Fork 0
mirror of https://github.com/lnbits/lnbits-legend.git synced 2024-11-19 09:54:21 +01:00
Code Issues Packages Projects Releases Wiki Activity

Update lndrest.py

Browse Source
This commit is contained in:
Arc 2020-04-26 01:10:57 +01:00 committed by GitHub
parent 4b4a297c3f
commit 976a3d4e5c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 28 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

46
lnbits/wallets/lndrest.py
View File

@ -1,5 +1,6 @@
from os import getenv from os import getenv
import os import os
import base64
from requests import get, post from requests import get, post
from .base import InvoiceResponse, PaymentResponse, PaymentStatus, Wallet from .base import InvoiceResponse, PaymentResponse, PaymentStatus, Wallet
@ -7,7 +8,6 @@ from .base import InvoiceResponse, PaymentResponse, PaymentStatus, Wallet
class LndRestWallet(Wallet): class LndRestWallet(Wallet):
"""https://api.lightning.community/rest/index.html#lnd-rest-api-reference""" """https://api.lightning.community/rest/index.html#lnd-rest-api-reference"""
def __init__(self): def __init__(self):
endpoint = getenv("LND_REST_ENDPOINT") endpoint = getenv("LND_REST_ENDPOINT")
@ -37,8 +37,8 @@ class LndRestWallet(Wallet):
r = get(url=f"{self.endpoint}/v1/payreq/{payment_request}", headers=self.auth_read, verify=self.auth_cert,) r = get(url=f"{self.endpoint}/v1/payreq/{payment_request}", headers=self.auth_read, verify=self.auth_cert,)
print(r) print(r)
if r.ok: if r.ok:
dataa = r.json() checking_id = r.json()["payment_hash"].replace("/","_")
checking_id = dataa["payment_hash"] print(checking_id)
error_message = None error_message = None
ok = True ok = True
@ -46,32 +46,42 @@ class LndRestWallet(Wallet):
def pay_invoice(self, bolt11: str) -> PaymentResponse: def pay_invoice(self, bolt11: str) -> PaymentResponse:
r = post(url=f"{self.endpoint}/v2/withdrawals", headers=self.auth_admin, verify=self.auth_cert, json={"type": "ln", "address": bolt11}) r = post(
url=f"{self.endpoint}/v1/channels/transactions", headers=self.auth_admin, verify=self.auth_cert, json={"payment_request": bolt11}
)
ok, checking_id, fee_msat, error_message = r.ok, None, 0, None ok, checking_id, fee_msat, error_message = r.ok, None, 0, None
r = get(url=f"{self.endpoint}/v1/payreq/{bolt11}", headers=self.auth_admin, verify=self.auth_cert,)
if r.ok: if r.ok:
data = r.json()["data"] checking_id = r.json()["payment_hash"]
checking_id, fee_msat = data["id"], data["fee"] * 1000
else: else:
error_message = r.json()["message"] error_message = r.json()["error"]
return PaymentResponse(ok, checking_id, fee_msat, error_message) return PaymentResponse(ok, checking_id, fee_msat, error_message)
def get_invoice_status(self, checking_id: str) -> PaymentStatus: def get_invoice_status(self, checking_id: str) -> PaymentStatus:
r = get(url=f"{self.endpoint}/v1/charge/{checking_id}", headers=self.auth_invoice, verify=self.auth_cert) checking_id = checking_id.replace("_","/")
print(checking_id)
if not r.ok: r = get(url=f"{self.endpoint}/v1/invoice/{checking_id}", headers=self.auth_invoice, verify=self.auth_cert,)
print(r.json()["settled"])
if not r or r.json()["settled"] == False:
return PaymentStatus(None) return PaymentStatus(None)
statuses = {0: None, 1: True, -1: False} return PaymentStatus(r.json()["settled"])
return PaymentStatus(statuses[r.json()["data"]["status"]])
def get_payment_status(self, checking_id: str) -> PaymentStatus: def get_payment_status(self, checking_id: str) -> PaymentStatus:
r = get(url=f"{self.endpoint}/v1/withdrawal/{checking_id}", headers=self.auth_admin, verify=self.auth_cert)
r = get(url=f"{self.endpoint}/v1/payments", headers=self.auth_admin, verify=self.auth_cert, params={"include_incomplete": True, "max_payments": "20"})
if not r.ok: if not r.ok:
return PaymentStatus(None) return PaymentStatus(r, None)
statuses = {0: None, 1: True, -1: False} payments = [p for p in r.json()["payments"] if p["payment_hash"] == checking_id]
return PaymentStatus(statuses[r.json()["data"]["status"]]) print(checking_id)
payment = payments[0] if payments else None
# check payment.status: https://api.lightning.community/rest/index.html?python#peersynctype
statuses = {"UNKNOWN": None, "IN_FLIGHT": None, "SUCCEEDED": True, "FAILED": False}
return PaymentStatus(statuses[payment["status"]])