aljaz/nutshell
1
0
Fork 0
mirror of https://github.com/aljazceru/nutshell.git synced 2026-01-07 02:44:19 +01:00
Code Issues Packages Projects Releases Wiki Activity

mint: fix postgres migrations (#375)

Browse Source
This commit is contained in:
callebtc
2023-12-03 00:02:05 +01:00
committed by GitHub
parent 34a2e7e5da
commit 74c9317277
1 changed files with 10 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
cashu/mint/migrations.py
View File

@@ -55,7 +55,7 @@ async def m002_add_balance_views(db: Database):
SELECT SUM(amount) AS s
FROM {table_with_schema(db, 'promises')}
WHERE amount > 0
);
) AS balance_issued;
""")
await conn.execute(f"""
@@ -64,7 +64,7 @@ async def m002_add_balance_views(db: Database):
SELECT SUM(amount) AS s
FROM {table_with_schema(db, 'proofs_used')}
WHERE amount > 0
);
) AS balance_redeemed;
""")
await conn.execute(f"""
@@ -183,9 +183,13 @@ async def m009_add_out_to_invoices(db: Database):
# column in invoices for marking whether the invoice is incoming (out=False) or outgoing (out=True)
async with db.connect() as conn:
# we have to drop the balance views first and recreate them later
await conn.execute(f"DROP VIEW {table_with_schema(db, 'balance')}")
await conn.execute(f"DROP VIEW {table_with_schema(db, 'balance_issued')}")
await conn.execute(f"DROP VIEW {table_with_schema(db, 'balance_redeemed')}")
await conn.execute(f"DROP VIEW IF EXISTS {table_with_schema(db, 'balance')}")
await conn.execute(
f"DROP VIEW IF EXISTS {table_with_schema(db, 'balance_issued')}"
)
await conn.execute(
f"DROP VIEW IF EXISTS {table_with_schema(db, 'balance_redeemed')}"
)
# rename column pr to bolt11
await conn.execute(
@@ -211,6 +215,6 @@ async def m010_add_index_to_proofs_used(db: Database):
async with db.connect() as conn:
await conn.execute(
"CREATE INDEX IF NOT EXISTS"
f" {table_with_schema(db, 'proofs_used')}_secret_idx ON"
" proofs_used_secret_idx ON"
f" {table_with_schema(db, 'proofs_used')} (secret)"
)