Merge pull request #5829 from maxxrdrgz/mcp-streamable-http

Mcp streamable http

Author: RomneyDa

binary/package-lock.json

@@ -4,6 +4,7 @@ import { Transport } from "@modelcontextprotocol/sdk/shared/transport.js";
 import { SSEClientTransport } from "@modelcontextprotocol/sdk/client/sse.js";
 import { StdioClientTransport } from "@modelcontextprotocol/sdk/client/stdio.js";
 import { WebSocketClientTransport } from "@modelcontextprotocol/sdk/client/websocket.js";
+import { StreamableHTTPClientTransport } from "@modelcontextprotocol/sdk/client/streamableHttp.js";
 
 import {
   MCPConnectionStatus,
@@ -335,6 +336,10 @@ class MCPConnection {
           },
           requestInit: { headers: options.transport.requestOptions?.headers },
         });
+      case "streamable-http":
+        return new StreamableHTTPClientTransport(new URL(options.transport.url), {
+          requestInit: { headers: options.transport.requestOptions?.headers },
+        });
       default:
         throw new Error(
           `Unsupported transport type: ${(options.transport as any).type}`,

core/context/mcp/MCPConnection.ts

@@ -1135,7 +1135,17 @@ export interface SSEOptions {
   requestOptions?: RequestOptions;
 }
 
-export type TransportOptions = StdioOptions | WebSocketOptions | SSEOptions;
+export interface StreamableHTTPOptions {
+  type: "streamable-http";
+  url: string;
+  requestOptions?: RequestOptions;
+}
+
+export type TransportOptions = 
+  | StdioOptions
+  | WebSocketOptions
+  | SSEOptions
+  | StreamableHTTPOptions;
 
 export interface MCPOptions {
   name: string;

core/index.d.ts

@@ -3494,6 +3494,20 @@
                           }
                         },
                         "required": ["type", "url"]
+                      },
+                      {
+                        "type": "object",
+                        "properties": {
+                          "type": {
+                            "type": "string",
+                            "enum": ["streamable-http"]
+                          },
+                          "url": {
+                            "type": "string",
+                            "format": "uri"
+                          }
+                        },
+                        "required": ["type", "url"]
                       }
                     ]
                   }