We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent db61e00 commit b2bc997Copy full SHA for b2bc997
1 file changed
src/google/adk/tools/mcp_tool/mcp_tool.py
@@ -58,6 +58,7 @@
58
from .mcp_session_manager import MCPSessionManager
59
from .mcp_session_manager import retry_on_errors
60
from .session_context import SessionContext
61
+from ._internal import sanitize_header_value
62
from .types import HeaderProvider
63
64
logger = logging.getLogger("google_adk." + __name__)
@@ -396,6 +397,11 @@ async def _run_async_impl(
396
397
headers.update(auth_headers)
398
if dynamic_headers:
399
headers.update(dynamic_headers)
400
+
401
+ # Sanitize all header values to prevent injection attacks.
402
+ if headers:
403
+ headers = {k: sanitize_header_value(v) for k, v in headers.items()}
404
405
final_headers = headers if headers else None
406
407
# Propagate trace context in the _meta field as sprcified by MCP protocol.
0 commit comments