update api

This commit is contained in:
felinae98
2022-08-01 22:16:03 +08:00
parent ee01773e64
commit b8af6d0024
5 changed files with 45 additions and 18 deletions
@@ -66,7 +66,7 @@ def register_router_fastapi(driver: Driver, socketio):
return obj
async def check_group_permission(
groupNumber: str, token_obj: dict = Depends(get_jwt_obj)
groupNumber: int, token_obj: dict = Depends(get_jwt_obj)
):
groups = token_obj["groups"]
for group in groups:
@@ -99,7 +99,7 @@ def register_router_fastapi(driver: Driver, socketio):
return await get_target_name(platformName, target, jwt_obj)
@app.post(SUBSCRIBE_URL, dependencies=[Depends(check_group_permission)])
async def _add_group_subs(groupNumber: str, req: AddSubscribeReq):
async def _add_group_subs(groupNumber: int, req: AddSubscribeReq):
return await add_group_sub(
group_number=groupNumber,
platform_name=req.platformName,
@@ -110,7 +110,7 @@ def register_router_fastapi(driver: Driver, socketio):
)
@app.patch(SUBSCRIBE_URL, dependencies=[Depends(check_group_permission)])
async def _update_group_subs(groupNumber: str, req: AddSubscribeReq):
async def _update_group_subs(groupNumber: int, req: AddSubscribeReq):
return await update_group_sub(
group_number=groupNumber,
platform_name=req.platformName,
@@ -121,7 +121,7 @@ def register_router_fastapi(driver: Driver, socketio):
)
@app.delete(SUBSCRIBE_URL, dependencies=[Depends(check_group_permission)])
async def _del_group_subs(groupNumber: str, target: str, platformName: str):
async def _del_group_subs(groupNumber: int, target: str, platformName: str):
return await del_group_sub(groupNumber, platformName, target)
app.mount(URL_BASE, SinglePageApplication(directory=static_path), name="bison")
+4 -4
View File
@@ -89,7 +89,7 @@ async def get_subs_info(jwt_obj: dict):
map(
lambda sub: {
"platformName": sub.target.platform_name,
"targetName": sub.target.name,
"targetName": sub.target.target_name,
"cats": sub.categories,
"tags": sub.tags,
},
@@ -105,7 +105,7 @@ async def get_target_name(platform_name: str, target: str, jwt_obj: dict):
async def add_group_sub(
group_number: str,
group_number: int,
platform_name: str,
target: str,
target_name: str,
@@ -124,7 +124,7 @@ async def add_group_sub(
return {"status": 200, "msg": ""}
async def del_group_sub(group_number: str, platform_name: str, target: str):
async def del_group_sub(group_number: int, platform_name: str, target: str):
try:
await config.del_subscribe(int(group_number), "group", target, platform_name)
except (NoSuchUserException, NoSuchSubscribeException):
@@ -133,7 +133,7 @@ async def del_group_sub(group_number: str, platform_name: str, target: str):
async def update_group_sub(
group_number: str,
group_number: int,
platform_name: str,
target: str,
target_name: str,