From c20d112f6010923b938bb158e0c825cb4c8a448c Mon Sep 17 00:00:00 2001 From: Jin Hai Date: Thu, 25 Dec 2025 16:59:05 +0800 Subject: [PATCH] Print log (#12200) ### What problem does this PR solve? Print invalid URL --------- Signed-off-by: Jin Hai --- .github/workflows/tests.yml | 12 ++++++------ api/apps/__init__.py | 15 +++++++++++++-- 2 files changed, 19 insertions(+), 8 deletions(-) diff --git a/.github/workflows/tests.yml b/.github/workflows/tests.yml index 9e4734b84..37c666173 100644 --- a/.github/workflows/tests.yml +++ b/.github/workflows/tests.yml @@ -205,7 +205,7 @@ jobs: - name: Run sdk tests against Elasticsearch run: | export http_proxy=""; export https_proxy=""; export no_proxy=""; export HTTP_PROXY=""; export HTTPS_PROXY=""; export NO_PROXY="" - until sudo docker exec ${RAGFLOW_CONTAINER} curl -s --connect-timeout 5 ${HOST_ADDRESS} > /dev/null; do + until sudo docker exec ${RAGFLOW_CONTAINER} curl -s --connect-timeout 5 ${HOST_ADDRESS}/v1/system/ping > /dev/null; do echo "Waiting for service to be available..." sleep 5 done @@ -214,7 +214,7 @@ jobs: - name: Run frontend api tests against Elasticsearch run: | export http_proxy=""; export https_proxy=""; export no_proxy=""; export HTTP_PROXY=""; export HTTPS_PROXY=""; export NO_PROXY="" - until sudo docker exec ${RAGFLOW_CONTAINER} curl -s --connect-timeout 5 ${HOST_ADDRESS} > /dev/null; do + until sudo docker exec ${RAGFLOW_CONTAINER} curl -s --connect-timeout 5 ${HOST_ADDRESS}/v1/system/ping > /dev/null; do echo "Waiting for service to be available..." sleep 5 done @@ -223,7 +223,7 @@ jobs: - name: Run http api tests against Elasticsearch run: | export http_proxy=""; export https_proxy=""; export no_proxy=""; export HTTP_PROXY=""; export HTTPS_PROXY=""; export NO_PROXY="" - until sudo docker exec ${RAGFLOW_CONTAINER} curl -s --connect-timeout 5 ${HOST_ADDRESS} > /dev/null; do + until sudo docker exec ${RAGFLOW_CONTAINER} curl -s --connect-timeout 5 ${HOST_ADDRESS}/v1/system/ping > /dev/null; do echo "Waiting for service to be available..." sleep 5 done @@ -243,7 +243,7 @@ jobs: - name: Run sdk tests against Infinity run: | export http_proxy=""; export https_proxy=""; export no_proxy=""; export HTTP_PROXY=""; export HTTPS_PROXY=""; export NO_PROXY="" - until sudo docker exec ${RAGFLOW_CONTAINER} curl -s --connect-timeout 5 ${HOST_ADDRESS} > /dev/null; do + until sudo docker exec ${RAGFLOW_CONTAINER} curl -s --connect-timeout 5 ${HOST_ADDRESS}/v1/system/ping > /dev/null; do echo "Waiting for service to be available..." sleep 5 done @@ -252,7 +252,7 @@ jobs: - name: Run frontend api tests against Infinity run: | export http_proxy=""; export https_proxy=""; export no_proxy=""; export HTTP_PROXY=""; export HTTPS_PROXY=""; export NO_PROXY="" - until sudo docker exec ${RAGFLOW_CONTAINER} curl -s --connect-timeout 5 ${HOST_ADDRESS} > /dev/null; do + until sudo docker exec ${RAGFLOW_CONTAINER} curl -s --connect-timeout 5 ${HOST_ADDRESS}/v1/system/ping > /dev/null; do echo "Waiting for service to be available..." sleep 5 done @@ -261,7 +261,7 @@ jobs: - name: Run http api tests against Infinity run: | export http_proxy=""; export https_proxy=""; export no_proxy=""; export HTTP_PROXY=""; export HTTPS_PROXY=""; export NO_PROXY="" - until sudo docker exec ${RAGFLOW_CONTAINER} curl -s --connect-timeout 5 ${HOST_ADDRESS} > /dev/null; do + until sudo docker exec ${RAGFLOW_CONTAINER} curl -s --connect-timeout 5 ${HOST_ADDRESS}/v1/system/ping > /dev/null; do echo "Waiting for service to be available..." sleep 5 done diff --git a/api/apps/__init__.py b/api/apps/__init__.py index 6934e7aed..c329679f8 100644 --- a/api/apps/__init__.py +++ b/api/apps/__init__.py @@ -38,7 +38,6 @@ settings.init_settings() __all__ = ["app"] - app = Quart(__name__) app = cors(app, allow_origin="*") @@ -103,6 +102,7 @@ from werkzeug.local import LocalProxy T = TypeVar("T") P = ParamSpec("P") + def _load_user(): jwt = Serializer(secret_key=settings.SECRET_KEY) authorization = request.headers.get("Authorization") @@ -164,7 +164,7 @@ def login_required(func: Callable[P, Awaitable[T]]) -> Callable[P, Awaitable[T]] @wraps(func) async def wrapper(*args: P.args, **kwargs: P.kwargs) -> T: - if not current_user:# or not session.get("_user_id"): + if not current_user: # or not session.get("_user_id"): raise Unauthorized() else: return await current_app.ensure_async(func)(*args, **kwargs) @@ -228,6 +228,7 @@ def logout_user(): return True + def search_pages_path(page_path): app_path_list = [ path for path in page_path.glob("*_app.py") if not path.name.startswith(".") @@ -274,6 +275,16 @@ client_urls_prefix = [ ] +@app.errorhandler(404) +async def not_found(error): + error_msg: str = f"The requested URL {request.path} was not found" + logging.error(error_msg) + return { + "error": "Not Found", + "message": error_msg, + }, 404 + + @app.teardown_request def _db_close(exception): if exception: