This commit is contained in:
parent
b3eda4a0e1
commit
739b7b40d6
|
@ -30,11 +30,9 @@ async def follow(_, info, what, slug):
|
||||||
if not user_id:
|
if not user_id:
|
||||||
return {'error': 'unauthorized'}
|
return {'error': 'unauthorized'}
|
||||||
|
|
||||||
follower_query = select(Author).select_from(Author).filter(Author.user == user_id)
|
follower = local_session().query(Author).filter(Author.user == user_id).first()
|
||||||
[follower] = local_session().execute(follower_query)
|
|
||||||
if not follower:
|
if not follower:
|
||||||
return {'error': 'cant find follower'}
|
return {'error': 'cant find follower'}
|
||||||
|
|
||||||
if what == 'AUTHOR':
|
if what == 'AUTHOR':
|
||||||
error = author_follow(follower.id, slug)
|
error = author_follow(follower.id, slug)
|
||||||
if not error:
|
if not error:
|
||||||
|
@ -70,11 +68,9 @@ async def unfollow(_, info, what, slug):
|
||||||
user_id = info.context.get('user_id')
|
user_id = info.context.get('user_id')
|
||||||
if not user_id:
|
if not user_id:
|
||||||
return {'error': 'unauthorized'}
|
return {'error': 'unauthorized'}
|
||||||
follower_query = select(Author).filter(Author.user == user_id)
|
follower = local_session().query(Author).filter(Author.user == user_id).first()
|
||||||
[follower] = local_session().execute(follower_query)
|
|
||||||
if not follower:
|
if not follower:
|
||||||
return {'error': 'follower profile is not found'}
|
return {'error': 'follower profile is not found'}
|
||||||
|
|
||||||
if what == 'AUTHOR':
|
if what == 'AUTHOR':
|
||||||
error = author_unfollow(follower.id, slug)
|
error = author_unfollow(follower.id, slug)
|
||||||
# NOTE: after triggers should update cached stats
|
# NOTE: after triggers should update cached stats
|
||||||
|
|
Loading…
Reference in New Issue
Block a user