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

follows-stat-fix
All checks were successful
Deploy on push / deploy (push) Successful in 1m43s
Details

Browse Source
This commit is contained in:
Untone 2024-02-23 23:15:16 +03:00
parent 8b9ac594cd
commit 1edf93f7ce
1 changed files with 21 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
resolvers/stat.py
View File

@ -1,4 +1,4 @@
from sqlalchemy import func, distinct from sqlalchemy import func, distinct, select
from sqlalchemy.orm import aliased from sqlalchemy.orm import aliased
from orm.topic import TopicFollower, Topic from orm.topic import TopicFollower, Topic
@ -14,10 +14,10 @@ def add_topic_stat_columns(q):
aliased_shout_topic = aliased(ShoutTopic) aliased_shout_topic = aliased(ShoutTopic)
q = ( q = (
q.outerjoin(aliased_shout_topic, Topic.id == aliased_shout_topic.topic) q.outerjoin(aliased_shout_topic, aliased_shout_topic.topic == Topic.id)
.add_columns(func.count(distinct(aliased_shout_topic.shout)).label("shouts_stat")) .add_columns(func.count(distinct(aliased_shout_topic.shout)).label("shouts_stat"))
.outerjoin(aliased_shout_author, aliased_shout_topic.shout == aliased_shout_author.shout) .outerjoin(aliased_shout_author, aliased_shout_topic.shout == aliased_shout_author.shout)
.add_columns(func.count(distinct(aliased_shout_author.user)).label("authors_stat")) .add_columns(func.count(distinct(aliased_shout_author.author)).label("authors_stat"))
.outerjoin(aliased_topic_follower) .outerjoin(aliased_topic_follower)
.add_columns(func.count(distinct(aliased_topic_follower.follower)).label("followers_stat")) .add_columns(func.count(distinct(aliased_topic_follower.follower)).label("followers_stat"))
) )
@ -71,13 +71,27 @@ def get_topics_with_stat(q):
def author_follows_authors(author_id: int): def author_follows_authors(author_id: int):
authors = [] aliased_author_authors = aliased(AuthorFollower, name="af")
return authors
q = (
select(Author)
.join(aliased_author_authors, Author.id == aliased_author_authors.author)
.filter(aliased_author_authors.follower == author_id)
)
q = add_author_stat_columns(q)
return execute_with_ministat(q)
def author_follows_topics(author_id: int): def author_follows_topics(author_id: int):
topics = [] q = (
return topics select(Topic)
.join(TopicFollower, Topic.id == TopicFollower.topic)
.filter(TopicFollower.follower == author_id)
)
q = add_topic_stat_columns(q)
return execute_with_ministat(q)
def query_follows(author_id: int): def query_follows(author_id: int):