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

postprocess-query-for-order-4
All checks were successful
Deploy to core / deploy (push) Successful in 2m29s
Details

Browse Source
This commit is contained in:
Untone 2024-02-14 12:07:55 +03:00
parent 2e60fd2cc7
commit e9ed01e797
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
resolvers/author.py
View File

@ -25,7 +25,7 @@ logger = logging.getLogger('\t[resolvers.author]\t')
logger.setLevel(logging.DEBUG) logger.setLevel(logging.DEBUG)
def add_author_stat_columns(q, order=''): def add_author_stat_columns(q):
shout_author_aliased = aliased(ShoutAuthor) shout_author_aliased = aliased(ShoutAuthor)
q = q.outerjoin(shout_author_aliased).add_columns( q = q.outerjoin(shout_author_aliased).add_columns(
func.count(distinct(shout_author_aliased.shout)).label('shouts_stat') func.count(distinct(shout_author_aliased.shout)).label('shouts_stat')
@ -42,8 +42,6 @@ def add_author_stat_columns(q, order=''):
) )
q = q.group_by(Author.id) q = q.group_by(Author.id)
if order == 'followers' or order == 'shouts':
q = q.order_By(desc(f'{order}_stat'))
return q return q
@ -209,7 +207,7 @@ async def get_author_id(_, _info, user: str):
@query.field('load_authors_by') @query.field('load_authors_by')
async def load_authors_by(_, _info, by, limit, offset): async def load_authors_by(_, _info, by, limit, offset):
q = select(Author) q = select(Author)
q = add_author_stat_columns(q, order=by.get('order')) q = add_author_stat_columns(q)
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']}%"))
elif by.get('name'): elif by.get('name'):
@ -224,6 +222,10 @@ async def load_authors_by(_, _info, by, limit, offset):
before = int(time.time()) - by['created_at'] before = int(time.time()) - by['created_at']
q = q.filter(Author.created_at > before) q = q.filter(Author.created_at > before)
order = by.get('order')
if order == 'followers' or order == 'shouts':
q = q.order_by(desc(f'{order}_stat'))
q = q.limit(limit).offset(offset) q = q.limit(limit).offset(offset)
authors = await get_authors_from_query(q) authors = await get_authors_from_query(q)