From 84e4575717b6786fcdd4d988ad6318ab3aa85238 Mon Sep 17 00:00:00 2001 From: iHeyTang Date: Tue, 19 Aug 2025 10:18:42 +0800 Subject: [PATCH] =?UTF-8?q?refactor:=20=E7=A7=BB=E9=99=A4=E4=B8=8D?= =?UTF-8?q?=E5=86=8D=E7=BB=B4=E6=8A=A4=E7=9A=84=E6=9C=8D=E5=8A=A1=E5=99=A8?= =?UTF-8?q?=E6=96=87=E4=BB=B6=E5=88=97=E8=A1=A8=E6=8E=A5=E5=8F=A3=EF=BC=8C?= =?UTF-8?q?=E7=AE=80=E5=8C=96=E4=BB=A3=E7=A0=81=E7=BB=93=E6=9E=84=EF=BC=8C?= =?UTF-8?q?=E6=8F=90=E5=8D=87=E5=8F=AF=E8=AF=BB=E6=80=A7?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- workflow_service/routes/service.py | 54 ------------------------------ 1 file changed, 54 deletions(-) diff --git a/workflow_service/routes/service.py b/workflow_service/routes/service.py index 5ac8fd8..cf1b9e6 100644 --- a/workflow_service/routes/service.py +++ b/workflow_service/routes/service.py @@ -1,5 +1,4 @@ import asyncio -import os from datetime import datetime from typing import List @@ -95,56 +94,3 @@ async def get_servers_status(): ) ) return response_list - - -@service_router.get("/servers/{server_index}/files", response_model=ServerFiles) -async def list_server_files( - server_index: int = Path(..., ge=0, description="服务器在配置列表中的索引") -): - """ - 获取指定ComfyUI服务器的输入和输出文件夹中的文件列表。 - 注意:由于节点管理不再维护目录,此接口返回空列表。 - """ - servers = await server_manager.get_all_servers() - if server_index >= len(servers): - raise HTTPException( - status_code=404, - detail=f"服务器索引 {server_index} 超出范围。有效索引为 0 到 {len(servers) - 1}。", - ) - - server_config = servers[server_index] - - # 由于节点管理不再维护目录,返回空列表 - input_files, output_files = [], [] - - return ServerFiles( - server_index=server_index, - http_url=server_config.http_url, - input_files=input_files, - output_files=output_files, - ) - - -async def _get_folder_contents(path: str) -> List[FileDetails]: - """异步地列出并返回文件夹内容的详细信息。""" - if not os.path.isdir(path): - return [] - - def sync_list_files(dir_path): - files = [] - try: - for entry in os.scandir(dir_path): - if entry.is_file(): - stat = entry.stat() - files.append( - FileDetails( - name=entry.name, - size_kb=round(stat.st_size / 1024, 2), - modified_at=datetime.fromtimestamp(stat.st_mtime), - ) - ) - except OSError as e: - print(f"无法扫描目录 {dir_path}: {e}") - return sorted(files, key=lambda x: x.modified_at, reverse=True) - - return await asyncio.to_thread(sync_list_files, path)