re-enable the *ClientStreamableHttpTransportErrorHandlingTest

Author: tzolov

mcp-spring/mcp-spring-webflux/src/test/java/io/modelcontextprotocol/client/transport/WebClientStreamableHttpTransportErrorHandlingTest.java

@@ -44,7 +44,6 @@
  * @author Christian Tzolov
  */
 @Timeout(15)
-@Disabled
 public class WebClientStreamableHttpTransportErrorHandlingTest {
 
 	private static final int PORT = TestUtil.findAvailablePort();

mcp/src/test/java/io/modelcontextprotocol/client/transport/HttpClientStreamableHttpTransportErrorHandlingTest.java

@@ -39,7 +39,6 @@
  * @author Christian Tzolov
  */
 @Timeout(15)
-@Disabled
 public class HttpClientStreamableHttpTransportErrorHandlingTest {
 
 	private static final int PORT = TomcatTestUtil.findAvailablePort();

mcp/src/test/java/io/modelcontextprotocol/server/McpCompletionTests.java

@@ -27,10 +27,12 @@
 import io.modelcontextprotocol.spec.McpSchema;
 import io.modelcontextprotocol.spec.McpSchema.CompleteRequest;
 import io.modelcontextprotocol.spec.McpSchema.CompleteResult;
+import io.modelcontextprotocol.spec.McpSchema.ErrorCodes;
 import io.modelcontextprotocol.spec.McpSchema.InitializeResult;
 import io.modelcontextprotocol.spec.McpSchema.Prompt;
 import io.modelcontextprotocol.spec.McpSchema.PromptArgument;
 import io.modelcontextprotocol.spec.McpSchema.ReadResourceResult;
+import io.modelcontextprotocol.spec.McpSchema.Resource;
 import io.modelcontextprotocol.spec.McpSchema.ResourceReference;
 import io.modelcontextprotocol.spec.McpSchema.PromptReference;
 import io.modelcontextprotocol.spec.McpSchema.ServerCapabilities;
@@ -84,7 +86,7 @@ public void after() {
 				tomcat.destroy();
 			}
 			catch (LifecycleException e) {
-				throw new RuntimeException("Failed to stop Tomcat", e);
+				e.printStackTrace();
 			}
 		}
 	}
@@ -99,8 +101,13 @@ void testCompletionHandlerReceivesContext() {
 
 		ResourceReference resourceRef = new ResourceReference("ref/resource", "test://resource/{param}");
 
-		McpSchema.Resource resource = new McpSchema.Resource("test://resource/{param}", "Test Resource",
-				"A resource for testing", "text/plain", 123L, null);
+		var resource = Resource.builder()
+			.uri("test://resource/{param}")
+			.name("Test Resource")
+			.description("A resource for testing")
+			.mimeType("text/plain")
+			.size(123L)
+			.build();
 
 		var mcpServer = McpServer.sync(mcpServerTransportProvider)
 			.capabilities(ServerCapabilities.builder().completions().build())
@@ -199,8 +206,13 @@ else if ("products_db".equals(db)) {
 			return new CompleteResult(new CompleteResult.CompleteCompletion(List.of(), 0, false));
 		};
 
-		McpSchema.Resource resource = new McpSchema.Resource("db://{database}/{table}", "Database Table",
-				"Resource representing a table in a database", "application/json", 456L, null);
+		McpSchema.Resource resource = Resource.builder()
+			.uri("db://{database}/{table}")
+			.name("Database Table")
+			.description("Resource representing a table in a database")
+			.mimeType("application/json")
+			.size(456L)
+			.build();
 
 		var mcpServer = McpServer.sync(mcpServerTransportProvider)
 			.capabilities(ServerCapabilities.builder().completions().build())
@@ -254,7 +266,10 @@ void testCompletionErrorOnMissingContext() {
 						// Check if database context is provided
 						if (request.context() == null || request.context().arguments() == null
 								|| !request.context().arguments().containsKey("database")) {
-							throw new McpError("Please select a database first to see available tables");
+
+							throw McpError.builder(ErrorCodes.INVALID_REQUEST)
+								.message("Please select a database first to see available tables")
+								.build();
 						}
 						// Normal completion if context is provided
 						String db = request.context().arguments().get("database");
@@ -268,8 +283,13 @@ void testCompletionErrorOnMissingContext() {
 			return new CompleteResult(new CompleteResult.CompleteCompletion(List.of(), 0, false));
 		};
 
-		McpSchema.Resource resource = new McpSchema.Resource("db://{database}/{table}", "Database Table",
-				"Resource representing a table in a database", "application/json", 456L, null);
+		McpSchema.Resource resource = Resource.builder()
+			.uri("db://{database}/{table}")
+			.name("Database Table")
+			.description("Resource representing a table in a database")
+			.mimeType("application/json")
+			.size(456L)
+			.build();
 
 		var mcpServer = McpServer.sync(mcpServerTransportProvider)
 			.capabilities(ServerCapabilities.builder().completions().build())