Polish HttpHeaders.MCP_SESSION_ID

- Use `Mcp-Session-Id` instead of `mcp-session-id` to align with specification although the header name is case-insensitive.
- Use `HttpHeaders.MCP_SESSION_ID` instead of string literals.

Signed-off-by: Yanming Zhou <[email protected]>

Author: quaff

mcp-spring/mcp-spring-webmvc/src/main/java/io/modelcontextprotocol/server/transport/WebMvcStreamableServerTransportProvider.java

@@ -90,7 +90,7 @@ public class WebMvcStreamableServerTransportProvider implements McpStreamableSer
 	private McpStreamableServerSession.Factory sessionFactory;
 
 	/**
-	 * Map of active client sessions, keyed by mcp-session-id.
+	 * Map of active client sessions, keyed by Mcp-Session-Id.
 	 */
 	private final ConcurrentHashMap<String, McpStreamableServerSession> sessions = new ConcurrentHashMap<>();
 
@@ -241,7 +241,7 @@ private ServerResponse handleGet(ServerRequest request) {
 		McpTransportContext transportContext = this.contextExtractor.extract(request, new DefaultMcpTransportContext());
 
 		if (!request.headers().asHttpHeaders().containsKey(HttpHeaders.MCP_SESSION_ID)) {
-			return ServerResponse.badRequest().body("Session ID required in mcp-session-id header");
+			return ServerResponse.badRequest().body("Session ID required in " + HttpHeaders.MCP_SESSION_ID + " header");
 		}
 
 		String sessionId = request.headers().asHttpHeaders().getFirst(HttpHeaders.MCP_SESSION_ID);
@@ -434,7 +434,7 @@ private ServerResponse handleDelete(ServerRequest request) {
 		McpTransportContext transportContext = this.contextExtractor.extract(request, new DefaultMcpTransportContext());
 
 		if (!request.headers().asHttpHeaders().containsKey(HttpHeaders.MCP_SESSION_ID)) {
-			return ServerResponse.badRequest().body("Session ID required in mcp-session-id header");
+			return ServerResponse.badRequest().body("Session ID required in " + HttpHeaders.MCP_SESSION_ID + " header");
 		}
 
 		String sessionId = request.headers().asHttpHeaders().getFirst(HttpHeaders.MCP_SESSION_ID);

mcp/src/main/java/io/modelcontextprotocol/client/transport/HttpClientStreamableHttpTransport.java

@@ -416,8 +416,10 @@ public Mono<Void> sendMessage(McpSchema.JSONRPCMessage sentMessage) {
 					})).onErrorMap(CompletionException.class, t -> t.getCause()).onErrorComplete().subscribe();
 
 			})).flatMap(responseEvent -> {
-				if (transportSession.markInitialized(
-						responseEvent.responseInfo().headers().firstValue("mcp-session-id").orElseGet(() -> null))) {
+				if (transportSession.markInitialized(responseEvent.responseInfo()
+					.headers()
+					.firstValue(HttpHeaders.MCP_SESSION_ID)
+					.orElseGet(() -> null))) {
 					// Once we have a session, we try to open an async stream for
 					// the server to send notifications and requests out-of-band.
 

mcp/src/main/java/io/modelcontextprotocol/server/transport/HttpServletStreamableServerTransportProvider.java

@@ -103,7 +103,7 @@ public class HttpServletStreamableServerTransportProvider extends HttpServlet
 	private McpStreamableServerSession.Factory sessionFactory;
 
 	/**
-	 * Map of active client sessions, keyed by mcp-session-id.
+	 * Map of active client sessions, keyed by Mcp-Session-Id.
 	 */
 	private final ConcurrentHashMap<String, McpStreamableServerSession> sessions = new ConcurrentHashMap<>();
 
@@ -256,7 +256,7 @@ protected void doGet(HttpServletRequest request, HttpServletResponse response)
 		String sessionId = request.getHeader(HttpHeaders.MCP_SESSION_ID);
 
 		if (sessionId == null || sessionId.isBlank()) {
-			badRequestErrors.add("Session ID required in mcp-session-id header");
+			badRequestErrors.add("Session ID required in " + HttpHeaders.MCP_SESSION_ID + " header");
 		}
 
 		if (!badRequestErrors.isEmpty()) {
@@ -438,7 +438,7 @@ protected void doPost(HttpServletRequest request, HttpServletResponse response)
 			String sessionId = request.getHeader(HttpHeaders.MCP_SESSION_ID);
 
 			if (sessionId == null || sessionId.isBlank()) {
-				badRequestErrors.add("Session ID required in mcp-session-id header");
+				badRequestErrors.add("Session ID required in " + HttpHeaders.MCP_SESSION_ID + " header");
 			}
 
 			if (!badRequestErrors.isEmpty()) {
@@ -545,7 +545,7 @@ protected void doDelete(HttpServletRequest request, HttpServletResponse response
 
 		if (request.getHeader(HttpHeaders.MCP_SESSION_ID) == null) {
 			this.responseError(response, HttpServletResponse.SC_BAD_REQUEST,
-					new McpError("Session ID required in mcp-session-id header"));
+					new McpError("Session ID required in " + HttpHeaders.MCP_SESSION_ID + " header"));
 			return;
 		}
 

mcp/src/main/java/io/modelcontextprotocol/spec/HttpHeaders.java

@@ -14,7 +14,7 @@ public interface HttpHeaders {
 	/**
 	 * Identifies individual MCP sessions.
 	 */
-	String MCP_SESSION_ID = "mcp-session-id";
+	String MCP_SESSION_ID = "Mcp-Session-Id";
 
 	/**
 	 * Identifies events within an SSE Stream.