splitpayments/crud.py
dni ⚡ 5042d40af6
feat: update to lnbits 1.0.0 (#27)
* feat: update to lnbits 1.0.0
* fix select wallet
* fix splits
* fix: types, postgres errors with cache
---------

Co-authored-by: Tiago Vasconcelos <talvasconcelos@gmail.com>
2024-11-28 12:28:00 +01:00

23 lines
689 B
Python

from lnbits.db import Database
from .models import Target
db = Database("ext_splitpayments")
async def get_targets(source_wallet: str) -> list[Target]:
return await db.fetchall(
"SELECT * FROM splitpayments.targets WHERE source = :source_wallet",
{"source_wallet": source_wallet},
Target,
)
async def set_targets(source_wallet: str, targets: list[Target]):
async with db.connect() as conn:
await conn.execute(
"DELETE FROM splitpayments.targets WHERE source = :source_wallet",
{"source_wallet": source_wallet},
)
for target in targets:
await conn.insert("splitpayments.targets", target)