aiolabs/lnbits
1
0
Fork 0
Code Issues 1 Pull requests Projects Releases Packages Wiki Activity Actions

feat: add internal_invoice_queue_put to get rid of dynamic import (#3223)

Browse source
This commit is contained in:
dni ⚡ 2025-06-30 12:55:23 +02:00
parent 695e9b6471
commit 26eb7a449c
No known key found for this signature in database
GPG key ID: D1F416F29AD26E87
2 changed files with 9 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

6
lnbits/core/services/payments.py
View file

@ -20,6 +20,7 @@ from lnbits.exceptions import InvoiceError, PaymentError
from lnbits.fiat import get_fiat_provider from lnbits.fiat import get_fiat_provider
from lnbits.helpers import check_callback_url from lnbits.helpers import check_callback_url
from lnbits.settings import settings from lnbits.settings import settings
from lnbits.tasks import create_task, internal_invoice_queue_put
from lnbits.utils.crypto import fake_privkey, random_secret_and_hash from lnbits.utils.crypto import fake_privkey, random_secret_and_hash
from lnbits.utils.exchange_rates import fiat_amount_as_satoshis, satoshis_amount_as_fiat from lnbits.utils.exchange_rates import fiat_amount_as_satoshis, satoshis_amount_as_fiat
from lnbits.wallets import fake_wallet, get_funding_source from lnbits.wallets import fake_wallet, get_funding_source
@ -424,10 +425,7 @@ async def update_wallet_balance(
) )
payment.status = PaymentState.SUCCESS payment.status = PaymentState.SUCCESS
await update_payment(payment, conn=conn) await update_payment(payment, conn=conn)
# notify receiver asynchronously await internal_invoice_queue_put(payment.checking_id)
from lnbits.tasks import internal_invoice_queue
await internal_invoice_queue.put(payment.checking_id)
async def check_wallet_limits( async def check_wallet_limits(

7
lnbits/tasks.py
View file

@ -107,6 +107,13 @@ def register_invoice_listener(send_chan: asyncio.Queue, name: Optional[str] = No
internal_invoice_queue: asyncio.Queue = asyncio.Queue(0) internal_invoice_queue: asyncio.Queue = asyncio.Queue(0)
async def internal_invoice_queue_put(checking_id: str) -> None:
"""
A method to call when it wants to notify about an internal invoice payment.
"""
await internal_invoice_queue.put(checking_id)
async def internal_invoice_listener() -> None: async def internal_invoice_listener() -> None:
""" """
internal_invoice_queue will be filled directly in core/services.py internal_invoice_queue will be filled directly in core/services.py