эксклюзивные права на чтение (#46)

* эксклюзивные права на чтение

* эксклюзивные права на чтение

* Delete migrations/versions/f8c57101c0f6_init.py

* эксклюзивные права на чтение

* эксклюзивные права на чтение

* эксклюзивные права на чтение

Author: gitfresnel

migrations/versions/f8c57101c0f6_init.py

@@ -1,7 +1,7 @@
 """Init
 
 Revision ID: f8c57101c0f6
-Revises: 
+Revises:
 Create Date: 2023-05-09 12:48:25.550608
 
 """

migrations/versions/fc911d58459b_add_is_public_field_to_param.py

@@ -0,0 +1,27 @@
+"""add_is_public_field_to_param
+
+Revision ID: fc911d58459b
+Revises: 5a6490c55c81
+Create Date: 2025-03-11 21:38:50.699014
+
+"""
+
+import sqlalchemy as sa
+from alembic import op
+
+
+# revision identifiers, used by Alembic.
+revision = 'fc911d58459b'
+down_revision = '5a6490c55c81'
+branch_labels = None
+depends_on = None
+
+
+def upgrade():
+    op.add_column('param', sa.Column('is_public', sa.Boolean(), nullable=False, server_default=sa.false()))
+
+
+def downgrade():
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.drop_column('param', 'is_public')
+    # ### end Alembic commands ###

userdata_api/models/db.py

@@ -57,6 +57,7 @@ class Param(BaseDbModel):
     а параметры эти могут лежать в категории "контакты"
     """
 
+    is_public: Mapped[bool] = mapped_column(Boolean, default=False, nullable=False)
     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))

userdata_api/routes/user.py

@@ -18,7 +18,6 @@
 @user.get("/{id}", response_model=UserInfoGet)
 async def get_user_info(
     id: int,
-    additional_data: list[int] = Query(default=[]),
     user: dict[str, Any] = Depends(UnionAuth(scopes=[], allow_none=False, auto_error=True)),
 ) -> UserInfoGet:
     """
@@ -37,7 +36,7 @@ async def get_user_info(
     }
     """
 
-    return UserInfoGet.model_validate(await get(id, user, additional_data))
+    return UserInfoGet.model_validate(await get(id, user))
 
 
 @user.post("/{id}", response_model=StatusResponseModel)

userdata_api/schemas/param.py

@@ -6,6 +6,7 @@
 
 
 class ParamPost(Base):
+    is_public: bool = False
     visible_in_user_response: bool = True
     name: constr(min_length=1)
     is_required: bool
@@ -15,6 +16,7 @@ class ParamPost(Base):
 
 
 class ParamPatch(Base):
+    is_public: bool = False
     visible_in_user_response: bool = True
     name: constr(min_length=1) | None = None
     is_required: bool | None = None

userdata_api/utils/user.py

@@ -113,7 +113,7 @@ async def get_users_info(
     user_ids: list[int],
     category_ids: list[int] | None,
     user: dict[str, int | list[dict[str, str | int]]],
-    additional_data: list[int],
+    additional_data: list[int] | None = None,
 ) -> list[dict[str, str | None]]:
     """.
     Возвращает информацию о данных пользователей в указанных категориях
@@ -123,6 +123,8 @@ async def get_users_info(
     :param user: Сессия выполняющего запрос данных
     :return: Список словарей содержащих id пользователя, категорию, параметр категории и значение этого параметра у пользователя
     """
+    if additional_data is None:
+        additional_data = []
     is_single_user = category_ids is None
     scope_names = [scope["name"] for scope in user["session_scopes"]]
     param_dict: dict[Param, dict[int, list[Info] | Info | None] | None] = {}
@@ -152,6 +154,7 @@ async def get_users_info(
             info.category.read_scope
             and info.category.read_scope not in scope_names
             and (not is_single_user or info.owner_id != user["id"])
+            and not info.param.is_public
         ):
             continue
         if info.param not in param_dict:
@@ -229,9 +232,7 @@ async def get_users_info_batch(
     return UsersInfoGet(items=await get_users_info(user_ids, category_ids, user, additional_data))
 
 
-async def get_user_info(
-    user_id: int, user: dict[str, int | list[dict[str, str | int]]], additional_data: list[int]
-) -> UserInfoGet:
+async def get_user_info(user_id: int, user: dict[str, int | list[dict[str, str | int]]]) -> UserInfoGet:
     """Возвращает информауию о пользователе в соотетствии с переданным токеном.
 
     Пользователь может прочитать любую информацию о себе
@@ -243,7 +244,7 @@ async def get_user_info(
     :return: Список словарей содержащих категорию, параметр категории и значение этого параметра у пользователя
     """
 
-    result = await get_users_info([user_id], None, user, additional_data)
+    result = await get_users_info([user_id], None, user)
     for value in result:
         del value["user_id"]
     return UserInfoGet(items=result)