basic offlineshop functionality.

2021-03-07 00:08:36 -03:00
parent 88eb8e0e78
commit 732d06c1e5
15 changed files with 842 additions and 8 deletions
@@ -0,0 +1,72 @@
+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._asdict() 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},
+        "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