update-shout-fix-6
This commit is contained in:
parent
ee7c464065
commit
fa76d6c7b4
|
@ -230,8 +230,8 @@ async def load_shouts_by(_, _info, options):
|
||||||
return shouts
|
return shouts
|
||||||
|
|
||||||
|
|
||||||
@query.field('load_shouts_drafts')
|
|
||||||
@login_required
|
@login_required
|
||||||
|
@query.field('load_shouts_drafts')
|
||||||
async def load_shouts_drafts(_, info):
|
async def load_shouts_drafts(_, info):
|
||||||
user_id = info.context.get('user_id')
|
user_id = info.context.get('user_id')
|
||||||
shouts = []
|
shouts = []
|
||||||
|
|
|
@ -83,15 +83,14 @@ def login_required(f):
|
||||||
@wraps(f)
|
@wraps(f)
|
||||||
async def decorated_function(*args, **kwargs):
|
async def decorated_function(*args, **kwargs):
|
||||||
info = args[1]
|
info = args[1]
|
||||||
context = info.context
|
req = info.context.get('request')
|
||||||
req = context.get('request')
|
|
||||||
authorized = await check_auth(req)
|
authorized = await check_auth(req)
|
||||||
if authorized:
|
if authorized:
|
||||||
user_id, user_roles = authorized
|
user_id, user_roles = authorized
|
||||||
if user_id and user_roles:
|
if user_id and user_roles:
|
||||||
logger.info(f' got {user_id} roles: {user_roles}')
|
logger.info(f' got {user_id} roles: {user_roles}')
|
||||||
context['user_id'] = user_id.strip()
|
info.context['user_id'] = user_id.strip()
|
||||||
context['roles'] = user_roles
|
info.context['roles'] = user_roles
|
||||||
return await f(*args, **kwargs)
|
return await f(*args, **kwargs)
|
||||||
|
|
||||||
return decorated_function
|
return decorated_function
|
||||||
|
|
Loading…
Reference in New Issue
Block a user