cleanup

2022-10-14 01:01:43 +02:00
parent 436f208df2
commit dafcfef5be
7 changed files with 141 additions and 617 deletions
@@ -19,46 +19,6 @@ from cashu.core.base import MintKeyset
 from lnbits.db import Database, Connection


-# class LedgerCrud:
-#     """
-#     Database interface for Cashu mint.
-
-#     This class needs to be overloaded by any app that imports the Cashu mint.
-#     """
-
-#     async def get_keyset(*args, **kwags):
-
-#         return await get_keyset(*args, **kwags)
-
-#     async def get_lightning_invoice(*args, **kwags):
-
-#         return await get_lightning_invoice(*args, **kwags)
-
-#     async def get_proofs_used(*args, **kwags):
-
-#         return await get_proofs_used(*args, **kwags)
-
-#     async def invalidate_proof(*args, **kwags):
-
-#         return await invalidate_proof(*args, **kwags)
-
-#     async def store_keyset(*args, **kwags):
-
-#         return await store_keyset(*args, **kwags)
-
-#     async def store_lightning_invoice(*args, **kwags):
-
-#         return await store_lightning_invoice(*args, **kwags)
-
-#     async def store_promise(*args, **kwags):
-
-#         return await store_promise(*args, **kwags)
-
-#     async def update_lightning_invoice(*args, **kwags):
-
-#         return await update_lightning_invoice(*args, **kwags)
-
-
 async def create_cashu(
    cashu_id: str, keyset_id: str, wallet_id: str, data: Cashu
 ) -> Cashu:
@@ -85,23 +45,23 @@ 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"])
+# 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()
+#     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
+#     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]:
@@ -130,103 +90,103 @@ async def delete_cashu(cashu_id) -> None:
 # ##########################################


-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_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()
+# 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),
-    )
+#     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_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,
-):
+# 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]
+#     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),
-    )
+# 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 #############
-########################################
+# ########################################
+# ############ 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 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 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,
-        ),
-    )
+# 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,
+#         ),
+#     )


 ##############################