fix(0.0.8) 修复Cursor报错：TypeError: terminated: Body Timeout Error Calling MCP tool ，参考modelcontextprotocol/typescript-sdk#270

Author: licon

src/server.ts

@@ -807,11 +807,57 @@ export class FeishuMcpServer {
 
   async startHttpServer(port: number): Promise<void> {
     const app = express();
+    const transports: {[sessionId: string]: SSEServerTransport} = {};
+    const sseConnections = new Map<string, { res: Response, intervalId: NodeJS.Timeout }>();
+    const KEEP_ALIVE_INTERVAL_MS = 25000; // Send keep-alive every 25 seconds
+
 
     app.get('/sse', async (_req: Request, res: Response) => {
       console.log('New SSE connection established');
       this.sseTransport = new SSEServerTransport('/messages', res as unknown as ServerResponse<IncomingMessage>);
-      await this.server.connect(this.sseTransport);
+
+      const sessionId = this.sseTransport.sessionId; // Get session ID from transport
+      transports[sessionId] = this.sseTransport;
+      // Start keep-alive ping
+      const intervalId = setInterval(() => {
+	      if (sseConnections.has(sessionId) && !res.writableEnded) {
+		      res.write(': keepalive\n\n');
+	      } else {
+		      // Should not happen if close handler is working, but clear just in case
+		      clearInterval(intervalId);
+		      sseConnections.delete(sessionId);
+	      }
+      }, KEEP_ALIVE_INTERVAL_MS);
+        // Store connection details
+      sseConnections.set(sessionId, { res, intervalId });
+      console.log(`[SSE Connection] Client connected: ${sessionId}, starting keep-alive.`);
+      res.on("close", () => {
+	      console.log(`[SSE Connection] Client disconnected: ${sessionId}, stopping keep-alive.`);
+	      // Clean up transport
+	      delete transports[sessionId];
+	      // Clean up keep-alive interval
+	      const connection = sseConnections.get(sessionId);
+	      if (connection) {
+		      clearInterval(connection.intervalId);
+		      sseConnections.delete(sessionId);
+	      }
+      });
+      // Connect server to transport *after* setting up handlers
+      try {
+	      await this.server.connect(this.sseTransport)
+      } catch (error) {
+	      console.error(`[SSE Connection] Error connecting server to transport for ${sessionId}:`, error);
+	      // Ensure cleanup happens even if connect fails
+	      clearInterval(intervalId);
+	      sseConnections.delete(sessionId);
+	      delete transports[sessionId];
+	      if (!res.writableEnded) {
+		      res.status(500).end('Failed to connect MCP server to transport');
+	      }
+      }
+
+
+      // await this.server.connect(this.sseTransport);
     });
 
     app.post('/messages', async (req: Request, res: Response) => {