feat(server): Enhance server factory interfaces with async specification and streamline server creation

Author: codeboyzhou

src/main/java/com/github/codeboyzhou/mcp/declarative/server/configurable/AbstractConfigurableMcpServerFactory.java

@@ -3,8 +3,10 @@
 import com.github.codeboyzhou.mcp.declarative.configuration.McpServerCapabilities;
 import com.github.codeboyzhou.mcp.declarative.configuration.McpServerChangeNotification;
 import com.github.codeboyzhou.mcp.declarative.configuration.McpServerConfiguration;
+import io.modelcontextprotocol.server.McpAsyncServer;
 import io.modelcontextprotocol.spec.McpSchema;
 import io.modelcontextprotocol.spec.McpServerTransportProviderBase;
+import java.time.Duration;
 
 public abstract class AbstractConfigurableMcpServerFactory<T extends McpServerTransportProviderBase>
     implements ConfigurableMcpServerFactory<T> {
@@ -31,4 +33,14 @@ public McpSchema.ServerCapabilities serverCapabilities() {
     }
     return capabilities.build();
   }
+
+  @Override
+  public McpAsyncServer create() {
+    return specification()
+        .serverInfo(configuration.name(), configuration.version())
+        .capabilities(serverCapabilities())
+        .instructions(configuration.instructions())
+        .requestTimeout(Duration.ofMillis(configuration.requestTimeout()))
+        .build();
+  }
 }

src/main/java/com/github/codeboyzhou/mcp/declarative/server/configurable/ConfigurableMcpHttpSseServerFactory.java

@@ -1,14 +1,8 @@
 package com.github.codeboyzhou.mcp.declarative.server.configurable;
 
-import com.github.codeboyzhou.mcp.declarative.common.NamedThreadFactory;
 import com.github.codeboyzhou.mcp.declarative.configuration.McpServerConfiguration;
-import com.github.codeboyzhou.mcp.declarative.server.McpHttpServer;
-import io.modelcontextprotocol.server.McpAsyncServer;
 import io.modelcontextprotocol.server.McpServer;
 import io.modelcontextprotocol.server.transport.HttpServletSseServerTransportProvider;
-import java.time.Duration;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
 
 public class ConfigurableMcpHttpSseServerFactory
     extends AbstractConfigurableMcpServerFactory<HttpServletSseServerTransportProvider> {
@@ -27,20 +21,7 @@ public HttpServletSseServerTransportProvider transportProvider() {
   }
 
   @Override
-  public McpAsyncServer create() {
-    HttpServletSseServerTransportProvider transportProvider = transportProvider();
-    McpAsyncServer server =
-        McpServer.async(transportProvider)
-            .serverInfo(configuration.name(), configuration.version())
-            .capabilities(serverCapabilities())
-            .instructions(configuration.instructions())
-            .requestTimeout(Duration.ofMillis(configuration.requestTimeout()))
-            .build();
-    McpHttpServer httpServer = new McpHttpServer();
-    NamedThreadFactory threadFactory = new NamedThreadFactory(McpHttpServer.class.getSimpleName());
-    ExecutorService executor = Executors.newSingleThreadExecutor(threadFactory);
-    executor.execute(
-        () -> httpServer.use(transportProvider).bind(configuration.sse().port()).start());
-    return server;
+  public McpServer.AsyncSpecification<?> specification() {
+    return McpServer.async(transportProvider());
   }
 }

src/main/java/com/github/codeboyzhou/mcp/declarative/server/configurable/ConfigurableMcpHttpStreamableServerFactory.java

@@ -1,14 +1,8 @@
 package com.github.codeboyzhou.mcp.declarative.server.configurable;
 
-import com.github.codeboyzhou.mcp.declarative.common.NamedThreadFactory;
 import com.github.codeboyzhou.mcp.declarative.configuration.McpServerConfiguration;
-import com.github.codeboyzhou.mcp.declarative.server.McpHttpServer;
-import io.modelcontextprotocol.server.McpAsyncServer;
 import io.modelcontextprotocol.server.McpServer;
 import io.modelcontextprotocol.server.transport.HttpServletStreamableServerTransportProvider;
-import java.time.Duration;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
 
 public class ConfigurableMcpHttpStreamableServerFactory
     extends AbstractConfigurableMcpServerFactory<HttpServletStreamableServerTransportProvider> {
@@ -23,20 +17,7 @@ public HttpServletStreamableServerTransportProvider transportProvider() {
   }
 
   @Override
-  public McpAsyncServer create() {
-    HttpServletStreamableServerTransportProvider transportProvider = transportProvider();
-    McpAsyncServer server =
-        McpServer.async(transportProvider)
-            .serverInfo(configuration.name(), configuration.version())
-            .capabilities(serverCapabilities())
-            .instructions(configuration.instructions())
-            .requestTimeout(Duration.ofMillis(configuration.requestTimeout()))
-            .build();
-    McpHttpServer httpServer = new McpHttpServer();
-    NamedThreadFactory threadFactory = new NamedThreadFactory(McpHttpServer.class.getSimpleName());
-    ExecutorService executor = Executors.newSingleThreadExecutor(threadFactory);
-    executor.execute(
-        () -> httpServer.use(transportProvider).bind(configuration.sse().port()).start());
-    return server;
+  public McpServer.AsyncSpecification<?> specification() {
+    return McpServer.async(transportProvider());
   }
 }

src/main/java/com/github/codeboyzhou/mcp/declarative/server/configurable/ConfigurableMcpServerFactory.java

@@ -1,14 +1,17 @@
 package com.github.codeboyzhou.mcp.declarative.server.configurable;
 
 import io.modelcontextprotocol.server.McpAsyncServer;
+import io.modelcontextprotocol.server.McpServer;
 import io.modelcontextprotocol.spec.McpSchema;
 import io.modelcontextprotocol.spec.McpServerTransportProviderBase;
 
 public interface ConfigurableMcpServerFactory<T extends McpServerTransportProviderBase> {
 
-  McpSchema.ServerCapabilities serverCapabilities();
-
   T transportProvider();
 
+  McpServer.AsyncSpecification<?> specification();
+
+  McpSchema.ServerCapabilities serverCapabilities();
+
   McpAsyncServer create();
 }

src/main/java/com/github/codeboyzhou/mcp/declarative/server/configurable/ConfigurableMcpStdioServerFactory.java

@@ -1,10 +1,8 @@
 package com.github.codeboyzhou.mcp.declarative.server.configurable;
 
 import com.github.codeboyzhou.mcp.declarative.configuration.McpServerConfiguration;
-import io.modelcontextprotocol.server.McpAsyncServer;
 import io.modelcontextprotocol.server.McpServer;
 import io.modelcontextprotocol.server.transport.StdioServerTransportProvider;
-import java.time.Duration;
 
 public class ConfigurableMcpStdioServerFactory
     extends AbstractConfigurableMcpServerFactory<StdioServerTransportProvider> {
@@ -19,12 +17,7 @@ public StdioServerTransportProvider transportProvider() {
   }
 
   @Override
-  public McpAsyncServer create() {
-    return McpServer.async(transportProvider())
-        .serverInfo(configuration.name(), configuration.version())
-        .capabilities(serverCapabilities())
-        .instructions(configuration.instructions())
-        .requestTimeout(Duration.ofMillis(configuration.requestTimeout()))
-        .build();
+  public McpServer.AsyncSpecification<?> specification() {
+    return McpServer.async(transportProvider());
   }
 }