-
Notifications
You must be signed in to change notification settings - Fork 0
/
param.py
108 lines (94 loc) · 4.75 KB
/
param.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
from typing import Any
from auth_lib.fastapi import UnionAuth
from fastapi import APIRouter, Depends, Request
from fastapi_sqlalchemy import db
from pydantic import parse_obj_as
from userdata_api.exceptions import AlreadyExists, ObjectNotFound
from userdata_api.models.db import Category, Param
from userdata_api.schemas.param import ParamGet, ParamPatch, ParamPost
from userdata_api.schemas.response_model import StatusResponseModel
param = APIRouter(prefix="/category/{category_id}/param", tags=["Param"])
@param.post("", response_model=ParamGet)
async def create_param(
request: Request,
category_id: int,
param_inp: ParamPost,
_: dict[str, Any] = Depends(UnionAuth(scopes=["userdata.param.create"], allow_none=False, auto_error=True)),
) -> ParamGet:
"""
Создать поле внутри категории. Ответ на пользовательские данные будет такой {..., category: {...,param: '', ...}}
:param request: https://fastapi.tiangolo.com/advanced/using-request-directly/
:param category_id: Айди котегории в которой создавать параметр
:param param_inp: Модель для создания
:param _: Аутентификация
:return: ParamGet - созданный параметр
"""
Category.get(category_id, session=db.session)
if Param.query(session=db.session).filter(Param.category_id == category_id, Param.name == param_inp.name).all():
raise AlreadyExists(Param, param_inp.name)
return ParamGet.from_orm(Param.create(session=db.session, **param_inp.dict(), category_id=category_id))
@param.get("/{id}", response_model=ParamGet)
async def get_param(id: int, category_id: int) -> ParamGet:
"""
Получить параметр по айди
:param id: Айди параметра
:param category_id: айди категории в которой этот параметр находиится
:return: ParamGet - полученный параметр
"""
res = Param.query(session=db.session).filter(Param.id == id, Param.category_id == category_id).one_or_none()
if not res:
raise ObjectNotFound(Param, id)
return ParamGet.from_orm(res)
@param.get("", response_model=list[ParamGet])
async def get_params(category_id: int) -> list[ParamGet]:
"""
Получить все параметры категории
:param category_id: Айди категории
:return: list[ParamGet] - список полученных параметров
"""
return parse_obj_as(list[ParamGet], Param.query(session=db.session).filter(Param.category_id == category_id).all())
@param.patch("/{id}", response_model=ParamGet)
async def patch_param(
request: Request,
id: int,
category_id: int,
param_inp: ParamPatch,
_: dict[str, Any] = Depends(UnionAuth(scopes=["userdata.param.update"], allow_none=False, auto_error=True)),
) -> ParamGet:
"""
Обновить параметр внутри категории
:param request: https://fastapi.tiangolo.com/advanced/using-request-directly/
:param id: Айди обновляемого параметра
:param category_id: Адйи категории в которой находится параметр
:param param_inp: Модель для создания параметра
:param _: Аутентификация
:return: ParamGet- Обновленный параметр
"""
if category_id:
Category.get(category_id, session=db.session)
if category_id:
return ParamGet.from_orm(
Param.update(id, session=db.session, **param_inp.dict(exclude_unset=True), category_id=category_id)
)
return ParamGet.from_orm(Param.update(id, session=db.session, **param_inp.dict(exclude_unset=True)))
@param.delete("/{id}", response_model=StatusResponseModel)
async def delete_param(
request: Request,
id: int,
category_id: int,
_: dict[str, Any] = Depends(UnionAuth(scopes=["userdata.param.delete"], allow_none=False, auto_error=True)),
) -> StatusResponseModel:
"""
Удалить параметр внутри категории
:param request: https://fastapi.tiangolo.com/advanced/using-request-directly/
:param id: Айди удаляемого параметра
:param category_id: Айди категории в которой находится удлаляемый параметр
:param _: Аутентификация
:return: None
"""
res: Param = Param.query(session=db.session).filter(Param.id == id, Param.category_id == category_id).one_or_none()
if not res:
raise ObjectNotFound(Param, id)
res.is_deleted = True
db.session.commit()
return StatusResponseModel(status="Success", message="Param deleted")