mirror of
https://github.com/lnbits/lnbits-legend.git
synced 2025-01-19 05:33:47 +01:00
update to cashu 0.5.3 with db fix
This commit is contained in:
callebtc
dni ⚡
parent
23308fe6cf
commit
175516f8e4
@ -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]
|
||||
|
||||
@ -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
|
||||
|
||||
@ -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]
|
||||
|
||||
Loading…
Reference in New Issue
Block a user