From d806931296cbd7c4a388775358102ba3beb1772b Mon Sep 17 00:00:00 2001 From: jxxghp Date: Mon, 9 Sep 2024 08:33:07 +0800 Subject: [PATCH] =?UTF-8?q?downloading=20api=20=E6=94=AF=E6=8C=81=E5=A4=9A?= =?UTF-8?q?=E4=B8=8B=E8=BD=BD=E5=99=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/api/endpoints/download.py | 5 +++-- app/chain/download.py | 4 ++-- 2 files changed, 5 insertions(+), 4 deletions(-) diff --git a/app/api/endpoints/download.py b/app/api/endpoints/download.py index 55354db0..655b69bc 100644 --- a/app/api/endpoints/download.py +++ b/app/api/endpoints/download.py @@ -15,12 +15,13 @@ router = APIRouter() @router.get("/", summary="正在下载", response_model=List[schemas.DownloadingTorrent]) -def read( +def list( + name: str = None, _: schemas.TokenPayload = Depends(verify_token)) -> Any: """ 查询正在下载的任务 """ - return DownloadChain().downloading() + return DownloadChain().downloading(name) @router.post("/", summary="添加下载（含媒体信息）", response_model=schemas.Response) diff --git a/app/chain/download.py b/app/chain/download.py index 6221b6fa..20049d1e 100644 --- a/app/chain/download.py +++ b/app/chain/download.py @@ -886,11 +886,11 @@ class DownloadChain(ChainBase): link=settings.MP_DOMAIN('#/downloading') )) - def downloading(self) -> List[DownloadingTorrent]: + def downloading(self, name: str = None) -> List[DownloadingTorrent]: """ 查询正在下载的任务 """ - torrents = self.list_torrents(status=TorrentStatus.DOWNLOADING) + torrents = self.list_torrents(downloader=name, status=TorrentStatus.DOWNLOADING) if not torrents: return [] ret_torrents = []