highperfocused/lnbits
1
0
Fork 0
mirror of https://github.com/lnbits/lnbits.git synced 2025-06-08 14:13:02 +02:00
Code Issues Packages Projects Releases Wiki Activity

feat: update invoice status

Browse Source
This commit is contained in:
Vlad Stan 2022-10-07 15:18:09 +03:00 committed by dni ⚡
parent cf31d2729d
commit 2757ad2ea9
1 changed files with 19 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
lnbits/extensions/cashu/views_api.py
View File

@ -25,6 +25,7 @@ from .crud import (
get_lightning_invoice, get_lightning_invoice,
store_lightning_invoice, store_lightning_invoice,
store_promise, store_promise,
update_lightning_invoice,
) )
from .ledger import mint, request_mint from .ledger import mint, request_mint
from .mint import generate_promises, get_pubkeys from .mint import generate_promises, get_pubkeys
@ -279,8 +280,10 @@ async def mint_coins(
raise HTTPException( raise HTTPException(
status_code=HTTPStatus.NOT_FOUND, detail="Mint does not have this invoice." status_code=HTTPStatus.NOT_FOUND, detail="Mint does not have this invoice."
) )
# if invoice.issued == True: if invoice.issued == True:
# todo: give old tokens? raise HTTPException(
status_code=HTTPStatus.PAYMENT_REQUIRED, detail="Tokens already issued for this invoice."
)
status: PaymentStatus = await check_transaction_status( status: PaymentStatus = await check_transaction_status(
cashu.wallet, payment_hash cashu.wallet, payment_hash
@ -290,18 +293,21 @@ async def mint_coins(
raise HTTPException( raise HTTPException(
status_code=HTTPStatus.PAYMENT_REQUIRED, detail="Invoice not paid." status_code=HTTPStatus.PAYMENT_REQUIRED, detail="Invoice not paid."
) )
amounts = []
B_s = []
for payload in data.blinded_messages:
amounts.append(payload.amount)
B_s.append(PublicKey(bytes.fromhex(payload.B_), raw=True))
try: try:
promises = await generate_promises(cashu.prvkey, amounts, B_s) await update_lightning_invoice(cashu_id, payment_hash, True)
for amount, B_, p in zip(amounts, B_s, promises):
await store_promise(amount, B_.serialize().hex(), p.C_, cashu_id) amounts = []
return promises B_s = []
for payload in data.blinded_messages:
amounts.append(payload.amount)
B_s.append(PublicKey(bytes.fromhex(payload.B_), raw=True))
promises = await generate_promises(cashu.prvkey, amounts, B_s)
for amount, B_, p in zip(amounts, B_s, promises):
await store_promise(amount, B_.serialize().hex(), p.C_, cashu_id)
return promises
except Exception as exc: except Exception as exc:
return CashuError(error=str(exc)) return CashuError(error=str(exc))