feat: get_storage_for_public_key
This commit is contained in:
parent
48c21a76d9
commit
f109833a36
1 changed files with 9 additions and 0 deletions
9
crud.py
9
crud.py
|
|
@ -119,6 +119,15 @@ async def get_event(relay_id: str, id: str) -> Optional[NostrEvent]:
|
||||||
event.tags = await get_event_tags(relay_id, id)
|
event.tags = await get_event_tags(relay_id, id)
|
||||||
return event
|
return event
|
||||||
|
|
||||||
|
async def get_storage_for_public_key(relay_id: str, pubkey: str) -> int:
|
||||||
|
row = await db.fetchone("SELECT SUM(size) FROM nostrrelay.events WHERE relay_id = ? AND pubkey = ?", (relay_id, pubkey,))
|
||||||
|
if not row:
|
||||||
|
return 0
|
||||||
|
|
||||||
|
return row["sum"]
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
async def mark_events_deleted(relay_id: str, filter: NostrFilter):
|
async def mark_events_deleted(relay_id: str, filter: NostrFilter):
|
||||||
if filter.is_empty():
|
if filter.is_empty():
|
||||||
return None
|
return None
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue