rename StreamableHttpServerTransport to NodeStreamableHttpServerTransport, add server-express, server-hono to pkg.pr.new

KKonstantinov · KKonstantinov · commit 564aed24ede7 · 2025-12-20T13:48:27.000+02:00
diff --git a/.github/workflows/publish.yml b/.github/workflows/publish.yml
@@ -38,4 +38,4 @@ jobs:
               run: pnpm run build:all
 
             - name: Publish preview packages
-              run: pnpm dlx pkg-pr-new publish --packageManager=npm --pnpm './packages/server' './packages/client'
+              run: pnpm dlx pkg-pr-new publish --packageManager=npm --pnpm './packages/server' './packages/client' './packages/server-express' './packages/server-hono'
diff --git a/CLAUDE.md b/CLAUDE.md
@@ -224,7 +224,7 @@ mcpServer.tool('tool-name', { param: z.string() }, async ({ param }, extra) => {
 
 ```typescript
 // Server
-const transport = new StreamableHTTPServerTransport({ sessionIdGenerator: () => randomUUID() });
+const transport = new NodeStreamableHTTPServerTransport({ sessionIdGenerator: () => randomUUID() });
 await server.connect(transport);
 
 // Client
diff --git a/examples/server/README.md b/examples/server/README.md
@@ -71,7 +71,7 @@ When deploying MCP servers in a horizontally scaled environment (multiple server
 
 ### Stateless mode
 
-To enable stateless mode, configure the `StreamableHTTPServerTransport` with:
+To enable stateless mode, configure the `NodeStreamableHTTPServerTransport` with:
 
 ```typescript
 sessionIdGenerator: undefined;
diff --git a/examples/server/src/elicitationFormExample.ts b/examples/server/src/elicitationFormExample.ts
@@ -9,7 +9,7 @@
 
 import { randomUUID } from 'node:crypto';
 
-import { isInitializeRequest, McpServer, StreamableHTTPServerTransport } from '@modelcontextprotocol/server';
+import { isInitializeRequest, McpServer, NodeStreamableHTTPServerTransport } from '@modelcontextprotocol/server';
 import { createMcpExpressApp } from '@modelcontextprotocol/server-express';
 import type { Request, Response } from 'express';
 
@@ -322,7 +322,7 @@ async function main() {
     const app = createMcpExpressApp();
 
     // Map to store transports by session ID
-    const transports: { [sessionId: string]: StreamableHTTPServerTransport } = {};
+    const transports: { [sessionId: string]: NodeStreamableHTTPServerTransport } = {};
 
     // MCP POST endpoint
     const mcpPostHandler = async (req: Request, res: Response) => {
@@ -332,13 +332,13 @@ async function main() {
         }
 
         try {
-            let transport: StreamableHTTPServerTransport;
+            let transport: NodeStreamableHTTPServerTransport;
             if (sessionId && transports[sessionId]) {
                 // Reuse existing transport for this session
                 transport = transports[sessionId];
             } else if (!sessionId && isInitializeRequest(req.body)) {
                 // New initialization request - create new transport
-                transport = new StreamableHTTPServerTransport({
+                transport = new NodeStreamableHTTPServerTransport({
                     sessionIdGenerator: () => randomUUID(),
                     onsessioninitialized: sessionId => {
                         // Store the transport by session ID when session is initialized
diff --git a/examples/server/src/elicitationUrlExample.ts b/examples/server/src/elicitationUrlExample.ts
@@ -16,7 +16,7 @@ import {
     getOAuthProtectedResourceMetadataUrl,
     isInitializeRequest,
     McpServer,
-    StreamableHTTPServerTransport,
+    NodeStreamableHTTPServerTransport,
     UrlElicitationRequiredError
 } from '@modelcontextprotocol/server';
 import { createMcpExpressApp, mcpAuthMetadataRouter, requireBearerAuth } from '@modelcontextprotocol/server-express';
@@ -592,7 +592,7 @@ app.post('/confirm-payment', express.urlencoded(), (req: Request, res: Response)
 });
 
 // Map to store transports by session ID
-const transports: { [sessionId: string]: StreamableHTTPServerTransport } = {};
+const transports: { [sessionId: string]: NodeStreamableHTTPServerTransport } = {};
 
 // Interface for a function that can send an elicitation request
 type ElicitationSender = (params: ElicitRequestURLParams) => Promise<ElicitResult>;
@@ -611,15 +611,15 @@ const mcpPostHandler = async (req: Request, res: Response) => {
     console.debug(`Received MCP POST for session: ${sessionId || 'unknown'}`);
 
     try {
-        let transport: StreamableHTTPServerTransport;
+        let transport: NodeStreamableHTTPServerTransport;
         if (sessionId && transports[sessionId]) {
             // Reuse existing transport
             transport = transports[sessionId];
         } else if (!sessionId && isInitializeRequest(req.body)) {
             const server = getServer();
             // New initialization request
             const eventStore = new InMemoryEventStore();
-            transport = new StreamableHTTPServerTransport({
+            transport = new NodeStreamableHTTPServerTransport({
                 sessionIdGenerator: () => randomUUID(),
                 eventStore, // Enable resumability
                 onsessioninitialized: sessionId => {
diff --git a/examples/server/src/jsonResponseStreamableHttp.ts b/examples/server/src/jsonResponseStreamableHttp.ts
@@ -1,7 +1,7 @@
 import { randomUUID } from 'node:crypto';
 
 import type { CallToolResult } from '@modelcontextprotocol/server';
-import { isInitializeRequest, McpServer, StreamableHTTPServerTransport } from '@modelcontextprotocol/server';
+import { isInitializeRequest, McpServer, NodeStreamableHTTPServerTransport } from '@modelcontextprotocol/server';
 import { createMcpExpressApp } from '@modelcontextprotocol/server-express';
 import type { Request, Response } from 'express';
 import * as z from 'zod/v4';
@@ -97,21 +97,21 @@ const getServer = () => {
 const app = createMcpExpressApp();
 
 // Map to store transports by session ID
-const transports: { [sessionId: string]: StreamableHTTPServerTransport } = {};
+const transports: { [sessionId: string]: NodeStreamableHTTPServerTransport } = {};
 
 app.post('/mcp', async (req: Request, res: Response) => {
     console.log('Received MCP request:', req.body);
     try {
         // Check for existing session ID
         const sessionId = req.headers['mcp-session-id'] as string | undefined;
-        let transport: StreamableHTTPServerTransport;
+        let transport: NodeStreamableHTTPServerTransport;
 
         if (sessionId && transports[sessionId]) {
             // Reuse existing transport
             transport = transports[sessionId];
         } else if (!sessionId && isInitializeRequest(req.body)) {
             // New initialization request - use JSON response mode
-            transport = new StreamableHTTPServerTransport({
+            transport = new NodeStreamableHTTPServerTransport({
                 sessionIdGenerator: () => randomUUID(),
                 enableJsonResponse: true, // Enable JSON response mode
                 onsessioninitialized: sessionId => {
diff --git a/examples/server/src/simpleStatelessStreamableHttp.ts b/examples/server/src/simpleStatelessStreamableHttp.ts
@@ -1,5 +1,5 @@
 import type { CallToolResult, GetPromptResult, ReadResourceResult } from '@modelcontextprotocol/server';
-import { McpServer, StreamableHTTPServerTransport } from '@modelcontextprotocol/server';
+import { McpServer, NodeStreamableHTTPServerTransport } from '@modelcontextprotocol/server';
 import { createMcpExpressApp } from '@modelcontextprotocol/server-express';
 import type { Request, Response } from 'express';
 import * as z from 'zod/v4';
@@ -104,7 +104,7 @@ const app = createMcpExpressApp();
 app.post('/mcp', async (req: Request, res: Response) => {
     const server = getServer();
     try {
-        const transport: StreamableHTTPServerTransport = new StreamableHTTPServerTransport({
+        const transport: NodeStreamableHTTPServerTransport = new NodeStreamableHTTPServerTransport({
             sessionIdGenerator: undefined
         });
         await server.connect(transport);
diff --git a/examples/server/src/simpleStreamableHttp.ts b/examples/server/src/simpleStreamableHttp.ts
@@ -17,7 +17,7 @@ import {
     InMemoryTaskStore,
     isInitializeRequest,
     McpServer,
-    StreamableHTTPServerTransport
+    NodeStreamableHTTPServerTransport
 } from '@modelcontextprotocol/server';
 import { createMcpExpressApp, mcpAuthMetadataRouter, requireBearerAuth } from '@modelcontextprotocol/server-express';
 import type { Request, Response } from 'express';
@@ -588,7 +588,7 @@ if (useOAuth) {
 }
 
 // Map to store transports by session ID
-const transports: { [sessionId: string]: StreamableHTTPServerTransport } = {};
+const transports: { [sessionId: string]: NodeStreamableHTTPServerTransport } = {};
 
 // MCP POST endpoint with optional auth
 const mcpPostHandler = async (req: Request, res: Response) => {
@@ -603,14 +603,14 @@ const mcpPostHandler = async (req: Request, res: Response) => {
         console.log('Authenticated user:', req.auth);
     }
     try {
-        let transport: StreamableHTTPServerTransport;
+        let transport: NodeStreamableHTTPServerTransport;
         if (sessionId && transports[sessionId]) {
             // Reuse existing transport
             transport = transports[sessionId];
         } else if (!sessionId && isInitializeRequest(req.body)) {
             // New initialization request
             const eventStore = new InMemoryEventStore();
-            transport = new StreamableHTTPServerTransport({
+            transport = new NodeStreamableHTTPServerTransport({
                 sessionIdGenerator: () => randomUUID(),
                 eventStore, // Enable resumability
                 onsessioninitialized: sessionId => {
diff --git a/examples/server/src/simpleTaskInteractive.ts b/examples/server/src/simpleTaskInteractive.ts
@@ -42,7 +42,7 @@ import {
     ListToolsRequestSchema,
     RELATED_TASK_META_KEY,
     Server,
-    StreamableHTTPServerTransport
+    NodeStreamableHTTPServerTransport
 } from '@modelcontextprotocol/server';
 import { createMcpExpressApp } from '@modelcontextprotocol/server-express';
 import type { Request, Response } from 'express';
@@ -642,7 +642,7 @@ const createServer = (): Server => {
 const app = createMcpExpressApp();
 
 // Map to store transports by session ID
-const transports: { [sessionId: string]: StreamableHTTPServerTransport } = {};
+const transports: { [sessionId: string]: NodeStreamableHTTPServerTransport } = {};
 
 // Helper to check if request is initialize
 const isInitializeRequest = (body: unknown): boolean => {
@@ -654,12 +654,12 @@ app.post('/mcp', async (req: Request, res: Response) => {
     const sessionId = req.headers['mcp-session-id'] as string | undefined;
 
     try {
-        let transport: StreamableHTTPServerTransport;
+        let transport: NodeStreamableHTTPServerTransport;
 
         if (sessionId && transports[sessionId]) {
             transport = transports[sessionId];
         } else if (!sessionId && isInitializeRequest(req.body)) {
-            transport = new StreamableHTTPServerTransport({
+            transport = new NodeStreamableHTTPServerTransport({
                 sessionIdGenerator: () => randomUUID(),
                 onsessioninitialized: sid => {
                     console.log(`Session initialized: ${sid}`);
diff --git a/examples/server/src/sseAndStreamableHttpCompatibleServer.ts b/examples/server/src/sseAndStreamableHttpCompatibleServer.ts
@@ -1,7 +1,7 @@
 import { randomUUID } from 'node:crypto';
 
 import type { CallToolResult } from '@modelcontextprotocol/server';
-import { isInitializeRequest, McpServer, SSEServerTransport, StreamableHTTPServerTransport } from '@modelcontextprotocol/server';
+import { isInitializeRequest, McpServer, SSEServerTransport, NodeStreamableHTTPServerTransport } from '@modelcontextprotocol/server';
 import { createMcpExpressApp } from '@modelcontextprotocol/server-express';
 import type { Request, Response } from 'express';
 import * as z from 'zod/v4';
@@ -76,7 +76,7 @@ const getServer = () => {
 const app = createMcpExpressApp();
 
 // Store transports by session ID
-const transports: Record<string, StreamableHTTPServerTransport | SSEServerTransport> = {};
+const transports: Record<string, NodeStreamableHTTPServerTransport | SSEServerTransport> = {};
 
 //=============================================================================
 // STREAMABLE HTTP TRANSPORT (PROTOCOL VERSION 2025-11-25)
@@ -89,16 +89,16 @@ app.all('/mcp', async (req: Request, res: Response) => {
     try {
         // Check for existing session ID
         const sessionId = req.headers['mcp-session-id'] as string | undefined;
-        let transport: StreamableHTTPServerTransport;
+        let transport: NodeStreamableHTTPServerTransport;
 
         if (sessionId && transports[sessionId]) {
             // Check if the transport is of the correct type
             const existingTransport = transports[sessionId];
-            if (existingTransport instanceof StreamableHTTPServerTransport) {
+            if (existingTransport instanceof NodeStreamableHTTPServerTransport) {
                 // Reuse existing transport
                 transport = existingTransport;
             } else {
-                // Transport exists but is not a StreamableHTTPServerTransport (could be SSEServerTransport)
+                // Transport exists but is not a NodeStreamableHTTPServerTransport (could be SSEServerTransport)
                 res.status(400).json({
                     jsonrpc: '2.0',
                     error: {
@@ -111,7 +111,7 @@ app.all('/mcp', async (req: Request, res: Response) => {
             }
         } else if (!sessionId && req.method === 'POST' && isInitializeRequest(req.body)) {
             const eventStore = new InMemoryEventStore();
-            transport = new StreamableHTTPServerTransport({
+            transport = new NodeStreamableHTTPServerTransport({
                 sessionIdGenerator: () => randomUUID(),
                 eventStore, // Enable resumability
                 onsessioninitialized: sessionId => {
@@ -186,7 +186,7 @@ app.post('/messages', async (req: Request, res: Response) => {
         // Reuse existing transport
         transport = existingTransport;
     } else {
-        // Transport exists but is not a SSEServerTransport (could be StreamableHTTPServerTransport)
+        // Transport exists but is not a SSEServerTransport (could be NodeStreamableHTTPServerTransport)
         res.status(400).json({
             jsonrpc: '2.0',
             error: {
diff --git a/examples/server/src/ssePollingExample.ts b/examples/server/src/ssePollingExample.ts
@@ -15,7 +15,7 @@
 import { randomUUID } from 'node:crypto';
 
 import type { CallToolResult } from '@modelcontextprotocol/server';
-import { McpServer, StreamableHTTPServerTransport } from '@modelcontextprotocol/server';
+import { McpServer, NodeStreamableHTTPServerTransport } from '@modelcontextprotocol/server';
 import { createMcpExpressApp } from '@modelcontextprotocol/server-express';
 import cors from 'cors';
 import type { Request, Response } from 'express';
@@ -112,7 +112,7 @@ app.use(cors());
 const eventStore = new InMemoryEventStore();
 
 // Track transports by session ID for session reuse
-const transports = new Map<string, StreamableHTTPServerTransport>();
+const transports = new Map<string, NodeStreamableHTTPServerTransport>();
 
 // Handle all MCP requests
 app.all('/mcp', async (req: Request, res: Response) => {
@@ -122,7 +122,7 @@ app.all('/mcp', async (req: Request, res: Response) => {
     let transport = sessionId ? transports.get(sessionId) : undefined;
 
     if (!transport) {
-        transport = new StreamableHTTPServerTransport({
+        transport = new NodeStreamableHTTPServerTransport({
             sessionIdGenerator: () => randomUUID(),
             eventStore,
             retryInterval: 2000, // Default retry interval for priming events
diff --git a/examples/server/src/standaloneSseWithGetStreamableHttp.ts b/examples/server/src/standaloneSseWithGetStreamableHttp.ts
@@ -1,7 +1,7 @@
 import { randomUUID } from 'node:crypto';
 
 import type { ReadResourceResult } from '@modelcontextprotocol/server';
-import { isInitializeRequest, McpServer, StreamableHTTPServerTransport } from '@modelcontextprotocol/server';
+import { isInitializeRequest, McpServer, NodeStreamableHTTPServerTransport } from '@modelcontextprotocol/server';
 import { createMcpExpressApp } from '@modelcontextprotocol/server-express';
 import type { Request, Response } from 'express';
 
@@ -12,7 +12,7 @@ const server = new McpServer({
 });
 
 // Store transports by session ID to send notifications
-const transports: { [sessionId: string]: StreamableHTTPServerTransport } = {};
+const transports: { [sessionId: string]: NodeStreamableHTTPServerTransport } = {};
 
 const addResource = (name: string, content: string) => {
     const uri = `https://mcp-example.com/dynamic/${encodeURIComponent(name)}`;
@@ -42,14 +42,14 @@ app.post('/mcp', async (req: Request, res: Response) => {
     try {
         // Check for existing session ID
         const sessionId = req.headers['mcp-session-id'] as string | undefined;
-        let transport: StreamableHTTPServerTransport;
+        let transport: NodeStreamableHTTPServerTransport;
 
         if (sessionId && transports[sessionId]) {
             // Reuse existing transport
             transport = transports[sessionId];
         } else if (!sessionId && isInitializeRequest(req.body)) {
             // New initialization request
-            transport = new StreamableHTTPServerTransport({
+            transport = new NodeStreamableHTTPServerTransport({
                 sessionIdGenerator: () => randomUUID(),
                 onsessioninitialized: sessionId => {
                     // Store the transport by session ID when session is initialized
diff --git a/packages/core/src/shared/protocol.ts b/packages/core/src/shared/protocol.ts
@@ -292,14 +292,14 @@ export type RequestHandlerExtra<SendRequestT extends Request, SendNotificationT
 
     /**
      * Closes the SSE stream for this request, triggering client reconnection.
-     * Only available when using StreamableHTTPServerTransport with eventStore configured.
+     * Only available when using NodeStreamableHTTPServerTransport with eventStore configured.
      * Use this to implement polling behavior during long-running operations.
      */
     closeSSEStream?: () => void;
 
     /**
      * Closes the standalone GET SSE stream, triggering client reconnection.
-     * Only available when using StreamableHTTPServerTransport with eventStore configured.
+     * Only available when using NodeStreamableHTTPServerTransport with eventStore configured.
      * Use this to implement polling behavior for server-initiated notifications.
      */
     closeStandaloneSSEStream?: () => void;
diff --git a/packages/core/src/types/types.ts b/packages/core/src/types/types.ts
@@ -2415,13 +2415,13 @@ export interface MessageExtraInfo {
 
     /**
      * Callback to close the SSE stream for this request, triggering client reconnection.
-     * Only available when using StreamableHTTPServerTransport with eventStore configured.
+     * Only available when using NodeStreamableHTTPServerTransport with eventStore configured.
      */
     closeSSEStream?: () => void;
 
     /**
      * Callback to close the standalone GET SSE stream, triggering client reconnection.
-     * Only available when using StreamableHTTPServerTransport with eventStore configured.
+     * Only available when using NodeStreamableHTTPServerTransport with eventStore configured.
      */
     closeStandaloneSSEStream?: () => void;
 }
diff --git a/packages/server-express/README.md b/packages/server-express/README.md
@@ -32,13 +32,13 @@ const app = createMcpExpressApp(); // default host is 127.0.0.1; protection enab
 ### Streamable HTTP endpoint (Express)
 
 ```ts
-import { McpServer, StreamableHTTPServerTransport } from '@modelcontextprotocol/server';
+import { McpServer, NodeStreamableHTTPServerTransport } from '@modelcontextprotocol/server';
 import { createMcpExpressApp } from '@modelcontextprotocol/server-express';
 
 const app = createMcpExpressApp();
 
 app.post('/mcp', async (req, res) => {
-    const transport = new StreamableHTTPServerTransport();
+    const transport = new NodeStreamableHTTPServerTransport();
     await transport.handleRequest(req, res, req.body);
 });
 ```
diff --git a/packages/server-express/package.json b/packages/server-express/package.json
@@ -1,5 +1,6 @@
 {
     "name": "@modelcontextprotocol/server-express",
+    "private": false,
     "version": "2.0.0-alpha.0",
     "description": "Express adapters for the Model Context Protocol TypeScript server SDK",
     "license": "MIT",
diff --git a/packages/server-hono/package.json b/packages/server-hono/package.json
@@ -1,5 +1,6 @@
 {
     "name": "@modelcontextprotocol/server-hono",
+    "private": false,
     "version": "2.0.0-alpha.0",
     "description": "Hono adapters for the Model Context Protocol TypeScript server SDK",
     "license": "MIT",
diff --git a/packages/server/src/server/sse.ts b/packages/server/src/server/sse.ts
diff --git a/packages/server/src/server/streamableHttp.ts b/packages/server/src/server/streamableHttp.ts
diff --git a/packages/server/src/server/webStandardStreamableHttp.ts b/packages/server/src/server/webStandardStreamableHttp.ts
diff --git a/packages/server/test/server/streamableHttp.test.ts b/packages/server/test/server/streamableHttp.test.ts
diff --git a/test/integration/test/stateManagementStreamableHttp.test.ts b/test/integration/test/stateManagementStreamableHttp.test.ts
diff --git a/test/integration/test/taskLifecycle.test.ts b/test/integration/test/taskLifecycle.test.ts
diff --git a/test/integration/test/taskResumability.test.ts b/test/integration/test/taskResumability.test.ts
