-
-
-
-
- Send onchain funds offchain (BTC -> LN)
-
-
-
-
- Send offchain funds to onchain address (LN -> BTC)
-
-
-
-
- Check all pending swaps if they can be refunded.
-
-
-
-
-
-
-
-
-
Swaps (In)
-
-
- Export to CSV
-
-
-
-
-
-
-
Reverse Swaps (Out)
-
-
- Export to CSV
-
-
+
+ {% include "boltz/_buttons.html" %} {% include
+ "boltz/_submarineSwapList.html" %} {% include
+ "boltz/_reverseSubmarineSwapList.html" %} {% include
+ "boltz/_autoReverseSwapList.html" %}
-
-
-
- {{SITE_TITLE}} Boltz extension
-
-
-
- {% include "boltz/_api_docs.html" %}
-
-
+
+ {% include "boltz/_api_docs.html" %}
-
-
-
-
-
-
-
-
-
-
-
- Cancel
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- Create Onchain TX when transaction is in mempool, but not
- confirmed yet.
-
-
-
-
-
-
- Cancel
-
-
-
-
-
-
-
-
-
-
- {% raw %}
- Bitcoin On-Chain TX
- Expected amount (sats): {{ qrCodeDialog.data.expected_amount }}
-
- Expected amount (btc): {{ qrCodeDialog.data.expected_amount_btc
- }}
- Onchain Address: {{ qrCodeDialog.data.address }}
- {% endraw %}
-
-
- Copy On-Chain Address
- Close
-
-
-
-
-
-
- {% raw %}
- Wallet: {{ statusDialog.data.wallet }}
- Boltz Status: {{ statusDialog.data.boltz }}
- Mempool Status: {{ statusDialog.data.mempool }}
- Blockheight timeout: {{ statusDialog.data.timeout_block_height
- }}
- {% endraw %}
-
-
- Refund
-
- Download refundfile
- Close
-
-
-
-
-
- pending swaps
-
- {% raw %}
-
-
-
-
- {{ col.label }}
-
-
-
-
-
-
-
- refund swap
-
-
- dowload refund file
-
-
- open tx on mempool.space
-
-
-
- {{ col.value }}
-
-
-
- {% endraw %}
-
- pending reverse swaps
-
- {% raw %}
-
-
-
-
- {{ col.label }}
-
-
-
-
-
-
-
- open tx on mempool.space
-
-
-
- {{ col.value }}
-
-
-
- {% endraw %}
-
-
- Close
-
-
-
+ {% include "boltz/_submarineSwapDialog.html" %} {% include
+ "boltz/_reverseSubmarineSwapDialog.html" %} {% include
+ "boltz/_autoReverseSwapDialog.html" %} {% include "boltz/_qrDialog.html" %} {%
+ include "boltz/_statusDialog.html" %}
{% endblock %} {% block scripts %} {{ window_vars(user) }}
diff --git a/lnbits/extensions/boltz/utils.py b/lnbits/extensions/boltz/utils.py
index 4fb2edda..7623fb6f 100644
--- a/lnbits/extensions/boltz/utils.py
+++ b/lnbits/extensions/boltz/utils.py
@@ -1,10 +1,25 @@
+import asyncio
import calendar
import datetime
+from typing import Awaitable
-import httpx
-from loguru import logger
+from boltz_client.boltz import BoltzClient, BoltzConfig
-from lnbits.core.services import fee_reserve, get_wallet
+from lnbits.core.services import fee_reserve, get_wallet, pay_invoice
+from lnbits.settings import settings
+
+from .models import ReverseSubmarineSwap
+
+
+def create_boltz_client() -> BoltzClient:
+ config = BoltzConfig(
+ network=settings.boltz_network,
+ api_url=settings.boltz_url,
+ mempool_url=f"{settings.boltz_mempool_space_url}/api",
+ mempool_ws_url=f"{settings.boltz_mempool_space_url_ws}/api/v1/ws",
+ referral_id="lnbits",
+ )
+ return BoltzClient(config)
async def check_balance(data) -> bool:
@@ -23,22 +38,50 @@ def get_timestamp():
return calendar.timegm(date.utctimetuple())
-def req_wrap(funcname, *args, **kwargs):
- try:
+async def execute_reverse_swap(client, swap: ReverseSubmarineSwap):
+ # claim_task is watching onchain address for the lockup transaction to arrive / confirm
+ # and if the lockup is there, claim the onchain revealing preimage for hold invoice
+ claim_task = asyncio.create_task(
+ client.claim_reverse_swap(
+ privkey_wif=swap.claim_privkey,
+ preimage_hex=swap.preimage,
+ lockup_address=swap.lockup_address,
+ receive_address=swap.onchain_address,
+ redeem_script_hex=swap.redeem_script,
+ )
+ )
+ # pay_task is paying the hold invoice which gets held until you reveal your preimage when claiming your onchain funds
+ pay_task = pay_invoice_and_update_status(
+ swap.id,
+ claim_task,
+ pay_invoice(
+ wallet_id=swap.wallet,
+ payment_request=swap.invoice,
+ description=f"reverse swap for {swap.onchain_amount} sats on boltz.exchange",
+ extra={"tag": "boltz", "swap_id": swap.id, "reverse": True},
+ ),
+ )
+
+ # they need to run be concurrently, because else pay_task will lock the eventloop and claim_task will not be executed.
+ # the lockup transaction can only happen after you pay the invoice, which cannot be redeemed immediatly -> hold invoice
+ # after getting the lockup transaction, you can claim the onchain funds revealing the preimage for boltz to redeem the hold invoice
+ asyncio.gather(claim_task, pay_task)
+
+
+def pay_invoice_and_update_status(
+ swap_id: str, wstask: asyncio.Task, awaitable: Awaitable
+) -> asyncio.Task:
+ async def _pay_invoice(awaitable):
+ from .crud import update_swap_status
+
try:
- func = getattr(httpx, funcname)
- except AttributeError:
- logger.error('httpx function not found "%s"' % funcname)
- else:
- res = func(*args, timeout=30, **kwargs)
- res.raise_for_status()
- return res
- except httpx.RequestError as exc:
- msg = f"Unreachable: {exc.request.url!r}."
- logger.error(msg)
- raise
- except httpx.HTTPStatusError as exc:
- msg = f"HTTP Status Error: {exc.response.status_code} while requesting {exc.request.url!r}."
- logger.error(msg)
- logger.error(exc.response.json()["error"])
- raise
+ awaited = await awaitable
+ await update_swap_status(swap_id, "complete")
+ return awaited
+ except asyncio.exceptions.CancelledError:
+ """lnbits process was exited, do nothing and handle it in startup script"""
+ except:
+ wstask.cancel()
+ await update_swap_status(swap_id, "failed")
+
+ return asyncio.create_task(_pay_invoice(awaitable))
diff --git a/lnbits/extensions/boltz/views.py b/lnbits/extensions/boltz/views.py
index b6864113..4b0e6d53 100644
--- a/lnbits/extensions/boltz/views.py
+++ b/lnbits/extensions/boltz/views.py
@@ -1,11 +1,10 @@
from urllib.parse import urlparse
-from fastapi import Request
-from fastapi.params import Depends
+from fastapi import Depends, Request
from fastapi.templating import Jinja2Templates
from starlette.responses import HTMLResponse
-from lnbits.core.models import Payment, User
+from lnbits.core.models import User
from lnbits.decorators import check_user_exists
from . import boltz_ext, boltz_renderer
@@ -16,7 +15,6 @@ templates = Jinja2Templates(directory="templates")
@boltz_ext.get("/", response_class=HTMLResponse)
async def index(request: Request, user: User = Depends(check_user_exists)):
root_url = urlparse(str(request.url)).netloc
- wallet_ids = [wallet.id for wallet in user.wallets]
return boltz_renderer().TemplateResponse(
"boltz/index.html",
{"request": request, "user": user.dict(), "root_url": root_url},
diff --git a/lnbits/extensions/boltz/views_api.py b/lnbits/extensions/boltz/views_api.py
index 34f4033e..ab32fac9 100644
--- a/lnbits/extensions/boltz/views_api.py
+++ b/lnbits/extensions/boltz/views_api.py
@@ -1,34 +1,23 @@
-from datetime import datetime
from http import HTTPStatus
from typing import List
-import httpx
-from fastapi import status
-from fastapi.encoders import jsonable_encoder
-from fastapi.param_functions import Body
-from fastapi.params import Depends, Query
-from loguru import logger
-from pydantic import BaseModel
+from fastapi import Depends, Query, status
from starlette.exceptions import HTTPException
-from starlette.requests import Request
from lnbits.core.crud import get_user
+from lnbits.core.services import create_invoice
from lnbits.decorators import WalletTypeInfo, get_key_type, require_admin_key
+from lnbits.helpers import urlsafe_short_hash
from lnbits.settings import settings
from . import boltz_ext
-from .boltz import (
- create_refund_tx,
- create_reverse_swap,
- create_swap,
- get_boltz_pairs,
- get_swap_status,
-)
from .crud import (
+ create_auto_reverse_submarine_swap,
create_reverse_submarine_swap,
create_submarine_swap,
- get_pending_reverse_submarine_swaps,
- get_pending_submarine_swaps,
+ delete_auto_reverse_submarine_swap,
+ get_auto_reverse_submarine_swap_by_wallet,
+ get_auto_reverse_submarine_swaps,
get_reverse_submarine_swap,
get_reverse_submarine_swaps,
get_submarine_swap,
@@ -36,12 +25,14 @@ from .crud import (
update_swap_status,
)
from .models import (
+ AutoReverseSubmarineSwap,
+ CreateAutoReverseSubmarineSwap,
CreateReverseSubmarineSwap,
CreateSubmarineSwap,
ReverseSubmarineSwap,
SubmarineSwap,
)
-from .utils import check_balance
+from .utils import check_balance, create_boltz_client, execute_reverse_swap
@boltz_ext.get(
@@ -76,17 +67,8 @@ async def api_submarineswap(
):
wallet_ids = [g.wallet.id]
if all_wallets:
- wallet_ids = (await get_user(g.wallet.user)).wallet_ids
-
- for swap in await get_pending_submarine_swaps(wallet_ids):
- swap_status = get_swap_status(swap)
- if swap_status.hit_timeout:
- if not swap_status.has_lockup:
- logger.warning(
- f"Boltz - swap: {swap.id} hit timeout, but no lockup tx..."
- )
- await update_swap_status(swap.id, "timeout")
-
+ user = await get_user(g.wallet.user)
+ wallet_ids = user.wallet_ids if user else []
return [swap.dict() for swap in await get_submarine_swaps(wallet_ids)]
@@ -109,35 +91,29 @@ async def api_submarineswap(
},
},
)
-async def api_submarineswap_refund(
- swap_id: str,
- g: WalletTypeInfo = Depends(require_admin_key),
-):
- if swap_id == None:
+async def api_submarineswap_refund(swap_id: str):
+ if not swap_id:
raise HTTPException(
status_code=HTTPStatus.BAD_REQUEST, detail="swap_id missing"
)
-
swap = await get_submarine_swap(swap_id)
- if swap == None:
+ if not swap:
raise HTTPException(
status_code=HTTPStatus.NOT_FOUND, detail="swap does not exist."
)
-
if swap.status != "pending":
raise HTTPException(
status_code=HTTPStatus.METHOD_NOT_ALLOWED, detail="swap is not pending."
)
- try:
- await create_refund_tx(swap)
- except httpx.RequestError as exc:
- raise HTTPException(
- status_code=HTTPStatus.INTERNAL_SERVER_ERROR,
- detail=f"Unreachable: {exc.request.url!r}.",
- )
- except Exception as exc:
- raise HTTPException(status_code=HTTPStatus.METHOD_NOT_ALLOWED, detail=str(exc))
+ client = create_boltz_client()
+ await client.refund_swap(
+ privkey_wif=swap.refund_privkey,
+ lockup_address=swap.address,
+ receive_address=swap.refund_address,
+ redeem_script_hex=swap.redeem_script,
+ timeout_block_height=swap.timeout_block_height,
+ )
await update_swap_status(swap.id, "refunded")
return swap
@@ -153,37 +129,43 @@ async def api_submarineswap_refund(
""",
response_description="create swap",
response_model=SubmarineSwap,
+ dependencies=[Depends(require_admin_key)],
responses={
- 405: {"description": "not allowed method, insufficient balance"},
+ 405: {
+ "description": "auto reverse swap is active, a swap would immediatly be swapped out again."
+ },
500: {"description": "boltz error"},
},
)
-async def api_submarineswap_create(
- data: CreateSubmarineSwap,
- wallet: WalletTypeInfo = Depends(require_admin_key),
-):
- try:
- swap_data = await create_swap(data)
- except httpx.RequestError as exc:
+async def api_submarineswap_create(data: CreateSubmarineSwap):
+
+ auto_swap = await get_auto_reverse_submarine_swap_by_wallet(data.wallet)
+ if auto_swap:
raise HTTPException(
- status_code=HTTPStatus.INTERNAL_SERVER_ERROR,
- detail=f"Unreachable: {exc.request.url!r}.",
+ status_code=HTTPStatus.METHOD_NOT_ALLOWED,
+ detail="auto reverse swap is active, a swap would immediatly be swapped out again.",
)
- except Exception as exc:
- raise HTTPException(status_code=HTTPStatus.METHOD_NOT_ALLOWED, detail=str(exc))
- except httpx.HTTPStatusError as exc:
- raise HTTPException(
- status_code=exc.response.status_code, detail=exc.response.json()["error"]
- )
- swap = await create_submarine_swap(swap_data)
- return swap.dict()
+
+ client = create_boltz_client()
+ swap_id = urlsafe_short_hash()
+ payment_hash, payment_request = await create_invoice(
+ wallet_id=data.wallet,
+ amount=data.amount,
+ memo=f"swap of {data.amount} sats on boltz.exchange",
+ extra={"tag": "boltz", "swap_id": swap_id},
+ )
+ refund_privkey_wif, swap = client.create_swap(payment_request)
+ new_swap = await create_submarine_swap(
+ data, swap, swap_id, refund_privkey_wif, payment_hash
+ )
+ return new_swap.dict() if new_swap else None
# REVERSE SWAP
@boltz_ext.get(
"/api/v1/swap/reverse",
name=f"boltz.get /swap/reverse",
- summary="get a list of reverse swaps a swap",
+ summary="get a list of reverse swaps",
description="""
This endpoint gets a list of reverse swaps.
""",
@@ -192,13 +174,14 @@ async def api_submarineswap_create(
response_model=List[ReverseSubmarineSwap],
)
async def api_reverse_submarineswap(
- g: WalletTypeInfo = Depends(get_key_type), # type:ignore
+ g: WalletTypeInfo = Depends(get_key_type),
all_wallets: bool = Query(False),
):
wallet_ids = [g.wallet.id]
if all_wallets:
- wallet_ids = (await get_user(g.wallet.user)).wallet_ids
- return [swap.dict() for swap in await get_reverse_submarine_swaps(wallet_ids)]
+ user = await get_user(g.wallet.user)
+ wallet_ids = user.wallet_ids if user else []
+ return [swap for swap in await get_reverse_submarine_swaps(wallet_ids)]
@boltz_ext.post(
@@ -211,6 +194,7 @@ async def api_reverse_submarineswap(
""",
response_description="create reverse swap",
response_model=ReverseSubmarineSwap,
+ dependencies=[Depends(require_admin_key)],
responses={
405: {"description": "not allowed method, insufficient balance"},
500: {"description": "boltz error"},
@@ -218,30 +202,88 @@ async def api_reverse_submarineswap(
)
async def api_reverse_submarineswap_create(
data: CreateReverseSubmarineSwap,
- wallet: WalletTypeInfo = Depends(require_admin_key),
-):
+) -> ReverseSubmarineSwap:
if not await check_balance(data):
raise HTTPException(
status_code=HTTPStatus.METHOD_NOT_ALLOWED, detail="Insufficient balance."
)
+ client = create_boltz_client()
+ claim_privkey_wif, preimage_hex, swap = client.create_reverse_swap(
+ amount=data.amount
+ )
+ new_swap = await create_reverse_submarine_swap(
+ data, claim_privkey_wif, preimage_hex, swap
+ )
+ await execute_reverse_swap(client, new_swap)
+ return new_swap
- try:
- swap_data, task = await create_reverse_swap(data)
- except httpx.RequestError as exc:
- raise HTTPException(
- status_code=HTTPStatus.INTERNAL_SERVER_ERROR,
- detail=f"Unreachable: {exc.request.url!r}.",
- )
- except httpx.HTTPStatusError as exc:
- raise HTTPException(
- status_code=exc.response.status_code, detail=exc.response.json()["error"]
- )
- except Exception as exc:
- raise HTTPException(status_code=HTTPStatus.METHOD_NOT_ALLOWED, detail=str(exc))
- swap = await create_reverse_submarine_swap(swap_data)
- return swap.dict()
+@boltz_ext.get(
+ "/api/v1/swap/reverse/auto",
+ name=f"boltz.get /swap/reverse/auto",
+ summary="get a list of auto reverse swaps",
+ description="""
+ This endpoint gets a list of auto reverse swaps.
+ """,
+ response_description="list of auto reverse swaps",
+ dependencies=[Depends(get_key_type)],
+ response_model=List[AutoReverseSubmarineSwap],
+)
+async def api_auto_reverse_submarineswap(
+ g: WalletTypeInfo = Depends(get_key_type),
+ all_wallets: bool = Query(False),
+):
+ wallet_ids = [g.wallet.id]
+ if all_wallets:
+ user = await get_user(g.wallet.user)
+ wallet_ids = user.wallet_ids if user else []
+ return [swap.dict() for swap in await get_auto_reverse_submarine_swaps(wallet_ids)]
+
+
+@boltz_ext.post(
+ "/api/v1/swap/reverse/auto",
+ status_code=status.HTTP_201_CREATED,
+ name=f"boltz.post /swap/reverse/auto",
+ summary="create a auto reverse submarine swap",
+ description="""
+ This endpoint creates a auto reverse submarine swap
+ """,
+ response_description="create auto reverse swap",
+ response_model=AutoReverseSubmarineSwap,
+ dependencies=[Depends(require_admin_key)],
+ responses={
+ 405: {
+ "description": "auto reverse swap is active, only 1 swap per wallet possible."
+ },
+ },
+)
+async def api_auto_reverse_submarineswap_create(data: CreateAutoReverseSubmarineSwap):
+
+ auto_swap = await get_auto_reverse_submarine_swap_by_wallet(data.wallet)
+ if auto_swap:
+ raise HTTPException(
+ status_code=HTTPStatus.METHOD_NOT_ALLOWED,
+ detail="auto reverse swap is active, only 1 swap per wallet possible.",
+ )
+
+ swap = await create_auto_reverse_submarine_swap(data)
+ return swap.dict() if swap else None
+
+
+@boltz_ext.delete(
+ "/api/v1/swap/reverse/auto/{swap_id}",
+ name=f"boltz.delete /swap/reverse/auto",
+ summary="delete a auto reverse submarine swap",
+ description="""
+ This endpoint deletes a auto reverse submarine swap
+ """,
+ response_description="delete auto reverse swap",
+ dependencies=[Depends(require_admin_key)],
+)
+async def api_auto_reverse_submarineswap_delete(swap_id: str):
+ await delete_auto_reverse_submarine_swap(swap_id)
+ return "OK"
@boltz_ext.post(
@@ -252,65 +294,22 @@ async def api_reverse_submarineswap_create(
This endpoint attempts to get the status of the swap.
""",
response_description="status of swap json",
+ dependencies=[Depends(require_admin_key)],
responses={
404: {"description": "when swap_id is not found"},
},
)
-async def api_swap_status(
- swap_id: str, wallet: WalletTypeInfo = Depends(require_admin_key)
-):
+async def api_swap_status(swap_id: str):
swap = await get_submarine_swap(swap_id) or await get_reverse_submarine_swap(
swap_id
)
- if swap == None:
+ if not swap:
raise HTTPException(
status_code=HTTPStatus.NOT_FOUND, detail="swap does not exist."
)
- try:
- status = get_swap_status(swap)
- except httpx.RequestError as exc:
- raise HTTPException(
- status_code=HTTPStatus.INTERNAL_SERVER_ERROR,
- detail=f"Unreachable: {exc.request.url!r}.",
- )
- except Exception as exc:
- raise HTTPException(
- status_code=HTTPStatus.INTERNAL_SERVER_ERROR, detail=str(exc)
- )
- return status
-
-@boltz_ext.post(
- "/api/v1/swap/check",
- name=f"boltz.swap_check",
- summary="list all pending swaps",
- description="""
- This endpoint gives you 2 lists of pending swaps and reverse swaps.
- """,
- response_description="list of pending swaps",
-)
-async def api_check_swaps(
- g: WalletTypeInfo = Depends(require_admin_key),
- all_wallets: bool = Query(False),
-):
- wallet_ids = [g.wallet.id]
- if all_wallets:
- wallet_ids = (await get_user(g.wallet.user)).wallet_ids
- status = []
- try:
- for swap in await get_pending_submarine_swaps(wallet_ids):
- status.append(get_swap_status(swap))
- for reverseswap in await get_pending_reverse_submarine_swaps(wallet_ids):
- status.append(get_swap_status(reverseswap))
- except httpx.RequestError as exc:
- raise HTTPException(
- status_code=HTTPStatus.INTERNAL_SERVER_ERROR,
- detail=f"Unreachable: {exc.request.url!r}.",
- )
- except Exception as exc:
- raise HTTPException(
- status_code=HTTPStatus.INTERNAL_SERVER_ERROR, detail=str(exc)
- )
+ client = create_boltz_client()
+ status = client.swap_status(swap.boltz_id)
return status
@@ -325,14 +324,5 @@ async def api_check_swaps(
response_model=dict,
)
async def api_boltz_config():
- try:
- res = get_boltz_pairs()
- except httpx.RequestError as exc:
- raise HTTPException(
- status_code=HTTPStatus.INTERNAL_SERVER_ERROR,
- detail=f"Unreachable: {exc.request.url!r}.",
- )
- except Exception as e:
- raise HTTPException(status_code=HTTPStatus.INTERNAL_SERVER_ERROR, detail=str(e))
-
- return res["pairs"]["BTC/BTC"]
+ client = create_boltz_client()
+ return {"minimal": client.limit_minimal, "maximal": client.limit_maximal}
diff --git a/lnbits/extensions/cashu/templates/cashu/mint.html b/lnbits/extensions/cashu/templates/cashu/mint.html
index bcb919ff..a6959ec2 100644
--- a/lnbits/extensions/cashu/templates/cashu/mint.html
+++ b/lnbits/extensions/cashu/templates/cashu/mint.html
@@ -4,18 +4,19 @@
-
- {{ mint_name }}
+
+ {{ mint_name }}
+
Open walletclick to open wallet
@@ -58,24 +59,34 @@
This service is in BETA
- We hold no responsibility for people losing access to funds. Use at
- your own risk!
+ Cashu is still experimental and in active development. There are
+ likely bugs in this implementation so please use this with caution. We
+ hold no responsibility for people losing access to funds. Use at your
+ own risk!
+ 
+ 
+ 
+ 
+ 
+