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

dict-fix

Browse Source
This commit is contained in:
Untone 2024-03-11 16:58:31 +03:00
parent e6f5cfcb8d
commit 78dbde6273
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
resolvers/follower.py
View File

@ -46,7 +46,7 @@ async def follow(_, info, what, slug):
[author] = get_with_stat(select(Author).select_from(Author).where(Author.slug == slug)) [author] = get_with_stat(select(Author).select_from(Author).where(Author.slug == slug))
if not author: if not author:
return {"error": "author is not found"} return {"error": "author is not found"}
follows = await update_follows_for_author(follower, 'author', author, True) follows = await update_follows_for_author(follower, 'author', author.dict(), True)
_followers = await update_followers_for_author(follower, author, True) _followers = await update_followers_for_author(follower, author, True)
await notify_follower(follower.dict(), author.id, 'unfollow') await notify_follower(follower.dict(), author.id, 'unfollow')
@ -56,7 +56,7 @@ async def follow(_, info, what, slug):
[topic] = get_with_stat(select(Topic).where(Topic.slug == slug)) [topic] = get_with_stat(select(Topic).where(Topic.slug == slug))
if not topic: if not topic:
return {"error": "topic is not found"} return {"error": "topic is not found"}
follows = await update_follows_for_author(follower, 'topic', topic, True) follows = await update_follows_for_author(follower, 'topic', topic.dict(), True)
elif what == 'COMMUNITY': elif what == 'COMMUNITY':
follows = local_session().execute(select(Community)) follows = local_session().execute(select(Community))
@ -67,7 +67,7 @@ async def follow(_, info, what, slug):
[shout] = local_session().execute(select(Shout).where(Shout.slug == slug)) [shout] = local_session().execute(select(Shout).where(Shout.slug == slug))
if not shout: if not shout:
return {"error": "cant find shout"} return {"error": "cant find shout"}
follows = await update_follows_for_author(follower, 'shout', shout, True) follows = await update_follows_for_author(follower, 'shout', shout.dict(), True)
return {f'{what.lower()}s': follows, "error": error} return {f'{what.lower()}s': follows, "error": error}
@ -94,7 +94,7 @@ async def unfollow(_, info, what, slug):
return {"error": "cant find author"} return {"error": "cant find author"}
_followers = await update_followers_for_author(follower, author, False) _followers = await update_followers_for_author(follower, author, False)
await notify_follower(follower.dict(), author.id, 'unfollow') await notify_follower(follower.dict(), author.id, 'unfollow')
follows = await update_follows_for_author(follower, 'author', author, False) follows = await update_follows_for_author(follower, 'author', author.dict(), False)
elif what == 'TOPIC': elif what == 'TOPIC':
error = topic_unfollow(follower.id, slug) error = topic_unfollow(follower.id, slug)
@ -103,7 +103,7 @@ async def unfollow(_, info, what, slug):
[topic] = get_with_stat(select(Topic).where(Topic.slug == slug)) [topic] = get_with_stat(select(Topic).where(Topic.slug == slug))
if not topic: if not topic:
return {"error": "cant find topic"} return {"error": "cant find topic"}
follows = await update_follows_for_author(follower, 'topic', topic, False) follows = await update_follows_for_author(follower, 'topic', topic.dict(), False)
elif what == 'COMMUNITY': elif what == 'COMMUNITY':
follows = local_session().execute(select(Community)) follows = local_session().execute(select(Community))
@ -116,7 +116,7 @@ async def unfollow(_, info, what, slug):
if not shout: if not shout:
return {"error": "cant find shout"} return {"error": "cant find shout"}
if not error: if not error:
follows = await update_follows_for_author(follower, 'shout', shout, False) follows = await update_follows_for_author(follower, 'shout', shout.dict(), False)
return {'error': error, f'{what.lower()}s': follows} return {'error': error, f'{what.lower()}s': follows}