add 立即执行下载器文件整理 API
This commit is contained in:
@ -6,7 +6,7 @@ from sqlalchemy.orm import Session
|
|||||||
|
|
||||||
from app import schemas
|
from app import schemas
|
||||||
from app.chain.transfer import TransferChain
|
from app.chain.transfer import TransferChain
|
||||||
from app.core.security import verify_token
|
from app.core.security import verify_token, verify_uri_token
|
||||||
from app.db import get_db
|
from app.db import get_db
|
||||||
from app.db.models.transferhistory import TransferHistory
|
from app.db.models.transferhistory import TransferHistory
|
||||||
from app.schemas import MediaType
|
from app.schemas import MediaType
|
||||||
@ -105,3 +105,12 @@ def manual_transfer(path: str = None,
|
|||||||
return schemas.Response(success=False, message=errormsg)
|
return schemas.Response(success=False, message=errormsg)
|
||||||
# 成功
|
# 成功
|
||||||
return schemas.Response(success=True)
|
return schemas.Response(success=True)
|
||||||
|
|
||||||
|
|
||||||
|
@router.get("/now", summary="立即执行下载器文件整理", response_model=schemas.Response)
|
||||||
|
def now(_: str = Depends(verify_uri_token)) -> Any:
|
||||||
|
"""
|
||||||
|
立即执行下载器文件整理 API_TOKEN认证(?token=xxx)
|
||||||
|
"""
|
||||||
|
TransferChain().process()
|
||||||
|
return schemas.Response(success=True)
|
||||||
|
Reference in New Issue
Block a user