From 175516f8e4bc8ea6263237bce055263379aee4d2 Mon Sep 17 00:00:00 2001 From: callebtc <93376500+callebtc@users.noreply.github.com> Date: Sat, 26 Nov 2022 02:14:39 +0100 Subject: [PATCH] update to cashu 0.5.3 with db fix --- lnbits/extensions/cashu/crud.py | 182 --------------------------- lnbits/extensions/cashu/views_api.py | 11 +- pyproject.toml | 2 +- 3 files changed, 7 insertions(+), 188 deletions(-) diff --git a/lnbits/extensions/cashu/crud.py b/lnbits/extensions/cashu/crud.py index cbeedc12f..773a11fde 100644 --- a/lnbits/extensions/cashu/crud.py +++ b/lnbits/extensions/cashu/crud.py @@ -42,25 +42,6 @@ async def create_cashu( return cashu -# async def update_cashu_keys(cashu_id, wif: str = None) -> Optional[Cashu]: -# entropy = bytes([random.getrandbits(8) for i in range(16)]) -# mnemonic = bip39.mnemonic_from_bytes(entropy) -# seed = bip39.mnemonic_to_seed(mnemonic) -# root = bip32.HDKey.from_seed(seed, version=NETWORKS["main"]["xprv"]) - -# bip44_xprv = root.derive("m/44h/1h/0h") -# bip44_xpub = bip44_xprv.to_public() - -# await db.execute( -# "UPDATE cashu.cashu SET prv = ?, pub = ? WHERE id = ?", -# bip44_xprv.to_base58(), -# bip44_xpub.to_base58(), -# cashu_id, -# ) -# row = await db.fetchone("SELECT * FROM cashu.cashu WHERE id = ?", (cashu_id,)) -# return Cashu(**row) if row else None - - async def get_cashu(cashu_id) -> Optional[Cashu]: row = await db.fetchone("SELECT * FROM cashu.cashu WHERE id = ?", (cashu_id,)) return Cashu(**row) if row else None @@ -80,166 +61,3 @@ async def get_cashus(wallet_ids: Union[str, List[str]]) -> List[Cashu]: async def delete_cashu(cashu_id) -> None: await db.execute("DELETE FROM cashu.cashu WHERE id = ?", (cashu_id,)) - - -# ########################################## -# ###############MINT STUFF################# -# ########################################## - - -# async def store_promises( -# amounts: List[int], B_s: List[str], C_s: List[str], cashu_id: str -# ): -# for amount, B_, C_ in zip(amounts, B_s, C_s): -# await store_promise(amount, B_, C_, cashu_id) - - -# async def store_promise(amount: int, B_: str, C_: str, cashu_id: str): -# promise_id = urlsafe_short_hash() - -# await db.execute( -# """ -# INSERT INTO cashu.promises -# (id, amount, B_b, C_b, cashu_id) -# VALUES (?, ?, ?, ?, ?) -# """, -# (promise_id, amount, str(B_), str(C_), cashu_id), -# ) - - -# async def get_promises(cashu_id) -> Optional[Cashu]: -# row = await db.fetchall( -# "SELECT * FROM cashu.promises WHERE cashu_id = ?", (cashu_id,) -# ) -# return Promises(**row) if row else None - - -# async def get_proofs_used( -# db: Database, -# conn: Optional[Connection] = None, -# ): - -# rows = await (conn or db).fetchall( -# """ -# SELECT secret from cashu.proofs_used -# """ -# ) -# return [row[0] for row in rows] - - -# async def invalidate_proof(cashu_id: str, proof: Proof): -# invalidate_proof_id = urlsafe_short_hash() -# await db.execute( -# """ -# INSERT INTO cashu.proofs_used -# (id, amount, C, secret, cashu_id) -# VALUES (?, ?, ?, ?, ?) -# """, -# (invalidate_proof_id, proof.amount, str(proof.C), str(proof.secret), cashu_id), -# ) - - -# ######################################## -# ############ MINT INVOICES ############# -# ######################################## - - -# async def store_lightning_invoice(cashu_id: str, invoice: Invoice): -# await db.execute( -# """ -# INSERT INTO cashu.invoices -# (cashu_id, amount, pr, hash, issued) -# VALUES (?, ?, ?, ?, ?) -# """, -# ( -# cashu_id, -# invoice.amount, -# invoice.pr, -# invoice.hash, -# invoice.issued, -# ), -# ) - - -# async def get_lightning_invoice(cashu_id: str, hash: str): -# row = await db.fetchone( -# """ -# SELECT * from cashu.invoices -# WHERE cashu_id =? AND hash = ? -# """, -# ( -# cashu_id, -# hash, -# ), -# ) -# return Invoice.from_row(row) - - -# async def update_lightning_invoice(cashu_id: str, hash: str, issued: bool): -# await db.execute( -# "UPDATE cashu.invoices SET issued = ? WHERE cashu_id = ? AND hash = ?", -# ( -# issued, -# cashu_id, -# hash, -# ), -# ) - - -############################## -######### KEYSETS ############ -############################## - - -# async def store_keyset( -# keyset: MintKeyset, -# db: Database = None, -# conn: Optional[Connection] = None, -# ): - -# await (conn or db).execute( # type: ignore -# """ -# INSERT INTO cashu.keysets -# (id, derivation_path, valid_from, valid_to, first_seen, active, version) -# VALUES (?, ?, ?, ?, ?, ?, ?) -# """, -# ( -# keyset.id, -# keyset.derivation_path, -# keyset.valid_from or db.timestamp_now, -# keyset.valid_to or db.timestamp_now, -# keyset.first_seen or db.timestamp_now, -# True, -# keyset.version, -# ), -# ) - - -# async def get_keyset( -# id: str = None, -# derivation_path: str = "", -# db: Database = None, -# conn: Optional[Connection] = None, -# ): -# clauses = [] -# values: List[Any] = [] -# clauses.append("active = ?") -# values.append(True) -# if id: -# clauses.append("id = ?") -# values.append(id) -# if derivation_path: -# clauses.append("derivation_path = ?") -# values.append(derivation_path) -# where = "" -# if clauses: -# where = f"WHERE {' AND '.join(clauses)}" - -# rows = await (conn or db).fetchall( # type: ignore -# f""" -# SELECT * from cashu.keysets -# {where} -# """, -# tuple(values), -# ) -# return [MintKeyset.from_row(row) for row in rows] diff --git a/lnbits/extensions/cashu/views_api.py b/lnbits/extensions/cashu/views_api.py index 3b51bb6a3..ad253abf0 100644 --- a/lnbits/extensions/cashu/views_api.py +++ b/lnbits/extensions/cashu/views_api.py @@ -262,7 +262,7 @@ async def melt_coins( # TOKENS assert all([p.id == cashu.keyset_id for p in proofs]), HTTPException( status_code=HTTPStatus.METHOD_NOT_ALLOWED, - detail="Tokens are from another mint.", + detail="Error: Tokens are from another mint.", ) assert all([ledger._verify_proof(p) for p in proofs]), HTTPException( @@ -354,10 +354,11 @@ async def split( # !!!!!!! MAKE SURE THAT PROOFS ARE ONLY FROM THIS CASHU KEYSET ID # THIS IS NECESSARY BECAUSE THE CASHU BACKEND WILL ACCEPT ANY VALID # TOKENS - assert all([p.id == cashu.keyset_id for p in proofs]), HTTPException( - status_code=HTTPStatus.METHOD_NOT_ALLOWED, - detail="Tokens are from another mint.", - ) + if not all([p.id == cashu.keyset_id for p in proofs]): + raise HTTPException( + status_code=HTTPStatus.METHOD_NOT_ALLOWED, + detail="Error: Tokens are from another mint.", + ) amount = payload.amount outputs = payload.outputs.blinded_messages diff --git a/pyproject.toml b/pyproject.toml index dc7215d5d..fd9ecd50f 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -63,7 +63,7 @@ protobuf = "^4.21.6" Cerberus = "^1.3.4" async-timeout = "^4.0.2" pyln-client = "0.11.1" -cashu = "^0.5.1" +cashu = "^0.5.3" [tool.poetry.dev-dependencies]