Function _prepare_and_validate_request

api_utils/request_processor.py:160–214

Prepare and validate request, return (combined prompt, attachment path list, tool_exec_results).

(
    req_id: str,
    request: ChatCompletionRequest,
    check_client_disconnected: Callable,
    fc_state: Optional[FunctionCallingState] = None,
)

async def _prepare_and_validate_request(
    req_id: str,
    request: ChatCompletionRequest,
    check_client_disconnected: Callable,
    fc_state: Optional[FunctionCallingState] = None,
) -> Tuple[str, List[str], Optional[List[Dict[str, Any]]]]:
    """Prepare and validate request, return (combined prompt, attachment path list, tool_exec_results)."""
    try:
        validate_chat_request(request.messages, req_id)
    except ValueError as e:
        raise bad_request(req_id, f"Invalid request: {e}")

    prepared_prompt, attachments_list = prepare_combined_prompt(
        request.messages,
        req_id,
        getattr(request, "tools", None),
        getattr(request, "tool_choice", None),
        fc_state=fc_state,
    )
    # Active function execution based on tools/tool_choice (supports per-request MCP endpoints)
    try:
        # Inject mcp_endpoint into utils.maybe_execute_tools registration logic
        if hasattr(request, "mcp_endpoint") and request.mcp_endpoint:
            from .tools_registry import register_runtime_tools

            register_runtime_tools(
                getattr(request, "tools", None), request.mcp_endpoint
            )
        tool_exec_results = await maybe_execute_tools(
            request.messages, request.tools, getattr(request, "tool_choice", None)
        )
    except asyncio.CancelledError:
        raise
    except Exception:
        tool_exec_results = None

    check_client_disconnected("After Prompt Prep")
    # Inline results at the end of the prompt for submission together
    if tool_exec_results:
        try:
            for res in tool_exec_results:
                name = res.get("name")
                args = res.get("arguments")
                result_str = res.get("result")
                prepared_prompt += f"\n---\nTool Execution: {name}\nArguments:\n{args}\nResult:\n{result_str}\n"
        except Exception:
            pass

    # Process and validate attachments
    # Acceptance criteria: Only accept data:/file:/absolute paths provided by current request
    final_attachments = collect_and_validate_attachments(
        request, req_id, attachments_list
    )

    return prepared_prompt, final_attachments, tool_exec_results


async def _handle_response_processing(