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

follow-fix

Browse Source
This commit is contained in:
Untone 2024-05-01 04:00:37 +03:00
parent 658a2400c4
commit 88de00706d
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
resolvers/follower.py
View File

@ -48,10 +48,12 @@ async def follow(_, info, what, slug):
if result: if result:
[author] = result [author] = result
if author: if author:
await cache_follower(follower_dict, author.dict()) author_dict = author.dict()
await cache_follower(follower_dict, author_dict)
await notify_follower(follower_dict, author.id, "follow") await notify_follower(follower_dict, author.id, "follow")
if not any(a["id"] == author.id for a in follows): if not any(a["id"] == author.id for a in follows):
follows.append(author.dict()) if author_dict not in follows:
follows.append(author_dict)
elif what == "TOPIC": elif what == "TOPIC":
error = topic_follow(follower_id, slug) error = topic_follow(follower_id, slug)
@ -90,7 +92,8 @@ async def unfollow(_, info, what, slug):
logger.info(f"@{follower_dict.get('slug')} unfollowed @{slug}") logger.info(f"@{follower_dict.get('slug')} unfollowed @{slug}")
author = local_session().query(Author).where(Author.slug == slug).first() author = local_session().query(Author).where(Author.slug == slug).first()
if isinstance(author, Author): if isinstance(author, Author):
await cache_follower(follower_dict, author.dict(), False) author_dict = author.dict()
await cache_follower(follower_dict, author_dict, False)
await notify_follower(follower_dict, author.id, "unfollow") await notify_follower(follower_dict, author.id, "unfollow")
for idx, item in enumerate(follows): for idx, item in enumerate(follows):
if item["id"] == author.id: if item["id"] == author.id: