WIP: make it compile

Signed-off-by: Dariusz Jędrzejczyk <[email protected]>

Author: chemicL

mcp/src/main/java/io/modelcontextprotocol/server/McpAsyncServerExchange.java

@@ -13,6 +13,7 @@
 import io.modelcontextprotocol.spec.McpSchema;
 import io.modelcontextprotocol.spec.McpSchema.LoggingLevel;
 import io.modelcontextprotocol.spec.McpSchema.LoggingMessageNotification;
+import io.modelcontextprotocol.spec.McpServerSession;
 import io.modelcontextprotocol.spec.McpSession;
 import io.modelcontextprotocol.spec.McpTransportContext;
 import io.modelcontextprotocol.util.Assert;
@@ -63,6 +64,7 @@ public class McpAsyncServerExchange {
 	@Deprecated
 	public McpAsyncServerExchange(McpSession session, McpSchema.ClientCapabilities clientCapabilities,
 			McpSchema.Implementation clientInfo) {
+		this.sessionId = null;
 		this.session = session;
 		this.clientCapabilities = clientCapabilities;
 		this.clientInfo = clientInfo;

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

@@ -246,6 +246,8 @@ private Mono<Void> handleIncomingNotification(McpSchema.JSONRPCNotification noti
 		return Mono.defer(() -> {
 			if (McpSchema.METHOD_NOTIFICATION_INITIALIZED.equals(notification.method())) {
 				this.state.lazySet(STATE_INITIALIZED);
+				// FIXME: The session ID passed here is not the same as the one in the
+				// legacy SSE transport.
 				exchangeSink.tryEmitValue(new McpAsyncServerExchange(this.id, this, clientCapabilities.get(),
 						clientInfo.get(), McpTransportContext.EMPTY));
 				return this.initNotificationHandler.handle();