14 скрытие части юзердаты от пользователя

migrations/versions/ea9459426db1_add_visible_in_user_response_field_to_.py

@@ -0,0 +1,29 @@
+"""Add visible_in_user_response field to Param table
+
+Revision ID: ea9459426db1
+Revises: f8c57101c0f6
+Create Date: 2024-05-12 20:27:45.549332
+
+"""
+
+import sqlalchemy as sa
+from alembic import op
+
+
+# revision identifiers, used by Alembic.
+revision = 'ea9459426db1'
+down_revision = 'f8c57101c0f6'
+branch_labels = None
+depends_on = None
+
+
+def upgrade():
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.add_column('param', sa.Column('visible_in_user_response', sa.Boolean(), nullable=False, server_default='0'))
+    # ### end Alembic commands ###
+
+
+def downgrade():
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.drop_column('param', 'visible_in_user_response')
+    # ### end Alembic commands ###

migrations/versions/f8c57101c0f6_init.py

@@ -5,6 +5,7 @@
 Create Date: 2023-05-09 12:48:25.550608
 
 """
+
 import sqlalchemy as sa
 from alembic import op
 

userdata_api/models/db.py

@@ -57,6 +57,7 @@ class Param(BaseDbModel):
     а параметры эти могут лежать в категории "контакты"
     """
 
+    visible_in_user_response: Mapped[bool] = mapped_column(Boolean, default=True)
     name: Mapped[str] = mapped_column(String)
     category_id: Mapped[int] = mapped_column(Integer, ForeignKey(Category.id))
     is_required: Mapped[bool] = mapped_column(Boolean, default=False)

userdata_api/routes/user.py

@@ -1,7 +1,7 @@
 from typing import Any
 
 from auth_lib.fastapi import UnionAuth
-from fastapi import APIRouter, Depends
+from fastapi import APIRouter, Depends, Query
 
 from userdata_api.schemas.response_model import StatusResponseModel
 from userdata_api.schemas.user import UserInfoGet, UserInfoUpdate
@@ -14,12 +14,15 @@
 
 @user.get("/{id}", response_model=UserInfoGet)
 async def get_user_info(
-    id: int, user: dict[str, Any] = Depends(UnionAuth(scopes=[], allow_none=False, auto_error=True))
+    id: int,
+    additional_data: list[str] = Query(default=[]),
+    user: dict[str, Any] = Depends(UnionAuth(scopes=[], allow_none=False, auto_error=True)),
 ) -> UserInfoGet:
     """
     Получить информацию о пользователе
     \f
     :param id: Айди овнера информации(пользователя)
+    :additional_data: список невидимых по дефолту параметров
     :param user: Аутентфикация
     :return: Словарь, ключи - категории на которые хватило прав(овнеру не нужны права, он получает всё).
     Значения - словари, ключи которых - имена параметров,
@@ -30,7 +33,8 @@ async def get_user_info(
     ...
     }
     """
-    return UserInfoGet.model_validate(await get(id, user))
+
+    return UserInfoGet.model_validate(await get(id, user, additional_data))
 
 
 @user.post("/{id}", response_model=StatusResponseModel)
@@ -53,7 +57,7 @@ async def update_user(
     Чтобы обновить от имени админиа, надо иметь скоуп `userdata.info.admin`
     Чтобы обновить неизменяемую информацию надо обладать скоупом `userdata.info.update`
     Для обновления своей информации(источник `user`) не нужны скоупы на обновление соответствующих категорий
-    Для обновления чужой информации от имени админа(источник  `admin`)
+    Для обновления чужой информации от имени админа(источник `admin`)
     нужны скоупы на обновление всех указанных в теле запроса категорий пользовательских данных данных
     \f
     :param request: Запрос из fastapi

userdata_api/schemas/param.py

@@ -6,13 +6,15 @@
 
 
 class ParamPost(Base):
+    visible_in_user_response: bool = True
     name: constr(min_length=1)
     is_required: bool
     changeable: bool
     type: ViewType
 
 
 class ParamPatch(Base):
+    visible_in_user_response: bool = True
     name: constr(min_length=1) | None = None
     is_required: bool | None = None
     changeable: bool | None = None

userdata_api/utils/user.py

@@ -1,7 +1,7 @@
 from __future__ import annotations
 
 from fastapi_sqlalchemy import db
-from sqlalchemy import not_
+from sqlalchemy import String, cast, func, not_, or_
 
 from userdata_api.exceptions import Forbidden, ObjectNotFound
 from userdata_api.models.db import Category, Info, Param, Source, ViewType
@@ -90,7 +90,9 @@ async def patch_user_info(new: UserInfoUpdate, user_id: int, user: dict[str, int
             continue
 
 
-async def get_user_info(user_id: int, user: dict[str, int | list[dict[str, str | int]]]) -> UserInfoGet:
+async def get_user_info(
+    user_id: int, user: dict[str, int | list[dict[str, str | int]]], additional_data: list[str]
+) -> UserInfoGet:
     """
     Возвращает информауию о пользователе в соотетствии с переданным токеном.
 
@@ -100,13 +102,24 @@ async def get_user_info(user_id: int, user: dict[str, int | list[dict[str, str |
 
     :param user_id: Айди пользователя
     :param user: Сессия выполняющего запрос данных
+    :additional_data: Список невидимых по дефолту параметров
     :return: Список словарей содержащих категорию, параметр категории и значение этого параметра у польщователя
     """
     infos: list[Info] = (
         Info.query(session=db.session)
         .join(Param)
         .join(Category)
-        .filter(Info.owner_id == user_id, not_(Param.is_deleted), not_(Category.is_deleted))
+        .filter(
+            Info.owner_id == user_id,
+            not_(Param.is_deleted),
+            not_(Category.is_deleted),
+            or_(
+                Param.visible_in_user_response,
+                func.concat('category', cast(Category.id, String), '.field', cast(Param.id, String)).in_(
+                    additional_data
+                ),
+            ),
+        )
         .all()
     )
     if not infos: