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

fix shoutsSubscribed, shoutsReviewed, shoutsCandidates

Browse Source
This commit is contained in:
knst-kotov 2022-02-15 13:34:41 +03:00
parent fdf64ce5f9
commit 847240e20f
1 changed files with 11 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
resolvers/zine.py
View File

@ -423,16 +423,18 @@ async def shouts_by_community(_, info, community, page, size):
return shouts return shouts
@query.field("shoutsSubscribed") @query.field("shoutsSubscribed")
@login_required
async def shouts_subscribed(_, info, page, size): async def shouts_subscribed(_, info, page, size):
user = info.context["request"].user
with local_session() as session: with local_session() as session:
shouts_by_topic = session.query(Shout).\ shouts_by_topic = session.query(Shout).\
join(ShoutTopic).\ join(ShoutTopic).\
join(TopicSubscription, ShoutTopic.topic == TopicSubscription.topic).\ join(TopicSubscription, ShoutTopic.topic == TopicSubscription.topic).\
where(and_(Shout.publishedAt != None, TopicSubscription.subscriber == User.slug)) where(and_(Shout.publishedAt != None, TopicSubscription.subscriber == user.slug))
shouts_by_author = session.query(Shout).\ shouts_by_author = session.query(Shout).\
join(ShoutAuthor).\ join(ShoutAuthor).\
join(AuthorSubscription, ShoutAuthor.user == AuthorSubscription.author).\ join(AuthorSubscription, ShoutAuthor.user == AuthorSubscription.author).\
where(and_(Shout.publishedAt != None, AuthorSubscription.subscriber == User.slug)) where(and_(Shout.publishedAt != None, AuthorSubscription.subscriber == user.slug))
shouts = shouts_by_topic.union(shouts_by_author).\ shouts = shouts_by_topic.union(shouts_by_author).\
order_by(desc(Shout.publishedAt)).\ order_by(desc(Shout.publishedAt)).\
limit(size).\ limit(size).\
@ -441,15 +443,16 @@ async def shouts_subscribed(_, info, page, size):
return shouts return shouts
@query.field("shoutsReviewed") @query.field("shoutsReviewed")
@login_required
async def shouts_reviewed(_, info, page, size): async def shouts_reviewed(_, info, page, size):
user = info.context["request"].user
with local_session() as session: with local_session() as session:
shouts_by_rating = session.query(Shout).\ shouts_by_rating = session.query(Shout).\
join(ShoutRating).\ join(ShoutRating).\
where(and_(Shout.publishedAt != None, ShoutRating.rater == User.slug)) where(and_(Shout.publishedAt != None, ShoutRating.rater == user.slug))
shouts_by_comment = session.query(Shout).\ shouts_by_comment = session.query(Shout).\
join(Comment).\ join(Comment).\
where(and_(Shout.publishedAt != None, Comment.author == User.id)) where(and_(Shout.publishedAt != None, Comment.author == user.id))
shouts = shouts_by_rating.union(shouts_by_comment).\ shouts = shouts_by_rating.union(shouts_by_comment).\
order_by(desc(Shout.publishedAt)).\ order_by(desc(Shout.publishedAt)).\
limit(size).\ limit(size).\
@ -458,12 +461,14 @@ async def shouts_reviewed(_, info, page, size):
return shouts return shouts
@query.field("shoutsCandidates") @query.field("shoutsCandidates")
@login_required
async def shouts_candidates(_, info, size): async def shouts_candidates(_, info, size):
user = info.context["request"].user
#TODO: postgres heavy load #TODO: postgres heavy load
with local_session() as session: with local_session() as session:
shouts = session.query(Shout).distinct().\ shouts = session.query(Shout).distinct().\
outerjoin(ShoutRating).\ outerjoin(ShoutRating).\
where(and_(Shout.publishedAt != None, ShoutRating.rater != User.slug)).\ where(and_(Shout.publishedAt != None, ShoutRating.rater != user.slug)).\
order_by(desc(Shout.publishedAt)).\ order_by(desc(Shout.publishedAt)).\
limit(size) limit(size)