SatSale

commit 34ae670b6e3fe4d17b4230ee1508cc80fcf52fb8
parent adc6cd08421e1af120c99bbf92a5fecca686a404
Author: nickfarrow <nicholas.w.farrow@gmail.com>
Date:   Wed, 11 Aug 2021 06:58:36 +1000

Add modular database file

Diffstat:
A
payments/database.py
 | 
41
+++++++++++++++++++++++++++++++++++++++++

1 file changed, 41 insertions(+), 0 deletions(-)
diff --git a/payments/database.py b/payments/database.py
@@ -0,0 +1,41 @@
+import sqlite3
+
+def create_database(name="database.db"):
+    with sqlite3.connect("database.db") as conn:
+        print("Creating new database.db...")
+        conn.execute(
+            "CREATE TABLE payments (uuid TEXT, dollar_value DECIMAL, btc_value DECIMAL, method TEXT, address TEXT, time DECIMAL, webhook TEXT, rhash TEXT)"
+        )
+    return
+
+
+def write_to_database(invoice, name="database.db"):
+    with sqlite3.connect("database.db") as conn:
+        cur = conn.cursor()
+        cur.execute(
+            "INSERT INTO payments (uuid,dollar_value,btc_value,method,address,time,webhook,rhash) VALUES (?,?,?,?,?,?,?,?)",
+            (
+                invoice["uuid"],
+                invoice["dollar_value"],
+                invoice["btc_value"],
+                invoice["method"],
+                invoice["address"],
+                invoice["time"],
+                invoice["webhook"],
+                invoice["rhash"],
+            ),
+        )
+    return
+
+
+def load_invoice_from_db(uuid):
+    with sqlite3.connect("database.db") as conn:
+        conn.row_factory = sqlite3.Row
+        cur = conn.cursor()
+        rows = cur.execute(
+            "select * from payments where uuid='{}'".format(uuid)
+        ).fetchall()
+    if len(rows) > 0:
+        return [dict(ix) for ix in rows][0]
+    else:
+        return None