mirrors/lnbits-legend
1
0
Fork 0
mirror of https://github.com/lnbits/lnbits-legend.git synced 2024-11-20 18:51:05 +01:00
Code Issues Packages Projects Releases Wiki Activity

refund notification

Browse Source
This commit is contained in:
Gene Takavic 2022-09-23 17:11:19 +02:00
parent 632d35682d
commit ea2d66fbd6
1 changed files with 21 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
lnbits/extensions/boltcards/tasks.py
View File

@ -2,12 +2,13 @@ import asyncio
import json
import httpx
from loguru import logger
from lnbits.core import db as core_db
from lnbits.core.models import Payment
from lnbits.tasks import register_invoice_listener
from .crud import create_refund, get_hit
from .crud import create_refund, get_card, get_hit
async def wait_for_paid_invoices():
@ -34,6 +35,25 @@ async def on_invoice_paid(payment: Payment) -> None:
)
await mark_webhook_sent(payment, 1)
card = await get_card(hit.card_id)
if card.webhook_url:
async with httpx.AsyncClient() as client:
try:
r = await client.post(
card.webhook_url,
json={
"notification": "card_refund",
"payment_hash": payment.payment_hash,
"payment_request": payment.bolt11,
"card_external_id": card.external_id,
"card_name": card.card_name,
"amount": int(payment.amount / 1000),
},
timeout=40,
)
except Exception as exc:
logger.error("Caught exception when dispatching webhook url:", exc)
async def mark_webhook_sent(payment: Payment, status: int) -> None:
payment.extra["wh_status"] = status