fix(transports): Conform SSE/HTTP streams to MCP spec and improve logging

- Removes non-standard initial messages (': stream opened', initial ': keep-alive') from SSE and HTTP stream transports.
- Corrects periodic keep-alive mechanism to send standard JSON-RPC 'ping' requests instead of ': keep-alive' comments, aligning with MCP specification.
- Updates server startup log message in MCPServer to include the framework's own version alongside the SDK version for better diagnostics.

Author: seuros

src/core/MCPServer.ts

@@ -432,8 +432,10 @@ export class MCPServer {
       }
       this.isRunning = true;
 
+      const frameworkPackageJson = require('../../package.json');
+      const frameworkVersion = frameworkPackageJson.version || 'unknown';
       const sdkVersion = this.getSdkVersion();
-      logger.info(`Starting MCP server with SDK ${sdkVersion}...`);
+      logger.info(`Starting MCP server (Framework: ${frameworkVersion}, SDK: ${sdkVersion})...`);
 
       const tools = await this.toolLoader.loadTools();
       this.toolsMap = new Map(

src/transports/http/server.ts

@@ -481,7 +481,6 @@ export class HttpStreamTransport extends AbstractTransport {
     if (res.socket) { res.socket.setNoDelay(true); res.socket.setKeepAlive(true); res.socket.setTimeout(0); logger.debug(`Optimized socket for SSE stream ${streamId}`); }
     else { logger.warn(`Could not access socket for SSE stream ${streamId} to optimize.`); }
     this._activeSseConnections.add(connection);
-    res.write(': stream opened\n\n');
     connection.pingInterval = setInterval(() => this.sendPing(connection), 15000);
     if (lastEventId && this._config.resumability.enabled) {
         this.handleResumption(connection, lastEventId, sessionId).catch(err => { logger.error(`Error during stream resumption for ${streamId}: ${err.message}`); this.cleanupConnection(connection, `Resumption error: ${err.message}`); });
@@ -646,7 +645,8 @@ export class HttpStreamTransport extends AbstractTransport {
   private sendPing(connection: ActiveSseConnection): void {
       if (!connection || !connection.res || connection.res.writableEnded) return;
       try {
-          connection.res.write(': keep-alive\n\n');
+          const pingMessage = { jsonrpc: "2.0", method: "ping", params: { timestamp: Date.now() } };
+          connection.res.write(`data: ${JSON.stringify(pingMessage)}\n\n`);
           logger.debug(`Sent keep-alive ping to stream ${connection.streamId}`);
       } catch (error: any) {
           logger.error(`Error sending ping to stream ${connection.streamId}: ${error.message}`);

src/transports/sse/server.ts

@@ -225,13 +225,14 @@ export class SSEServerTransport extends AbstractTransport {
     res.write(`event: endpoint\ndata: ${endpointUrl}\n\n`)
 
     logger.debug('Sending initial keep-alive')
-    res.write(": keep-alive\n\n")
+    // Removed initial keep-alive: res.write(": keep-alive\n\n")
 
     this._keepAliveInterval = setInterval(() => {
       if (this._sseResponse && !this._sseResponse.writableEnded) {
         try {
-          logger.debug('Sending keep-alive ping')
-          this._sseResponse.write(": keep-alive\n\n")
+          // Sending proper JSON-RPC ping instead of ': keep-alive' comment
+          // logger.debug('Sending keep-alive ping')
+          // this._sseResponse.write(": keep-alive\n\n")
 
           const pingMessage = {
             jsonrpc: "2.0",

tsconfig.json

@@ -9,7 +9,8 @@
     "strict": true,
     "esModuleInterop": true,
     "skipLibCheck": true,
-    "forceConsistentCasingInFileNames": true
+    "forceConsistentCasingInFileNames": true,
+    "resolveJsonModule": true
   },
   "include": ["src/**/*"],
   "exclude": ["node_modules", "**/*.test.ts"]