This commit is contained in:
parent
b13d532da2
commit
4fec0ca7fb
|
@ -22,9 +22,9 @@ async def follow(_, info, what, slug):
|
||||||
result = FollowingResult("NEW", "author", slug)
|
result = FollowingResult("NEW", "author", slug)
|
||||||
await FollowingManager.push("author", result)
|
await FollowingManager.push("author", result)
|
||||||
with local_session() as session:
|
with local_session() as session:
|
||||||
author_id = session.query(User.id).where(User.slug == slug).one()
|
author = session.query(User.id).where(User.slug == slug).one()
|
||||||
follower = session.query()
|
follower = session.query(User.id).where(User.id == auth.user_id).one()
|
||||||
notify_follower(follower.dict(), author_id)
|
notify_follower(follower.dict(), author.id)
|
||||||
elif what == "TOPIC":
|
elif what == "TOPIC":
|
||||||
if topic_follow(auth.user_id, slug):
|
if topic_follow(auth.user_id, slug):
|
||||||
result = FollowingResult("NEW", "topic", slug)
|
result = FollowingResult("NEW", "topic", slug)
|
||||||
|
|
Loading…
Reference in New Issue
Block a user