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

formatting
All checks were successful
deploy / deploy (push) Successful in 1m28s
Details

Browse Source
This commit is contained in:
Untone 2023-12-17 08:40:05 +03:00
parent 509f4409ff
commit edf20466d6
1 changed files with 15 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

41
resolvers/reader.py
View File

@ -20,20 +20,7 @@ def add_stat_columns(q):
q = q.outerjoin(aliased_reaction).add_columns( q = q.outerjoin(aliased_reaction).add_columns(
func.sum(aliased_reaction.id).label("reacted_stat"), func.sum(aliased_reaction.id).label("reacted_stat"),
func.sum(case((aliased_reaction.kind == ReactionKind.COMMENT.value, 1), else_=0)).label("commented_stat"), func.sum(case((aliased_reaction.kind == ReactionKind.COMMENT.value, 1), else_=0)).label("commented_stat"),
func.sum( get_rating_func(aliased_reaction).label("rating_stat"),
case(
(aliased_reaction.kind == ReactionKind.AGREE.value, 1),
(aliased_reaction.kind == ReactionKind.DISAGREE.value, -1),
(aliased_reaction.kind == ReactionKind.PROOF.value, 1),
(aliased_reaction.kind == ReactionKind.DISPROOF.value, -1),
(aliased_reaction.kind == ReactionKind.ACCEPT.value, 1),
(aliased_reaction.kind == ReactionKind.REJECT.value, -1),
(aliased_reaction.kind == ReactionKind.LIKE.value, 1),
(aliased_reaction.kind == ReactionKind.DISLIKE.value, -1),
(aliased_reaction.reply_to.is_not(None), 0),
else_=0,
)
).label("rating_stat"),
func.max( func.max(
case( case(
(aliased_reaction.kind != ReactionKind.COMMENT.value, None), (aliased_reaction.kind != ReactionKind.COMMENT.value, None),
@ -360,14 +347,13 @@ def get_shouts_from_query(q, user_id=None):
def get_rating_func(aliased_reaction): def get_rating_func(aliased_reaction):
return func.sum( return func.sum(
case( case(
(aliased_reaction.kind == ReactionKind.AGREE.value, 1), (aliased_reaction.kind == str(ReactionKind.AGREE.value), 1),
(aliased_reaction.kind == ReactionKind.DISAGREE.value, -1), (aliased_reaction.kind == str(ReactionKind.DISAGREE.value), -1),
(aliased_reaction.kind == ReactionKind.PROOF.value, 1), (aliased_reaction.kind == str(ReactionKind.PROOF.value), 1),
(aliased_reaction.kind == ReactionKind.DISPROOF.value, -1), (aliased_reaction.kind == str(ReactionKind.DISPROOF.value), -1),
(aliased_reaction.kind == ReactionKind.ACCEPT.value, 1), (aliased_reaction.kind == str(ReactionKind.ACCEPT.value), 1),
(aliased_reaction.kind == ReactionKind.REJECT.value, -1), (aliased_reaction.kind == str(ReactionKind.REJECT.value), -1),
(aliased_reaction.kind == ReactionKind.LIKE.value, 1), (aliased_reaction.kind == str(ReactionKind.DISLIKE.value), -1),
(aliased_reaction.kind == ReactionKind.DISLIKE.value, -1),
(aliased_reaction.reply_to.is_not(None), 0), (aliased_reaction.reply_to.is_not(None), 0),
else_=0, else_=0,
) )
@ -377,11 +363,14 @@ def get_rating_func(aliased_reaction):
@query.field("load_shouts_random_top") @query.field("load_shouts_random_top")
async def load_shouts_random_top(_, _info, params): async def load_shouts_random_top(_, _info, params):
""" """
:param _
:param _info: GraphQLInfoContext
:param params: { :param params: {
filters: { filters: {
layouts: ['music'] layouts: ['music']
after: 13245678 after: 13245678
fromRandomCount: 100, }
random_limit: 100
limit: 50 limit: 50
offset: 0 offset: 0
} }
@ -395,9 +384,9 @@ async def load_shouts_random_top(_, _info, params):
subquery = apply_filters(subquery, params.get("filters", {})) subquery = apply_filters(subquery, params.get("filters", {}))
subquery = subquery.group_by(Shout.id).order_by(desc(get_rating_func(aliased_reaction))) subquery = subquery.group_by(Shout.id).order_by(desc(get_rating_func(aliased_reaction)))
from_random_count = params.get("fromRandomCount") random_limit = params.get("random_limit")
if from_random_count: if random_limit:
subquery = subquery.limit(from_random_count) subquery = subquery.limit(random_limit)
q = ( q = (
select(Shout) select(Shout)