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

topic-stat-fix

Browse Source
This commit is contained in:
Untone 2024-04-09 21:05:24 +03:00
parent 489c3c3232
commit 10c24fe400
1 changed files with 10 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
resolvers/stat.py
View File

@ -15,27 +15,25 @@ def add_topic_stat_columns(q):
aliased_followers = aliased(TopicFollower) aliased_followers = aliased(TopicFollower)
aliased_shout = aliased(Shout) aliased_shout = aliased(Shout)
# shouts
q = q.outerjoin(aliased_shout_topic, aliased_shout_topic.topic == Topic.id) q = q.outerjoin(aliased_shout_topic, aliased_shout_topic.topic == Topic.id)
q = q.add_columns( q = q.add_columns(func.count(distinct(aliased_shout_topic.shout)).label('shouts_stat'))
func.count(distinct(aliased_shout_topic.shout)).label('shouts_stat')
)
q = q.outerjoin(aliased_shout, and_( # authors
aliased_shout.id == aliased_shout_topic.shout, q = q.outerjoin(aliased_authors, and_(
aliased_shout.published_at.is_not(None), aliased_shout.id == aliased_authors.shout,
aliased_shout.deleted_at.is_(None) aliased_authors.author == Author.id,
Topic.id.in_(select(ShoutTopic.topic).where(ShoutTopic.shout == aliased_shout.id))
)) ))
q = q.outerjoin(aliased_authors, aliased_shout.authors.contains(aliased_authors.id)) q = q.add_columns(func.count(distinct(aliased_authors.author_id)).label('authors_stat'))
q = q.add_columns(
func.count(distinct(aliased_authors.author)).label('authors_stat')
)
# followers
q = q.outerjoin(aliased_followers, aliased_followers.topic == Topic.id) q = q.outerjoin(aliased_followers, aliased_followers.topic == Topic.id)
q = q.add_columns( q = q.add_columns(
func.count(distinct(aliased_followers.follower)).label('followers_stat') func.count(distinct(aliased_followers.follower)).label('followers_stat')
) )
# Create a subquery for comments count # comments
sub_comments = ( sub_comments = (
select( select(
Shout.id.label('shout_id'), Shout.id.label('shout_id'),
@ -54,8 +52,6 @@ def add_topic_stat_columns(q):
.group_by(Shout.id) .group_by(Shout.id)
.subquery() .subquery()
) )
q = q.outerjoin(sub_comments, aliased_shout_topic.shout == sub_comments.c.shout_id) q = q.outerjoin(sub_comments, aliased_shout_topic.shout == sub_comments.c.shout_id)
q = q.add_columns(func.coalesce(sub_comments.c.comments_count, 0).label('comments_stat')) q = q.add_columns(func.coalesce(sub_comments.c.comments_count, 0).label('comments_stat'))