mirror of
https://github.com/aljazceru/nutshell.git
synced 2025-12-20 10:34:20 +01:00
93 lines
2.6 KiB
Python
93 lines
2.6 KiB
Python
from typing import Union
|
|
|
|
from fastapi import APIRouter
|
|
from secp256k1 import PublicKey
|
|
|
|
from cashu.core.base import (
|
|
CashuError,
|
|
CheckRequest,
|
|
GetMeltResponse,
|
|
GetMintResponse,
|
|
MeltRequest,
|
|
MintRequest,
|
|
PostSplitResponse,
|
|
SplitRequest,
|
|
)
|
|
from cashu.mint import ledger
|
|
|
|
router: APIRouter = APIRouter()
|
|
|
|
|
|
@router.get("/keys")
|
|
def keys():
|
|
"""Get the public keys of the mint"""
|
|
return ledger.get_pubkeys()
|
|
|
|
|
|
@router.get("/mint")
|
|
async def request_mint(amount: int = 0):
|
|
"""
|
|
Request minting of new tokens. The mint responds with a Lightning invoice.
|
|
This endpoint can be used for a Lightning invoice UX flow.
|
|
|
|
Call `POST /mint` after paying the invoice.
|
|
"""
|
|
payment_request, payment_hash = await ledger.request_mint(amount)
|
|
print(f"Lightning invoice: {payment_request}")
|
|
resp = GetMintResponse(pr=payment_request, hash=payment_hash)
|
|
return resp
|
|
|
|
|
|
@router.post("/mint")
|
|
async def mint(payloads: MintRequest, payment_hash: Union[str, None] = None):
|
|
"""
|
|
Requests the minting of tokens belonging to a paid payment request.
|
|
|
|
Call this endpoint after `GET /mint`.
|
|
"""
|
|
amounts = []
|
|
B_s = []
|
|
for payload in payloads.blinded_messages:
|
|
amounts.append(payload.amount)
|
|
B_s.append(PublicKey(bytes.fromhex(payload.B_), raw=True))
|
|
try:
|
|
promises = await ledger.mint(B_s, amounts, payment_hash=payment_hash)
|
|
return promises
|
|
except Exception as exc:
|
|
return CashuError(error=str(exc))
|
|
|
|
|
|
@router.post("/melt")
|
|
async def melt(payload: MeltRequest):
|
|
"""
|
|
Requests tokens to be destroyed and sent out via Lightning.
|
|
"""
|
|
ok, preimage = await ledger.melt(payload.proofs, payload.amount, payload.invoice)
|
|
resp = GetMeltResponse(paid=ok, preimage=preimage)
|
|
return resp
|
|
|
|
|
|
@router.post("/check")
|
|
async def check_spendable(payload: CheckRequest):
|
|
return await ledger.check_spendable(payload.proofs)
|
|
|
|
|
|
@router.post("/split")
|
|
async def split(payload: SplitRequest):
|
|
"""
|
|
Requetst a set of tokens with amount "total" to be split into two
|
|
newly minted sets with amount "split" and "total-split".
|
|
"""
|
|
proofs = payload.proofs
|
|
amount = payload.amount
|
|
outputs = payload.outputs.blinded_messages
|
|
try:
|
|
split_return = await ledger.split(proofs, amount, outputs)
|
|
except Exception as exc:
|
|
return CashuError(error=str(exc))
|
|
if not split_return:
|
|
return {"error": "there was a problem with the split."}
|
|
frst_promises, scnd_promises = split_return
|
|
resp = PostSplitResponse(fst=frst_promises, snd=scnd_promises)
|
|
return resp
|