remove SilentResponse

Author: 文徐

examples/servers/simple-prompt/mcp_simple_prompt/server.py

@@ -77,17 +77,17 @@ async def get_prompt(name: str, arguments: dict[str, str] | None = None) -> type
         )
 
     if transport == "sse":
-        from mcp.server.fastmcp.server import SilentResponse
         from mcp.server.sse import SseServerTransport
         from starlette.applications import Starlette
+        from starlette.responses import Response
         from starlette.routing import Mount, Route
 
         sse = SseServerTransport("/messages/")
 
         async def handle_sse(request: Request):
             async with sse.connect_sse(request.scope, request.receive, request._send) as streams:  # type: ignore[reportPrivateUsage]
                 await app.run(streams[0], streams[1], app.create_initialization_options())
-            return SilentResponse()
+            return Response()
 
         starlette_app = Starlette(
             debug=True,

examples/servers/simple-resource/mcp_simple_resource/server.py

@@ -57,17 +57,17 @@ async def read_resource(uri: AnyUrl) -> str | bytes:
         return SAMPLE_RESOURCES[name]["content"]
 
     if transport == "sse":
-        from mcp.server.fastmcp.server import SilentResponse
         from mcp.server.sse import SseServerTransport
         from starlette.applications import Starlette
+        from starlette.responses import Response
         from starlette.routing import Mount, Route
 
         sse = SseServerTransport("/messages/")
 
         async def handle_sse(request: Request):
             async with sse.connect_sse(request.scope, request.receive, request._send) as streams:  # type: ignore[reportPrivateUsage]
                 await app.run(streams[0], streams[1], app.create_initialization_options())
-            return SilentResponse()
+            return Response()
 
         starlette_app = Starlette(
             debug=True,

examples/servers/simple-tool/mcp_simple_tool/server.py

@@ -58,17 +58,17 @@ async def list_tools() -> list[types.Tool]:
         ]
 
     if transport == "sse":
-        from mcp.server.fastmcp.server import SilentResponse
         from mcp.server.sse import SseServerTransport
         from starlette.applications import Starlette
+        from starlette.responses import Response
         from starlette.routing import Mount, Route
 
         sse = SseServerTransport("/messages/")
 
         async def handle_sse(request: Request):
             async with sse.connect_sse(request.scope, request.receive, request._send) as streams:  # type: ignore[reportPrivateUsage]
                 await app.run(streams[0], streams[1], app.create_initialization_options())
-            return SilentResponse()
+            return Response()
 
         starlette_app = Starlette(
             debug=True,

src/mcp/server/sse.py

@@ -23,7 +23,7 @@ async def handle_sse(request):
                 streams[0], streams[1], app.create_initialization_options()
             )
         # Return empty response to avoid NoneType error
-        return SilentResponse()
+        return Response()
 
     # Create and run Starlette app
     starlette_app = Starlette(routes=routes)

tests/server/test_sse_security.py

@@ -10,10 +10,10 @@
 import uvicorn
 from starlette.applications import Starlette
 from starlette.requests import Request
+from starlette.responses import Response
 from starlette.routing import Mount, Route
 
 from mcp.server import Server
-from mcp.server.fastmcp.server import SilentResponse
 from mcp.server.sse import SseServerTransport
 from mcp.server.transport_security import TransportSecuritySettings
 from mcp.types import Tool
@@ -55,7 +55,7 @@ async def handle_sse(request: Request):
         except ValueError as e:
             # Validation error was already handled inside connect_sse
             logger.debug(f"SSE connection failed validation: {e}")
-        return SilentResponse()
+        return Response()
 
     routes = [
         Route("/sse", endpoint=handle_sse),

tests/shared/test_sse.py

@@ -20,7 +20,6 @@
 from mcp.client.session import ClientSession
 from mcp.client.sse import sse_client
 from mcp.server import Server
-from mcp.server.fastmcp.server import SilentResponse
 from mcp.server.sse import SseServerTransport
 from mcp.server.transport_security import TransportSecuritySettings
 from mcp.shared.exceptions import McpError
@@ -93,7 +92,7 @@ def make_server_app() -> Starlette:
     async def handle_sse(request: Request) -> Response:
         async with sse.connect_sse(request.scope, request.receive, request._send) as streams:
             await server.run(streams[0], streams[1], server.create_initialization_options())
-        return SilentResponse()
+        return Response()
 
     app = Starlette(
         routes=[
@@ -356,7 +355,7 @@ def run_context_server(server_port: int) -> None:
     async def handle_sse(request: Request) -> Response:
         async with sse.connect_sse(request.scope, request.receive, request._send) as streams:
             await context_server.run(streams[0], streams[1], context_server.create_initialization_options())
-        return SilentResponse()
+        return Response()
 
     app = Starlette(
         routes=[