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

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

Browse Source
This commit is contained in:
Untone 2024-03-28 20:36:35 +03:00
parent 5c41312b1d
commit 029e6af161
1 changed files with 14 additions and 33 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

47
resolvers/author.py
View File

@ -55,47 +55,28 @@ def get_authors_all(_, _info):
@query.field('get_author') @query.field('get_author')
async def get_author(_, _info, slug='', author_id=0): async def get_author(_, _info, slug='', author_id=0):
author_query = ''
author = None
author_dict = None author_dict = None
try: try:
author_query = '' author_query = select(Author).filter(or_(Author.slug == slug, Author.id == author_id))
author = None [author] = await get_authors_with_stat_cached(author_query)
author_id = 0 if isinstance(author, Author):
author_dict = None author_id = author.id
if slug: logger.debug(f'found @{slug} with id {author_id}')
author_query = select(Author).filter(Author.slug == slug) if not author.stat:
[author] = await get_authors_with_stat_cached(author_query) [author] = get_with_stat(author_query)
if author: if author:
author_id = author.id await set_author_cache(author.dict())
logger.debug(f'found @{slug} with id {author_id}')
if author_id:
author_query = select(Author).filter(Author.id == author_id)
cache_key = f'author:{author_id}'
cache = await redis.execute('GET', cache_key)
if cache and isinstance(cache, str):
author_dict = json.loads(cache)
logger.debug(f'got cached author {cache_key} -> {author_dict}')
if not author_dict.get('stat'):
cache = ''
logger.warn(f'author {author_id} stat updating')
if not cache:
[author] = await get_authors_with_stat_cached(author_query)
if not author or not author.stat:
[author] = get_with_stat(author_query)
if author:
author_dict = author.dict()
author.stat = author_dict.get('stat')
if author_dict:
await set_author_cache(author_dict)
logger.debug('updated author stored in cache') logger.debug('updated author stored in cache')
return author_dict if isinstance(author, Author):
except Exception as exc: author_dict = author.dict()
except Exception:
import traceback import traceback
logger.error(exc)
exc = traceback.format_exc() exc = traceback.format_exc()
logger.error(exc) logger.error(exc)
return return author_dict
# {"slug": "anonymous", "id": 1, "name": "Аноним", "bio": "Неизвестно кто"}
async def get_author_by_user_id(user_id: str): async def get_author_by_user_id(user_id: str):