diff --git a/__init__.py b/__init__.py index 6757f5a..9e188f2 100644 --- a/__init__.py +++ b/__init__.py @@ -21,7 +21,7 @@ nostrmarket_static_files = [ ] -def market_renderer(): +def nostrmarket_renderer(): return template_renderer(["lnbits/extensions/nostrmarket/templates"]) diff --git a/tasks.py b/tasks.py new file mode 100644 index 0000000..c2a1abf --- /dev/null +++ b/tasks.py @@ -0,0 +1,33 @@ +import asyncio +import json +import threading + +import httpx +import websocket +from loguru import logger + +from lnbits.core.models import Payment +from lnbits.helpers import url_for +from lnbits.tasks import register_invoice_listener + + + +async def wait_for_paid_invoices(): + invoice_queue = asyncio.Queue() + register_invoice_listener(invoice_queue) + + while True: + payment = await invoice_queue.get() + await on_invoice_paid(payment) + + +async def on_invoice_paid(payment: Payment) -> None: + if payment.extra.get("tag") != "market": + return + + print("### on_invoice_paid") + + +async def subscribe_nostrclient_ws(): + print("### subscribe_nostrclient_ws") + diff --git a/views.py b/views.py index 568d515..d836f29 100644 --- a/views.py +++ b/views.py @@ -1,7 +1,8 @@ import json from http import HTTPStatus -from fastapi import Depends, Request, HTMLResponse +from fastapi import Depends, Request +from starlette.responses import HTMLResponse from fastapi.templating import Jinja2Templates from loguru import logger diff --git a/views_api.py b/views_api.py new file mode 100644 index 0000000..e69de29