mirror of
https://github.com/lnbits/lnbits-legend.git
synced 2025-02-25 15:10:41 +01:00
fee40d7321
* F541 fix remove unused workflow and combine linters into one add lnbits/static to ruff ignore remote setupnode ignore upgrades for mypy ignore F401 for __init__ files unused noqa ignore upgrades for black F821: undefine name disabled and logged webhook_listener for opennode and lnpay because they are obvisouly not working E402: module level import not at top of file fixup revert breaking changes wait for PR #1876 https://github.com/lnbits/lnbits/pull/1876 E721 fixes, only popped up for python3.9 not 3.10 [REFACTOR] core/__init__ to not have circular import issues WIP add db for backwards compat fix pyright make mypy happy again pyright did not catch those, i think mypy got confused with relative imports. maybe we should use absolute ones everywhere E402: module level import not at top of file dont forget to add core_app rebase on ruff pr f remo format * fix clnrest * ignore E402 in conftest * refactoring issues --------- Co-authored-by: jacksn <jkranawetter05@gmail.com>
60 lines
1.8 KiB
Python
60 lines
1.8 KiB
Python
import asyncio
|
|
import datetime
|
|
from http import HTTPStatus
|
|
|
|
from fastapi import APIRouter, HTTPException
|
|
from loguru import logger
|
|
|
|
from lnbits import bolt11
|
|
|
|
from ..crud import get_standalone_payment
|
|
from ..tasks import api_invoice_listeners
|
|
|
|
public_router = APIRouter()
|
|
|
|
|
|
@public_router.get("/public/v1/payment/{payment_hash}")
|
|
async def api_public_payment_longpolling(payment_hash):
|
|
payment = await get_standalone_payment(payment_hash)
|
|
|
|
if not payment:
|
|
raise HTTPException(
|
|
status_code=HTTPStatus.NOT_FOUND, detail="Payment does not exist."
|
|
)
|
|
elif not payment.pending:
|
|
return {"status": "paid"}
|
|
|
|
try:
|
|
invoice = bolt11.decode(payment.bolt11)
|
|
expiration = datetime.datetime.fromtimestamp(invoice.date + invoice.expiry)
|
|
if expiration < datetime.datetime.now():
|
|
return {"status": "expired"}
|
|
except Exception:
|
|
raise HTTPException(
|
|
status_code=HTTPStatus.BAD_REQUEST, detail="Invalid bolt11 invoice."
|
|
)
|
|
|
|
payment_queue = asyncio.Queue(0)
|
|
|
|
logger.debug(f"adding standalone invoice listener for hash: {payment_hash}")
|
|
api_invoice_listeners[payment_hash] = payment_queue
|
|
|
|
response = None
|
|
|
|
async def payment_info_receiver():
|
|
for payment in await payment_queue.get():
|
|
if payment.payment_hash == payment_hash:
|
|
nonlocal response
|
|
response = {"status": "paid"}
|
|
|
|
async def timeouter(cancel_scope):
|
|
await asyncio.sleep(45)
|
|
cancel_scope.cancel()
|
|
|
|
cancel_scope = asyncio.create_task(payment_info_receiver())
|
|
asyncio.create_task(timeouter(cancel_scope))
|
|
|
|
if response:
|
|
return response
|
|
else:
|
|
raise HTTPException(status_code=HTTPStatus.REQUEST_TIMEOUT, detail="timeout")
|