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

order shouts by publishedAt

Browse Source
This commit is contained in:
knst-kotov 2021-12-17 15:56:05 +01:00
parent 9ea6c6c71a
commit 931fd887d9
1 changed files with 9 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
resolvers/zine.py
View File

@ -82,7 +82,7 @@ class ShoutsCache:
stmt = select(Shout).\ stmt = select(Shout).\
options(selectinload(Shout.authors), selectinload(Shout.topics)).\ options(selectinload(Shout.authors), selectinload(Shout.topics)).\
where(Shout.publishedAt != None).\ where(Shout.publishedAt != None).\
order_by(desc("createdAt")).\ order_by(desc("publishedAt")).\
limit(ShoutsCache.limit) limit(ShoutsCache.limit)
shouts = [] shouts = []
for row in session.execute(stmt): for row in session.execute(stmt):
@ -351,8 +351,8 @@ async def shouts_by_topic(_, info, topic, limit):
with local_session() as session: with local_session() as session:
shouts = session.query(Shout).\ shouts = session.query(Shout).\
join(ShoutTopic).\ join(ShoutTopic).\
where(ShoutTopic.topic == topic).\ where(and_(ShoutTopic.topic == topic, Shout.publishedAt != None)).\
order_by(desc(Shout.createdAt)).\ order_by(desc(Shout.publishedAt)).\
limit(limit) limit(limit)
return shouts return shouts
@ -367,8 +367,8 @@ async def shouts_by_author(_, info, author, limit):
shouts = session.query(Shout).\ shouts = session.query(Shout).\
join(ShoutAuthor).\ join(ShoutAuthor).\
where(ShoutAuthor.user == user.id).\ where(and_(ShoutAuthor.user == user.id, Shout.publishedAt != None)).\
order_by(desc(Shout.createdAt)).\ order_by(desc(Shout.publishedAt)).\
limit(limit) limit(limit)
return shouts return shouts
@ -379,9 +379,10 @@ async def shouts_by_community(_, info, community, limit):
#TODO fix postgres high load #TODO fix postgres high load
shouts = session.query(Shout).distinct().\ shouts = session.query(Shout).distinct().\
join(ShoutTopic).\ join(ShoutTopic).\
where(ShoutTopic.topic.in_(\ where(and_(Shout.publishedAt != None,\
ShoutTopic.topic.in_(\
select(Topic.slug).where(Topic.community == community)\ select(Topic.slug).where(Topic.community == community)\
)).\ ))).\
order_by(desc(Shout.createdAt)).\ order_by(desc(Shout.publishedAt)).\
limit(limit) limit(limit)
return shouts return shouts