From ca2c0392bbca56a7092919dfe51ce317d01f0b55 Mon Sep 17 00:00:00 2001 From: WithdewHua Date: Sat, 16 Sep 2023 18:42:47 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E8=B0=83=E6=95=B4=20API=20=E9=A1=BA?= =?UTF-8?q?=E5=BA=8F,=E9=81=BF=E5=85=8D=E9=94=99=E8=AF=AF=E5=8C=B9?= =?UTF-8?q?=E9=85=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/api/endpoints/subscribe.py | 72 +++++++++++++++++----------------- 1 file changed, 36 insertions(+), 36 deletions(-) diff --git a/app/api/endpoints/subscribe.py b/app/api/endpoints/subscribe.py index c4bf53d7..052bf107 100644 --- a/app/api/endpoints/subscribe.py +++ b/app/api/endpoints/subscribe.py @@ -138,6 +138,42 @@ def subscribe_mediaid( return result if result else Subscribe() +@router.get("/refresh", summary="刷新订阅", response_model=schemas.Response) +def refresh_subscribes( + db: Session = Depends(get_db), + _: schemas.TokenPayload = Depends(verify_token)) -> Any: + """ + 刷新所有订阅 + """ + SubscribeChain(db).refresh() + return schemas.Response(success=True) + + +@router.get("/search", summary="搜索所有订阅", response_model=schemas.Response) +def search_subscribes( + background_tasks: BackgroundTasks, + db: Session = Depends(get_db), + _: schemas.TokenPayload = Depends(verify_token)) -> Any: + """ + 搜索所有订阅 + """ + background_tasks.add_task(start_subscribe_search, db=db, sid=None, state='R') + return schemas.Response(success=True) + + +@router.get("/search/{subscribe_id}", summary="搜索订阅", response_model=schemas.Response) +def search_subscribe( + subscribe_id: int, + background_tasks: BackgroundTasks, + db: Session = Depends(get_db), + _: schemas.TokenPayload = Depends(verify_token)) -> Any: + """ + 根据订阅编号搜索订阅 + """ + background_tasks.add_task(start_subscribe_search, db=db, sid=subscribe_id, state=None) + return schemas.Response(success=True) + + @router.get("/{subscribe_id}", summary="订阅详情", response_model=schemas.Subscribe) def read_subscribe( subscribe_id: int, @@ -243,39 +279,3 @@ async def seerr_subscribe(request: Request, background_tasks: BackgroundTasks, username=user_name) return schemas.Response(success=True) - - -@router.get("/refresh", summary="刷新订阅", response_model=schemas.Response) -def refresh_subscribes( - db: Session = Depends(get_db), - _: schemas.TokenPayload = Depends(verify_token)) -> Any: - """ - 刷新所有订阅 - """ - SubscribeChain(db).refresh() - return schemas.Response(success=True) - - -@router.get("/search/{subscribe_id}", summary="搜索订阅", response_model=schemas.Response) -def search_subscribe( - subscribe_id: int, - background_tasks: BackgroundTasks, - db: Session = Depends(get_db), - _: schemas.TokenPayload = Depends(verify_token)) -> Any: - """ - 搜索所有订阅 - """ - background_tasks.add_task(start_subscribe_search, db=db, sid=subscribe_id, state=None) - return schemas.Response(success=True) - - -@router.get("/search", summary="搜索所有订阅", response_model=schemas.Response) -def search_subscribes( - background_tasks: BackgroundTasks, - db: Session = Depends(get_db), - _: schemas.TokenPayload = Depends(verify_token)) -> Any: - """ - 搜索所有订阅 - """ - background_tasks.add_task(start_subscribe_search, db=db, sid=None, state='R') - return schemas.Response(success=True)