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

following-fix-3
All checks were successful
Deploy to core / deploy (push) Successful in 1m39s
Details

Browse Source
This commit is contained in:
Untone 2024-01-31 17:48:36 +03:00
parent 77907c73e0
commit 5a810fa126
1 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
resolvers/follower.py
View File

@ -1,6 +1,8 @@
import logging
from typing import List
from sqlalchemy.orm import aliased
from orm.author import Author, AuthorFollower
from orm.community import Community
from orm.reaction import Reaction
@ -103,23 +105,23 @@ async def get_my_followed(_, info):
author = session.query(Author).filter(Author.user == user_id).first()
if isinstance(author, Author):
author_id = author.id
aliased_author = aliased(Author)
authors_query = (
session.query(Author)
session.query(aliased_author, AuthorFollower)
.join(AuthorFollower, AuthorFollower.follower == author_id)
.filter(AuthorFollower.author == Author.id)
.filter(AuthorFollower.author == aliased_author.id)
)
topics_query = (
session.query(Topic)
session.query(Topic, TopicFollower)
.join(TopicFollower, TopicFollower.follower == author_id)
.filter(TopicFollower.topic == Topic.id)
)
for [author] in session.execute(authors_query).unique():
for [author] in session.execute(authors_query).all():
authors.add(author)
for [topic] in session.execute(topics_query).unique():
for [topic] in session.execute(topics_query).all():
topics.add(topic)
communities = session.query(Community).all()