mirror of
https://github.com/lnbits/lnbits-legend.git
synced 2024-11-20 18:51:05 +01:00
73 lines
2.4 KiB
Python
73 lines
2.4 KiB
Python
from quart import g, jsonify
|
|
from http import HTTPStatus
|
|
from lnurl.exceptions import InvalidUrl as LnurlInvalidUrl # type: ignore
|
|
|
|
from lnbits.decorators import api_check_wallet_key, api_validate_post_request
|
|
|
|
from . import offlineshop_ext
|
|
from .crud import (
|
|
get_or_create_shop_by_wallet,
|
|
add_item,
|
|
update_item,
|
|
get_items,
|
|
delete_item_from_shop,
|
|
)
|
|
|
|
|
|
@offlineshop_ext.route("/api/v1/offlineshop", methods=["GET"])
|
|
@api_check_wallet_key("invoice")
|
|
async def api_shop_from_wallet():
|
|
shop = await get_or_create_shop_by_wallet(g.wallet.id)
|
|
items = await get_items(shop.id)
|
|
|
|
try:
|
|
return (
|
|
jsonify({**shop._asdict(), **{"items": [item.values() for item in items],},}),
|
|
HTTPStatus.OK,
|
|
)
|
|
except LnurlInvalidUrl:
|
|
return (
|
|
jsonify({"message": "LNURLs need to be delivered over a publically accessible `https` domain or Tor."}),
|
|
HTTPStatus.UPGRADE_REQUIRED,
|
|
)
|
|
|
|
|
|
@offlineshop_ext.route("/api/v1/offlineshop/items", methods=["POST"])
|
|
@offlineshop_ext.route("/api/v1/offlineshop/items/<item_id>", methods=["PUT"])
|
|
@api_check_wallet_key("invoice")
|
|
@api_validate_post_request(
|
|
schema={
|
|
"name": {"type": "string", "empty": False, "required": True},
|
|
"description": {"type": "string", "empty": False, "required": True},
|
|
"image": {"type": "string", "required": False, "nullable": True},
|
|
"price": {"type": "number", "required": True},
|
|
"unit": {"type": "string", "allowed": ["sat", "USD"], "required": True},
|
|
}
|
|
)
|
|
async def api_add_or_update_item(item_id=None):
|
|
shop = await get_or_create_shop_by_wallet(g.wallet.id)
|
|
if item_id == None:
|
|
await add_item(
|
|
shop.id, g.data["name"], g.data["description"], g.data.get("image"), g.data["price"], g.data["unit"],
|
|
)
|
|
return "", HTTPStatus.CREATED
|
|
else:
|
|
await update_item(
|
|
shop.id,
|
|
item_id,
|
|
g.data["name"],
|
|
g.data["description"],
|
|
g.data.get("image"),
|
|
g.data["price"],
|
|
g.data["unit"],
|
|
)
|
|
return "", HTTPStatus.OK
|
|
|
|
|
|
@offlineshop_ext.route("/api/v1/offlineshop/items/<item_id>", methods=["DELETE"])
|
|
@api_check_wallet_key("invoice")
|
|
async def api_delete_item(item_id):
|
|
shop = await get_or_create_shop_by_wallet(g.wallet.id)
|
|
await delete_item_from_shop(shop.id, item_id)
|
|
return "", HTTPStatus.NO_CONTENT
|