modelcontextprotocol/python-sdk
Watch
1
0
Fork
You've already forked python-sdk
 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

refactor: replace pydantic_core.from_json by json.loads (#1912)

Browse source
This commit is contained in:
Marcelo Trylesinski 2026-01-19 20:04:28 +01:00 • committed by GitHub
commit 3dc8b72041
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 4 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

12
src/mcp/server/streamable_http.py
View file

@ -6,7 +6,6 @@ The transport handles bidirectional communication using HTTP requests and
responses, with streaming support for long-running operations. responses, with streaming support for long-running operations.
""" """
import json
import logging import logging
import re import re
from abc import ABC, abstractmethod from abc import ABC, abstractmethod
@ -17,6 +16,7 @@ from http import HTTPStatus
from typing import Any from typing import Any
import anyio import anyio
import pydantic_core
from anyio.streams.memory import MemoryObjectReceiveStream, MemoryObjectSendStream from anyio.streams.memory import MemoryObjectReceiveStream, MemoryObjectSendStream
from pydantic import ValidationError from pydantic import ValidationError
from sse_starlette import EventSourceResponse from sse_starlette import EventSourceResponse
@ -24,10 +24,7 @@ from starlette.requests import Request
from starlette.responses import Response from starlette.responses import Response
from starlette.types import Receive, Scope, Send from starlette.types import Receive, Scope, Send
from mcp.server.transport_security import ( from mcp.server.transport_security import TransportSecurityMiddleware, TransportSecuritySettings
TransportSecurityMiddleware,
TransportSecuritySettings,
)
from mcp.shared.message import ServerMessageMetadata, SessionMessage from mcp.shared.message import ServerMessageMetadata, SessionMessage
from mcp.shared.version import SUPPORTED_PROTOCOL_VERSIONS from mcp.shared.version import SUPPORTED_PROTOCOL_VERSIONS
from mcp.types import ( from mcp.types import (
@ -453,9 +450,8 @@ class StreamableHTTPServerTransport:
body = await request.body() body = await request.body()
try: try:
# TODO(Marcelo): Replace `json.loads` with `pydantic_core.from_json`. raw_message = pydantic_core.from_json(body)
raw_message = json.loads(body) except ValueError as e:
except json.JSONDecodeError as e:
response = self._create_error_response(f"Parse error: {str(e)}", HTTPStatus.BAD_REQUEST, PARSE_ERROR) response = self._create_error_response(f"Parse error: {str(e)}", HTTPStatus.BAD_REQUEST, PARSE_ERROR)
await response(scope, receive, send) await response(scope, receive, send)
return return