From f67ef7f96f19c4857c08cdb999aeb4c034a99d85 Mon Sep 17 00:00:00 2001 From: TheNoxium Date: Wed, 23 Apr 2025 16:06:33 +0300 Subject: [PATCH] fix: account post route --- api/api/db/logic/account.py | 7 ++----- api/api/endpoints/account.py | 13 ++++++++----- 2 files changed, 10 insertions(+), 10 deletions(-) diff --git a/api/api/db/logic/account.py b/api/api/db/logic/account.py index 9df5bc8..941379d 100644 --- a/api/api/db/logic/account.py +++ b/api/api/db/logic/account.py @@ -73,12 +73,11 @@ async def put_user_id(connection: AsyncConnection, update_values, user) -> Optio await connection.commit() -async def post_add_user(connection: AsyncConnection, user: User, user_id: int, creator_id: int) -> Optional[User]: +async def post_add_user(connection: AsyncConnection, user: User, creator_id: int) -> Optional[User]: """ Создает нове поле в таблице account_table. """ query = insert(account_table).values( - id=user_id, name=user.name, login=user.login, email=user.email, @@ -90,9 +89,7 @@ async def post_add_user(connection: AsyncConnection, user: User, user_id: int, c status=user.status.value ) - user.id = user_id - user.creator_id = creator_id - user.created_at = datetime.now(timezone.utc), + await connection.execute(query) diff --git a/api/api/endpoints/account.py b/api/api/endpoints/account.py index a7a21fa..fd44fdc 100644 --- a/api/api/endpoints/account.py +++ b/api/api/endpoints/account.py @@ -19,7 +19,7 @@ from api.db.connection.session import get_connection_dep from api.db.logic.account import get_user_id, put_user_id, post_add_user,get_user_login -from api.schemas.account.account import Role,Status +from api.schemas.account.account import User,Role,Status from api.schemas.endpoints.account import UserUpdate from api.services.access_token_validadtion import AccessTokenValidadtion @@ -53,9 +53,8 @@ async def get_account(user_id: int, return user -@api_router.post("/{user_id}") +@api_router.post("") async def post_account( - user_id: int, user: UserUpdate, connection: AsyncConnection = Depends(get_connection_dep), Authorize: AuthJWT = Depends() @@ -64,11 +63,13 @@ async def post_account( authorize_user = await db_user_role_validation(connection, current_user) - user_validation = await get_user_id(connection, user_id) + user_validation = await get_user_login(connection, user.login) if user_validation is None: - user_new = await post_add_user(connection,user,user_id,authorize_user.id) + + await post_add_user(connection,user,authorize_user.id) + user_new = await get_user_login(connection, user.login) return user_new else: @@ -103,6 +104,8 @@ async def put_account( if update_values is None: return user + user_update_data = User.model_validate(update_values) + await put_user_id(connection, update_values, user)