Changed form table name

This commit is contained in:
Ben Arc
2021-08-16 09:13:16 +01:00
parent 094943e293
commit 52cb381bd5
2 changed files with 9 additions and 9 deletions

View File

@@ -49,7 +49,7 @@ async def set_ticket_paid(payment_hash: str) -> Tickets:
amount = formdata.amountmade + row[7] amount = formdata.amountmade + row[7]
await db.execute( await db.execute(
""" """
UPDATE lnticket.forms UPDATE lnticket.form2
SET amountmade = ? SET amountmade = ?
WHERE id = ? WHERE id = ?
""", """,
@@ -114,7 +114,7 @@ async def create_form(
form_id = urlsafe_short_hash() form_id = urlsafe_short_hash()
await db.execute( await db.execute(
""" """
INSERT INTO lnticket.forms (id, wallet, name, webhook, description, flatrate, amount, amountmade) INSERT INTO lnticket.form2 (id, wallet, name, webhook, description, flatrate, amount, amountmade)
VALUES (?, ?, ?, ?, ?, ?, ?, ?) VALUES (?, ?, ?, ?, ?, ?, ?, ?)
""", """,
(form_id, wallet, name, webhook, description, flatrate, amount, 0), (form_id, wallet, name, webhook, description, flatrate, amount, 0),
@@ -128,15 +128,15 @@ async def create_form(
async def update_form(form_id: str, **kwargs) -> Forms: async def update_form(form_id: str, **kwargs) -> Forms:
q = ", ".join([f"{field[0]} = ?" for field in kwargs.items()]) q = ", ".join([f"{field[0]} = ?" for field in kwargs.items()])
await db.execute( await db.execute(
f"UPDATE lnticket.forms SET {q} WHERE id = ?", (*kwargs.values(), form_id) f"UPDATE lnticket.form2 SET {q} WHERE id = ?", (*kwargs.values(), form_id)
) )
row = await db.fetchone("SELECT * FROM lnticket.forms WHERE id = ?", (form_id,)) row = await db.fetchone("SELECT * FROM lnticket.form2 WHERE id = ?", (form_id,))
assert row, "Newly updated form couldn't be retrieved" assert row, "Newly updated form couldn't be retrieved"
return Forms(**row) return Forms(**row)
async def get_form(form_id: str) -> Optional[Forms]: async def get_form(form_id: str) -> Optional[Forms]:
row = await db.fetchone("SELECT * FROM lnticket.forms WHERE id = ?", (form_id,)) row = await db.fetchone("SELECT * FROM lnticket.form2 WHERE id = ?", (form_id,))
return Forms(**row) if row else None return Forms(**row) if row else None
@@ -146,11 +146,11 @@ async def get_forms(wallet_ids: Union[str, List[str]]) -> List[Forms]:
q = ",".join(["?"] * len(wallet_ids)) q = ",".join(["?"] * len(wallet_ids))
rows = await db.fetchall( rows = await db.fetchall(
f"SELECT * FROM lnticket.forms WHERE wallet IN ({q})", (*wallet_ids,) f"SELECT * FROM lnticket.form2 WHERE wallet IN ({q})", (*wallet_ids,)
) )
return [Forms(**row) for row in rows] return [Forms(**row) for row in rows]
async def delete_form(form_id: str) -> None: async def delete_form(form_id: str) -> None:
await db.execute("DELETE FROM lnticket.forms WHERE id = ?", (form_id,)) await db.execute("DELETE FROM lnticket.form2 WHERE id = ?", (form_id,))

View File

@@ -151,7 +151,7 @@ async def m004_changed(db):
await db.execute( await db.execute(
""" """
CREATE TABLE lnticket.forms ( CREATE TABLE lnticket.form2 (
id TEXT PRIMARY KEY, id TEXT PRIMARY KEY,
wallet TEXT NOT NULL, wallet TEXT NOT NULL,
name TEXT NOT NULL, name TEXT NOT NULL,
@@ -178,7 +178,7 @@ async def m004_changed(db):
usescsv = usescsv[1:] usescsv = usescsv[1:]
await db.execute( await db.execute(
""" """
INSERT INTO lnticket.forms ( INSERT INTO lnticket.form2 (
id, id,
wallet, wallet,
name, name,