Fixed in a hacky way, but works

This commit is contained in:
benarc
2021-10-20 18:28:54 +01:00
parent 8f44747d6c
commit f68f45b6b1
2 changed files with 10 additions and 9 deletions

View File

@@ -13,7 +13,7 @@ async def create_copilot(
copilot_id = urlsafe_short_hash() copilot_id = urlsafe_short_hash()
await db.execute( await db.execute(
""" """
INSERT INTO copilot.copilots ( INSERT INTO copilot.newer_copilots (
id, id,
user, user,
lnurl_toggle, lnurl_toggle,
@@ -71,24 +71,26 @@ async def update_copilot(
q = ", ".join([f"{field[0]} = ?" for field in data]) q = ", ".join([f"{field[0]} = ?" for field in data])
items = [f"{field[1]}" for field in data] items = [f"{field[1]}" for field in data]
items.append(copilot_id) items.append(copilot_id)
await db.execute(f"UPDATE copilot.copilots SET {q} WHERE id = ?", (items)) await db.execute(f"UPDATE copilot.newer_copilots SET {q} WHERE id = ?", (items))
row = await db.fetchone( row = await db.fetchone(
"SELECT * FROM copilot.copilots WHERE id = ?", (copilot_id,) "SELECT * FROM copilot.newer_copilots WHERE id = ?", (copilot_id,)
) )
return Copilots(**row) if row else None return Copilots(**row) if row else None
async def get_copilot(copilot_id: str) -> Copilots: async def get_copilot(copilot_id: str) -> Copilots:
row = await db.fetchone( row = await db.fetchone(
"SELECT * FROM copilot.copilots WHERE id = ?", (copilot_id,) "SELECT * FROM copilot.newer_copilots WHERE id = ?", (copilot_id,)
) )
return Copilots(**row) if row else None return Copilots(**row) if row else None
async def get_copilots(user: str) -> List[Copilots]: async def get_copilots(user: str) -> List[Copilots]:
rows = await db.fetchall("SELECT * FROM copilot.copilots WHERE user = ?", (user,)) rows = await db.fetchall(
"SELECT * FROM copilot.newer_copilots WHERE user = ?", (user,)
)
return [Copilots(**row) for row in rows] return [Copilots(**row) for row in rows]
async def delete_copilot(copilot_id: str) -> None: async def delete_copilot(copilot_id: str) -> None:
await db.execute("DELETE FROM copilot.copilots WHERE id = ?", (copilot_id,)) await db.execute("DELETE FROM copilot.newer_copilots WHERE id = ?", (copilot_id,))

View File

@@ -75,7 +75,6 @@ async def m003_fix_data_types(db):
) )
await db.execute( await db.execute(
"INSERT INTO copilot.newer_copilots SELECT * FROM copilot.copilots;" "INSERT INTO copilot.newer_copilots SELECT * FROM copilot.copilots"
) )
await db.execute("DROP TABLE IF EXISTS copilot.copilots;") await db.execute("DROP TABLE IF EXISTS copilot.copilots")
await db.execute("ALTER TABLE copilot.newer_copilots RENAME TO copilot.copilots;")