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

auth-cache-fix
All checks were successful
Deploy to core / deploy (push) Successful in 1m58s
Details

Browse Source
This commit is contained in:
Untone 2024-02-23 14:19:54 +03:00
parent 64012344cb
commit 9999c362d4
1 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
services/auth.py
View File

@ -43,15 +43,22 @@ def cache_auth_request(f):
req = args[0] req = args[0]
cache_key = auth_cache_key(req) cache_key = auth_cache_key(req)
result = region.get(cache_key) result = region.get(cache_key)
if result is None: if result is not None: # Проверка наличия значения в кэше
logger.debug(f'CACHE found {cache_key}: {result}')
if isinstance(result, list) and len(result) == 2: # Проверка формата значения
return result
try:
[user_id, user_roles] = await f(*args, **kwargs) [user_id, user_roles] = await f(*args, **kwargs)
if user_id: if user_id:
region.set(cache_key, [user_id, user_roles]) region.set(cache_key, [user_id, user_roles])
return result return [user_id, user_roles]
except Exception as e:
logger.error(f'Error processing cache_auth_request: {e}')
return None # Возвращение None в случае ошибки
return decorated_function return decorated_function
# Измененная функция проверки аутентификации с кэшированием # Измененная функция проверки аутентификации с кэшированием
@cache_auth_request @cache_auth_request
async def check_auth(req): async def check_auth(req):