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

more-logs
All checks were successful
Deploy on push / deploy (push) Successful in 1m29s
Details

Browse Source
This commit is contained in:
Untone 2024-02-25 14:39:26 +03:00
parent 60e7cd03b7
commit fc58208bdd
2 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
resolvers/author.py
View File

@ -53,6 +53,7 @@ def get_author(_, _info, slug='', author_id=None):
async def get_author_by_user_id(user_id: str): async def get_author_by_user_id(user_id: str):
logger.info(f'getting author id for {user_id}')
redis_key = f'user:{user_id}:author' redis_key = f'user:{user_id}:author'
author = None author = None
try: try:
@ -63,7 +64,6 @@ async def get_author_by_user_id(user_id: str):
logger.debug(f'got cached author: {author}') logger.debug(f'got cached author: {author}')
return author return author
logger.info(f'getting author id for {user_id}')
q = select(Author).filter(Author.user == user_id) q = select(Author).filter(Author.user == user_id)
[author] = get_with_stat(q) [author] = get_with_stat(q)
@ -79,6 +79,7 @@ async def get_author_id(_, _info, user: str):
@query.field('load_authors_by') @query.field('load_authors_by')
def load_authors_by(_, _info, by, limit, offset): def load_authors_by(_, _info, by, limit, offset):
logger.debug(f'loading authors by {by}')
q = select(Author) q = select(Author)
if by.get('slug'): if by.get('slug'):
q = q.filter(Author.slug.ilike(f"%{by['slug']}%")) q = q.filter(Author.slug.ilike(f"%{by['slug']}%"))
@ -121,6 +122,7 @@ def get_author_follows(_, _info, slug='', user=None, author_id=None):
) )
author_id = author_id_result[0] if author_id_result else None author_id = author_id_result[0] if author_id_result else None
if author_id: if author_id:
logger.debug(f'getting {author_id} follows')
topics = author_follows_topics(author_id) topics = author_follows_topics(author_id)
authors = author_follows_authors(author_id) authors = author_follows_authors(author_id)
return { return {
@ -145,6 +147,7 @@ def get_author_follows_topics(_, _info, slug='', user=None, author_id=None):
) )
author_id = author_id_result[0] if author_id_result else None author_id = author_id_result[0] if author_id_result else None
if author_id: if author_id:
logger.debug(f'getting {author_id} follows topics')
follows = author_follows_topics(author_id) follows = author_follows_topics(author_id)
return follows return follows
else: else:
@ -162,6 +165,7 @@ def get_author_follows_authors(_, _info, slug='', user=None, author_id=None):
) )
author_id = author_id_result[0] if author_id_result else None author_id = author_id_result[0] if author_id_result else None
if author_id: if author_id:
logger.debug(f'getting {author_id} follows authors')
follows = author_follows_authors(author_id) follows = author_follows_authors(author_id)
return follows return follows
else: else:
@ -178,6 +182,7 @@ def create_author(user_id: str, slug: str, name: str = ''):
@query.field('get_author_followers') @query.field('get_author_followers')
def get_author_followers(_, _info, slug: str): def get_author_followers(_, _info, slug: str):
logger.debug(f'getting followers for @{slug}')
try: try:
with local_session() as session: with local_session() as session:
author_id_result = ( author_id_result = (

2
services/db.py
View File

@ -52,7 +52,7 @@ def before_cursor_execute(conn, cursor, statement, parameters, context, executem
def after_cursor_execute(conn, cursor, statement, parameters, context, executemany): def after_cursor_execute(conn, cursor, statement, parameters, context, executemany):
if hasattr(conn, '_query_start_time'): if hasattr(conn, '_query_start_time'):
elapsed = time.time() - conn.query_start_time elapsed = time.time() - conn.query_start_time
del conn.query_start_time conn.query_start_time = None
query = f'{statement}'.replace('\n', ' ') query = f'{statement}'.replace('\n', ' ')
logger.debug(f"\n{query}\n{'*' * math.floor(elapsed)} {elapsed:.3f} s\n") logger.debug(f"\n{query}\n{'*' * math.floor(elapsed)} {elapsed:.3f} s\n")