From 9b6b1e87b91f41fa69ea7b49dee3c5b8a89adf8e Mon Sep 17 00:00:00 2001 From: Vlad Stan Date: Tue, 28 Feb 2023 09:19:27 +0200 Subject: [PATCH] chore: get the extension started --- __init__.py | 2 +- tasks.py | 33 +++++++++++++++++++++++++++++++++ views.py | 3 ++- views_api.py | 0 4 files changed, 36 insertions(+), 2 deletions(-) create mode 100644 tasks.py create mode 100644 views_api.py 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