chore: remove unused change

fix: Add JSON RPC request type guard
2025-12-27 17:47:24 +00:00 · 2025-12-26 18:08:24 +08:00 · 2025-12-26 18:01:42 +08:00
1 changed files with 13 additions and 10 deletions
--- a/api/core/mcp/client/streamable_client.py
+++ b/api/core/mcp/client/streamable_client.py
@@ -313,17 +313,20 @@ class StreamableHTTPTransport:
            if is_initialization:
                self._maybe_extract_session_id_from_response(response)

-            content_type = cast(str, response.headers.get(CONTENT_TYPE, "").lower())
+            # Per https://modelcontextprotocol.io/specification/2025-06-18/basic#notifications:
+            # The server MUST NOT send a response to notifications.
+            if isinstance(message.root, JSONRPCRequest):
+                content_type = cast(str, response.headers.get(CONTENT_TYPE, "").lower())

-            if content_type.startswith(JSON):
-                self._handle_json_response(response, ctx.server_to_client_queue)
-            elif content_type.startswith(SSE):
-                self._handle_sse_response(response, ctx)
-            else:
-                self._handle_unexpected_content_type(
-                    content_type,
-                    ctx.server_to_client_queue,
-                )
+                if content_type.startswith(JSON):
+                    self._handle_json_response(response, ctx.server_to_client_queue)
+                elif content_type.startswith(SSE):
+                    self._handle_sse_response(response, ctx)
+                else:
+                    self._handle_unexpected_content_type(
+                        content_type,
+                        ctx.server_to_client_queue,
+                    )

    def _handle_json_response(
        self,
Author	SHA1	Message	Date
Novice	9a0cc7b4b1	chore: remove unused change	2025-12-26 18:08:24 +08:00
Novice	ac97129e3f	fix: Add JSON RPC request type guard	2025-12-26 18:01:42 +08:00