discours.io/core
5
0
Fork 0
Code Pull Requests Actions Projects Activity

get-author-fix-6
All checks were successful
Deploy on push / deploy (push) Successful in 23s
Details

Browse Source
This commit is contained in:
Untone 2024-02-26 05:43:35 +03:00
parent 8fb161470f
commit ebbbe05237
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
resolvers/author.py
View File

@ -49,10 +49,10 @@ async def get_author(_, _info, slug='', author_id=None):
if author_id: if author_id:
cache = await redis.execute('GET', f'id:{author_id}:author') cache = await redis.execute('GET', f'id:{author_id}:author')
q = select(Author).where(Author.id == author_id) q = select(Author).where(Author.id == author_id)
author = json.loads(cache) if cache else get_with_stat(q)[0] author_dict = json.loads(cache) if cache else get_with_stat(q)[0].dict()
if author: if author:
await update_author_cache(author.dict()) await update_author_cache(author_dict)
return author return author_dict
except Exception: except Exception:
import traceback import traceback
exc = traceback.format_exc() exc = traceback.format_exc()

2
services/event_listeners.py
View File

@ -89,7 +89,7 @@ def after_reaction_insert(mapper, connection, reaction: Reaction):
authors = get_with_stat(author_query) authors = get_with_stat(author_query)
for author in authors: for author in authors:
asyncio.create_task(update_author_cache(author.author())) asyncio.create_task(update_author_cache(author.dict()))
shout = connection.execute(select(Shout).select_from(Shout).where(Shout.id == reaction.shout)).first() shout = connection.execute(select(Shout).select_from(Shout).where(Shout.id == reaction.shout)).first()
if shout: if shout: