wangbo/ComfyUI
1
0
Fork 0
mirror of https://github.com/comfyanonymous/ComfyUI.git synced 2026-01-31 00:30:21 +08:00
Code Issues Actions 19 Packages Projects Releases Wiki Activity

Made some routes returmn 501's while functionality is worked on
Some checks failed
Python Linting / Run Ruff (push) Waiting to run
Details
Python Linting / Run Pylint (push) Waiting to run
Details
Build package / Build Test (3.10) (push) Has been cancelled
Details
Build package / Build Test (3.11) (push) Has been cancelled
Details
Build package / Build Test (3.12) (push) Has been cancelled
Details
Build package / Build Test (3.13) (push) Has been cancelled
Details
Build package / Build Test (3.14) (push) Has been cancelled
Details

Browse Source
This commit is contained in:
Jedrzej Kosinski 2026-01-26 21:02:05 -08:00
parent 4866bbfd8c
commit b16390c2fd
1 changed files with 21 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

39
app/assets/api/routes.py
View File

@ -8,7 +8,7 @@ from aiohttp import web
from pydantic import ValidationError from pydantic import ValidationError
import app.assets.manager as manager import app.assets.manager as manager
# import app.assets.scanner as scanner import app.assets.scanner as scanner
from app import user_manager from app import user_manager
from app.assets.api import schemas_in from app.assets.api import schemas_in
from app.assets.helpers import get_query_dict from app.assets.helpers import get_query_dict
@ -96,6 +96,7 @@ async def get_asset(request: web.Request) -> web.Response:
@ROUTES.get(f"/api/assets/{{id:{UUID_RE}}}/content") @ROUTES.get(f"/api/assets/{{id:{UUID_RE}}}/content")
async def download_asset_content(request: web.Request) -> web.Response: async def download_asset_content(request: web.Request) -> web.Response:
return _error_response(501, "NOT_IMPLEMENTED", "Downloading asset content is not implemented yet.")
# question: do we need disposition? could we just stick with one of these? # question: do we need disposition? could we just stick with one of these?
disposition = request.query.get("disposition", "attachment").lower().strip() disposition = request.query.get("disposition", "attachment").lower().strip()
if disposition not in {"inline", "attachment"}: if disposition not in {"inline", "attachment"}:
@ -124,6 +125,7 @@ async def download_asset_content(request: web.Request) -> web.Response:
@ROUTES.post("/api/assets/from-hash") @ROUTES.post("/api/assets/from-hash")
async def create_asset_from_hash(request: web.Request) -> web.Response: async def create_asset_from_hash(request: web.Request) -> web.Response:
return _error_response(501, "NOT_IMPLEMENTED", "Creating assets from hash is not implemented yet.")
try: try:
payload = await request.json() payload = await request.json()
body = schemas_in.CreateFromHashBody.model_validate(payload) body = schemas_in.CreateFromHashBody.model_validate(payload)
@ -387,6 +389,7 @@ async def set_asset_preview(request: web.Request) -> web.Response:
@ROUTES.delete(f"/api/assets/{{id:{UUID_RE}}}") @ROUTES.delete(f"/api/assets/{{id:{UUID_RE}}}")
async def delete_asset(request: web.Request) -> web.Response: async def delete_asset(request: web.Request) -> web.Response:
return _error_response(501, "NOT_IMPLEMENTED", "Deleting assets is not implemented yet.")
asset_info_id = str(uuid.UUID(request.match_info["id"])) asset_info_id = str(uuid.UUID(request.match_info["id"]))
delete_content = request.query.get("delete_content") delete_content = request.query.get("delete_content")
delete_content = True if delete_content is None else delete_content.lower() not in {"0", "false", "no"} delete_content = True if delete_content is None else delete_content.lower() not in {"0", "false", "no"}
@ -496,22 +499,22 @@ async def delete_asset_tags(request: web.Request) -> web.Response:
return web.json_response(result.model_dump(mode="json"), status=200) return web.json_response(result.model_dump(mode="json"), status=200)
# NOTE: this exists in case we decide to enable asset scan to be triggered separately from calling /object_info @ROUTES.post("/api/assets/scan/seed")
# @ROUTES.post("/api/assets/scan/seed") async def seed_assets(request: web.Request) -> web.Response:
# async def seed_assets(request: web.Request) -> web.Response: return _error_response(501, "NOT_IMPLEMENTED", "Seeding assets is not implemented yet.")
# try: try:
# payload = await request.json() payload = await request.json()
# except Exception: except Exception:
# payload = {} payload = {}
# try: try:
# body = schemas_in.ScheduleAssetScanBody.model_validate(payload) body = schemas_in.ScheduleAssetScanBody.model_validate(payload)
# except ValidationError as ve: except ValidationError as ve:
# return _validation_error_response("INVALID_BODY", ve) return _validation_error_response("INVALID_BODY", ve)
# try: try:
# scanner.seed_assets(body.roots) scanner.seed_assets(body.roots)
# except Exception: except Exception:
# logging.exception("seed_assets failed for roots=%s", body.roots) logging.exception("seed_assets failed for roots=%s", body.roots)
# return _error_response(500, "INTERNAL", "Unexpected server error.") return _error_response(500, "INTERNAL", "Unexpected server error.")
# return web.json_response({"synced": True, "roots": body.roots}, status=200) return web.json_response({"synced": True, "roots": body.roots}, status=200)