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

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

Browse Source
This commit is contained in:
Untone 2024-03-29 02:45:23 +03:00
parent 489e6b39a9
commit d529daea25
1 changed files with 8 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
resolvers/rating.py
View File

@ -175,36 +175,29 @@ def add_rating_columns(q, group_list):
# by comments # by comments
replied_comment = aliased(Reaction) replied_comment = aliased(Reaction)
react = aliased(Reaction)
comments_subq = select( comments_subq = select(
Author.id, Author.id,
func.coalesce(func.sum( func.coalesce(func.sum(
case( case(
(Reaction.kind == ReactionKind.LIKE.value, 1), (react.kind == ReactionKind.LIKE.value, 1),
(Reaction.kind == ReactionKind.DISLIKE.value, -1), (react.kind == ReactionKind.DISLIKE.value, -1),
else_=0 else_=0
) )
)).label('comments_rating'), )).label('comments_rating'),
).select_from(Reaction).outerjoin( ).select_from(react).outerjoin(
replied_comment, replied_comment,
and_( and_(
replied_comment.kind == ReactionKind.COMMENT.value, replied_comment.kind == ReactionKind.COMMENT.value,
replied_comment.created_by == Author.id, replied_comment.created_by == Author.id,
Reaction.kind.in_([ReactionKind.LIKE.value, ReactionKind.DISLIKE.value]), react.kind.in_([ReactionKind.LIKE.value, ReactionKind.DISLIKE.value]),
Reaction.reply_to == replied_comment.id, react.reply_to == replied_comment.id,
Reaction.deleted_at.is_(None) react.deleted_at.is_(None)
) )
).group_by(Author.id).subquery() ).group_by(Author.id).subquery()
q = q.outerjoin(comments_subq, Author.id == comments_subq.c.id) q = q.outerjoin(comments_subq, Author.id == comments_subq.c.id)
q = q.add_columns( q = q.add_columns(comments_subq.c.comments_rating)
func.coalesce(func.sum(
case(
(Reaction.kind == ReactionKind.LIKE.value, 1),
(Reaction.kind == ReactionKind.DISLIKE.value, -1),
else_=0
)
)).label('comments_rating')
)
group_list.extend([comments_subq.c.comments_rating]) group_list.extend([comments_subq.c.comments_rating])
return q, group_list return q, group_list