fix: restore missing MCP transport functions in tool_configuration_service

- Restore SSETransport and StreamableHttpTransport imports
- Restore get_mcp_authorization_token_by_name_and_url import
- Restore _create_mcp_transport function

Author: 葛锐

backend/services/tool_configuration_service.py

@@ -7,13 +7,18 @@
 
 from pydantic_core import PydanticUndefined
 from fastmcp import Client
+from fastmcp.client.transports import StreamableHttpTransport, SSETransport
 import jsonref
 from mcpadapt.smolagents_adapter import _sanitize_function_name
 
 from consts.const import LOCAL_MCP_SERVER, DATA_PROCESS_SERVICE
 from consts.exceptions import MCPConnectionError, ToolExecutionException, NotFoundException
 from consts.model import ToolInstanceInfoRequest, ToolInfo, ToolSourceEnum, ToolValidateRequest
-from database.remote_mcp_db import get_mcp_records_by_tenant, get_mcp_server_by_name_and_tenant
+from database.remote_mcp_db import (
+    get_mcp_records_by_tenant,
+    get_mcp_server_by_name_and_tenant,
+    get_mcp_authorization_token_by_name_and_url,
+)
 from database.tool_db import (
     create_or_update_tool_by_tool_info,
     query_all_tools,
@@ -31,6 +36,29 @@
 logger = logging.getLogger("tool_configuration_service")
 
 
+def _create_mcp_transport(url: str, authorization_token: Optional[str] = None):
+    """
+    Create appropriate MCP transport based on URL ending.
+
+    Args:
+        url: MCP server URL
+        authorization_token: Optional authorization token
+
+    Returns:
+        Transport instance (SSETransport or StreamableHttpTransport)
+    """
+    url_stripped = url.strip()
+    headers = {"Authorization": authorization_token} if authorization_token else {}
+
+    if url_stripped.endswith("/sse"):
+        return SSETransport(url=url_stripped, headers=headers)
+    elif url_stripped.endswith("/mcp"):
+        return StreamableHttpTransport(url=url_stripped, headers=headers)
+    else:
+        # Default to StreamableHttpTransport for unrecognized formats
+        return StreamableHttpTransport(url=url_stripped, headers=headers)
+
+
 def python_type_to_json_schema(annotation: Any) -> str:
     """
     Convert Python type annotations to JSON Schema types