mirror of
https://github.com/lnbits/lnbits.git
synced 2025-10-11 13:02:39 +02:00
Merge pull request #1174 from lnbits/uniwsupdates
Adds PoS websocket endpoint
This commit is contained in:
@@ -3,7 +3,7 @@ import asyncio
|
|||||||
from loguru import logger
|
from loguru import logger
|
||||||
|
|
||||||
from lnbits.core.models import Payment
|
from lnbits.core.models import Payment
|
||||||
from lnbits.core.services import create_invoice, pay_invoice
|
from lnbits.core.services import create_invoice, pay_invoice, websocketUpdater
|
||||||
from lnbits.helpers import get_current_extension_name
|
from lnbits.helpers import get_current_extension_name
|
||||||
from lnbits.tasks import register_invoice_listener
|
from lnbits.tasks import register_invoice_listener
|
||||||
|
|
||||||
@@ -26,6 +26,16 @@ async def on_invoice_paid(payment: Payment) -> None:
|
|||||||
tpos = await get_tpos(payment.extra.get("tposId"))
|
tpos = await get_tpos(payment.extra.get("tposId"))
|
||||||
tipAmount = payment.extra.get("tipAmount")
|
tipAmount = payment.extra.get("tipAmount")
|
||||||
|
|
||||||
|
strippedPayment = {
|
||||||
|
"amount": payment.amount,
|
||||||
|
"fee": payment.fee,
|
||||||
|
"checking_id": payment.checking_id,
|
||||||
|
"payment_hash": payment.payment_hash,
|
||||||
|
"bolt11": payment.bolt11,
|
||||||
|
}
|
||||||
|
|
||||||
|
await websocketUpdater(payment.extra.get("tposId"), str(strippedPayment))
|
||||||
|
|
||||||
if tipAmount is None:
|
if tipAmount is None:
|
||||||
# no tip amount
|
# no tip amount
|
||||||
return
|
return
|
||||||
|
Reference in New Issue
Block a user