This commit is contained in:
parent
da33ae92a9
commit
332be3f12b
|
@ -2,7 +2,6 @@ import json
|
||||||
from typing import List
|
from typing import List
|
||||||
|
|
||||||
from sqlalchemy import select, or_
|
from sqlalchemy import select, or_
|
||||||
from sqlalchemy.orm import aliased
|
|
||||||
from sqlalchemy.sql import and_
|
from sqlalchemy.sql import and_
|
||||||
|
|
||||||
from orm.author import Author, AuthorFollower
|
from orm.author import Author, AuthorFollower
|
||||||
|
@ -86,12 +85,11 @@ async def unfollow(_, info, what, slug):
|
||||||
|
|
||||||
def query_follows(user_id: str):
|
def query_follows(user_id: str):
|
||||||
with local_session() as session:
|
with local_session() as session:
|
||||||
aliased_author = aliased(Author)
|
author_id = (
|
||||||
author = (
|
session.query(Author.id).filter(Author.user == user_id).first()
|
||||||
session.query(aliased_author).filter(aliased_author.user == user_id).first()
|
|
||||||
)
|
)
|
||||||
if isinstance(author, Author):
|
session.commit()
|
||||||
author_id = author.id
|
if isinstance(author_id, int):
|
||||||
authors_query = (
|
authors_query = (
|
||||||
select(Author)
|
select(Author)
|
||||||
.join(AuthorFollower, AuthorFollower.follower == author_id)
|
.join(AuthorFollower, AuthorFollower.follower == author_id)
|
||||||
|
|
Loading…
Reference in New Issue
Block a user