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

fix shoutsByCommunity

Browse Source
This commit is contained in:
knst-kotov 2021-12-17 15:27:16 +01:00
parent db40c2dd93
commit 9ea6c6c71a
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
resolvers/zine.py
View File

@ -375,12 +375,13 @@ async def shouts_by_author(_, info, author, limit):
@query.field("shoutsByCommunity") @query.field("shoutsByCommunity")
async def shouts_by_community(_, info, community, limit): async def shouts_by_community(_, info, community, limit):
with local_session() as session: with local_session() as session:
topics = select(Topic.slug).\
where(Topic.community == community).cte()
shouts = session.query(Shout).\ #TODO fix postgres high load
shouts = session.query(Shout).distinct().\
join(ShoutTopic).\ join(ShoutTopic).\
where(ShoutTopic.topic.in_(topics)).\ where(ShoutTopic.topic.in_(\
select(Topic.slug).where(Topic.community == community)\
)).\
order_by(desc(Shout.createdAt)).\ order_by(desc(Shout.createdAt)).\
limit(limit) #TODO fix limit limit(limit)
return shouts return shouts