Add context extractor for HTTP headers in WebFlux and WebMvc configurations

Author: mehrdadbozorgmehr

auto-configurations/mcp/spring-ai-autoconfigure-mcp-server-webflux/src/main/java/org/springframework/ai/mcp/server/autoconfigure/McpServerStreamableHttpWebFluxAutoConfiguration.java

@@ -16,7 +16,11 @@
 
 package org.springframework.ai.mcp.server.autoconfigure;
 
+import java.util.HashMap;
+import java.util.Map;
+
 import com.fasterxml.jackson.databind.ObjectMapper;
+import io.modelcontextprotocol.common.McpTransportContext;
 import io.modelcontextprotocol.json.jackson.JacksonMcpJsonMapper;
 import io.modelcontextprotocol.server.transport.WebFluxStreamableServerTransportProvider;
 import io.modelcontextprotocol.spec.McpSchema;
@@ -33,6 +37,7 @@
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Conditional;
 import org.springframework.web.reactive.function.server.RouterFunction;
+import org.springframework.web.reactive.function.server.ServerRequest;
 
 /**
  * @author Christian Tzolov
@@ -57,9 +62,20 @@ public WebFluxStreamableServerTransportProvider webFluxStreamableServerTransport
 			.messageEndpoint(serverProperties.getMcpEndpoint())
 			.keepAliveInterval(serverProperties.getKeepAliveInterval())
 			.disallowDelete(serverProperties.isDisallowDelete())
+			.contextExtractor(this::extractContextFromRequest)
 			.build();
 	}
 
+	private McpTransportContext extractContextFromRequest(ServerRequest serverRequest) {
+		Map<String, Object> headersMap = new HashMap<>();
+		serverRequest.headers().asHttpHeaders().forEach((headerName, headerValues) -> {
+			if (!headerValues.isEmpty()) {
+				headersMap.put(headerName, headerValues.get(0));
+			}
+		});
+		return McpTransportContext.create(headersMap);
+	}
+
 	// Router function for streamable http transport used by Spring WebFlux to start an
 	// HTTP server.
 	@Bean

auto-configurations/mcp/spring-ai-autoconfigure-mcp-server-webflux/src/test/java/org/springframework/ai/mcp/server/autoconfigure/McpServerStreamableHttpWebFluxAutoConfigurationIT.java

@@ -192,4 +192,20 @@ void enabledPropertyExplicitlyTrue() {
 		});
 	}
 
+	@Test
+	void contextExtractorExtractsHeaders() {
+		this.contextRunner.run(context -> {
+			WebFluxStreamableServerTransportProvider provider = context
+				.getBean(WebFluxStreamableServerTransportProvider.class);
+
+			// Verify the provider is properly configured with context extractor
+			assertThat(provider).isNotNull();
+
+			// Note: Testing the actual header extraction requires a live request context
+			// which is better tested through integration tests with a running server.
+			// This test verifies that the bean is properly configured with the context
+			// extractor.
+		});
+	}
+
 }

auto-configurations/mcp/spring-ai-autoconfigure-mcp-server-webmvc/src/main/java/org/springframework/ai/mcp/server/autoconfigure/McpServerStreamableHttpWebMvcAutoConfiguration.java

@@ -16,7 +16,11 @@
 
 package org.springframework.ai.mcp.server.autoconfigure;
 
+import java.util.HashMap;
+import java.util.Map;
+
 import com.fasterxml.jackson.databind.ObjectMapper;
+import io.modelcontextprotocol.common.McpTransportContext;
 import io.modelcontextprotocol.json.jackson.JacksonMcpJsonMapper;
 import io.modelcontextprotocol.server.transport.WebMvcStreamableServerTransportProvider;
 import io.modelcontextprotocol.spec.McpSchema;
@@ -33,6 +37,7 @@
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Conditional;
 import org.springframework.web.servlet.function.RouterFunction;
+import org.springframework.web.servlet.function.ServerRequest;
 import org.springframework.web.servlet.function.ServerResponse;
 
 /**
@@ -41,32 +46,58 @@
  */
 @AutoConfiguration(before = McpServerAutoConfiguration.class)
 @ConditionalOnClass(McpSchema.class)
-@EnableConfigurationProperties({ McpServerProperties.class, McpServerStreamableHttpProperties.class })
+@EnableConfigurationProperties({ McpServerProperties.class,
+		McpServerStreamableHttpProperties.class })
 @Conditional({ McpServerStdioDisabledCondition.class,
 		McpServerAutoConfiguration.EnabledStreamableServerCondition.class })
 public class McpServerStreamableHttpWebMvcAutoConfiguration {
 
+	/**
+	 * Creates a WebMvc streamable server transport provider.
+	 * @param objectMapperProvider the object mapper provider
+	 * @param serverProperties the server properties
+	 * @return the transport provider
+	 */
 	@Bean
 	@ConditionalOnMissingBean
 	public WebMvcStreamableServerTransportProvider webMvcStreamableServerTransportProvider(
-			ObjectProvider<ObjectMapper> objectMapperProvider, McpServerStreamableHttpProperties serverProperties) {
+			final ObjectProvider<ObjectMapper> objectMapperProvider,
+			final McpServerStreamableHttpProperties serverProperties) {
 
-		ObjectMapper objectMapper = objectMapperProvider.getIfAvailable(ObjectMapper::new);
+		ObjectMapper objectMapper = objectMapperProvider
+			.getIfAvailable(ObjectMapper::new);
 
 		return WebMvcStreamableServerTransportProvider.builder()
 			.jsonMapper(new JacksonMcpJsonMapper(objectMapper))
 			.mcpEndpoint(serverProperties.getMcpEndpoint())
 			.keepAliveInterval(serverProperties.getKeepAliveInterval())
 			.disallowDelete(serverProperties.isDisallowDelete())
+			.contextExtractor(this::extractContextFromRequest)
 			.build();
 	}
 
-	// Router function for streamable http transport used by Spring WebFlux to start an
-	// HTTP server.
+	private McpTransportContext extractContextFromRequest(
+			final ServerRequest serverRequest) {
+		Map<String, Object> headersMap = new HashMap<>();
+		serverRequest.headers()
+			.asHttpHeaders()
+			.forEach((headerName, headerValues) -> {
+				if (!headerValues.isEmpty()) {
+					headersMap.put(headerName, headerValues.get(0));
+				}
+			});
+		return McpTransportContext.create(headersMap);
+	}
+
+	/**
+	 * Creates a router function for the streamable server transport.
+	 * @param webMvcProvider the transport provider
+	 * @return the router function
+	 */
 	@Bean
 	@ConditionalOnMissingBean(name = "webMvcStreamableServerRouterFunction")
 	public RouterFunction<ServerResponse> webMvcStreamableServerRouterFunction(
-			WebMvcStreamableServerTransportProvider webMvcProvider) {
+			final WebMvcStreamableServerTransportProvider webMvcProvider) {
 		return webMvcProvider.getRouterFunction();
 	}
 

auto-configurations/mcp/spring-ai-autoconfigure-mcp-server-webmvc/src/test/java/org/springframework/ai/mcp/server/autoconfigure/McpServerStreamableHttpWebMvcAutoConfigurationIT.java

@@ -23,7 +23,9 @@
 
 import org.springframework.boot.autoconfigure.AutoConfigurations;
 import org.springframework.boot.test.context.runner.ApplicationContextRunner;
+import org.springframework.mock.web.MockHttpServletRequest;
 import org.springframework.web.servlet.function.RouterFunction;
+import org.springframework.web.servlet.function.ServerRequest;
 
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.mockito.Mockito.mock;
@@ -192,4 +194,28 @@ void enabledPropertyExplicitlyTrue() {
 		});
 	}
 
+	@Test
+	void contextExtractorExtractsHeaders() {
+		this.contextRunner.run(context -> {
+			WebMvcStreamableServerTransportProvider provider = context
+				.getBean(WebMvcStreamableServerTransportProvider.class);
+
+			// Create a mock ServerRequest with headers
+			MockHttpServletRequest mockRequest = new MockHttpServletRequest();
+			mockRequest.addHeader("xxxx", "123456");
+			mockRequest.addHeader("Authorization", "Bearer token123");
+			mockRequest.addHeader("Content-Type", "application/json");
+
+			ServerRequest serverRequest = ServerRequest.create(mockRequest, java.util.Collections.emptyList());
+
+			// Verify the provider is properly configured
+			assertThat(provider).isNotNull();
+
+			// Verify headers are accessible from the ServerRequest
+			assertThat(serverRequest.headers().firstHeader("xxxx")).isEqualTo("123456");
+			assertThat(serverRequest.headers().firstHeader("Authorization")).isEqualTo("Bearer token123");
+			assertThat(serverRequest.headers().firstHeader("Content-Type")).isEqualTo("application/json");
+		});
+	}
+
 }