urec/chat_back
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages 1 Wiki Activity Actions

Тест кода

Browse source
This commit is contained in:
urec56 2024-08-27 20:33:56 +04:00
parent 55d2f2d0ef
commit d4d8062ac8
2 changed files with 0 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
app/services/redis_service.py
View file

@ -1,4 +1,3 @@
import logging
from datetime import timedelta from datetime import timedelta
from pydantic import BaseModel from pydantic import BaseModel
@ -33,7 +32,6 @@ class RedisService:
async def get_value[T: type[BaseModel]](self, key: str, model: T | None = None) -> T | str: async def get_value[T: type[BaseModel]](self, key: str, model: T | None = None) -> T | str:
value = await self.redis_session.get(key) value = await self.redis_session.get(key)
logging.warning(value)
return model.model_validate_json(value) if model else value.decode() return model.model_validate_json(value) if model else value.decode()
async def delete_key(self, key: str) -> None: async def delete_key(self, key: str) -> None:

9
app/services/user_service.py
View file

@ -1,4 +1,3 @@
import logging
from datetime import timedelta from datetime import timedelta
from pydantic import ValidationError from pydantic import ValidationError
@ -75,21 +74,13 @@ class UserService:
async with RedisService(is_raise=True) as redis: async with RedisService(is_raise=True) as redis:
verification_code = await redis.get_value(key=f"user_verification_code: {user.id}") verification_code = await redis.get_value(key=f"user_verification_code: {user.id}")
except AttributeError: except AttributeError:
logging.warning("Хуйня в редисе")
raise WrongCodeException raise WrongCodeException
if verification_code != confirmation_code: if verification_code != confirmation_code:
raise WrongCodeException raise WrongCodeException
logging.warning(f"{confirmation_code=}")
logging.warning(f"{verification_code=}")
logging.warning(f"{verification_code == confirmation_code=}")
async with uow: async with uow:
await uow.user.change_data(user_id=user.id, role=settings.VERIFICATED_USER) await uow.user.change_data(user_id=user.id, role=settings.VERIFICATED_USER)
logging.warning(f"dict user: {dict(id=user.id)}")
async with RedisService() as redis: async with RedisService() as redis:
await redis.delete_key(key=f"user: {dict(id=user.id)}") await redis.delete_key(key=f"user: {dict(id=user.id)}")
await redis.set_key(
key=f"user: {dict(id=user.id)}", expire_time=timedelta(hours=1), value=user.model_dump_json()
)
await uow.commit() await uow.commit()
@staticmethod @staticmethod