/**
* Streamable HTTP Transport for Remote MCP Access
* Uses the modern StreamableHTTPServerTransport
*/
import express, { Request, Response } from 'express';
import { Server } from '@modelcontextprotocol/sdk/server/index.js';
import { StreamableHTTPServerTransport } from '@modelcontextprotocol/sdk/server/streamableHttp.js';
import { createChhartMcpServer } from '../server-sse.js';
export function createHTTPServer(port: number = 3000) {
const app = express();
// Enable CORS for cross-origin requests
app.use((req, res, next) => {
res.header('Access-Control-Allow-Origin', '*');
res.header('Access-Control-Allow-Methods', 'GET, POST, OPTIONS');
res.header('Access-Control-Allow-Headers', 'Content-Type, mcp-session-id');
if (req.method === 'OPTIONS') {
res.sendStatus(200);
return;
}
next();
});
app.use(express.json({ limit: '10mb' }));
// Health check endpoint
app.get('/health', (req: Request, res: Response) => {
res.json({
status: 'ok',
service: 'chhart-mcp-server',
version: '1.0.2',
timestamp: new Date().toISOString()
});
});
// Create transport
const transport = new StreamableHTTPServerTransport();
const server = createChhartMcpServer();
// Connect the MCP server to the transport
server.connect(transport);
// MCP endpoint - handles all MCP protocol messages
app.post('/mcp', async (req: Request, res: Response) => {
try {
await transport.handleRequest(req, res, req.body);
} catch (error) {
console.error('Error handling MCP request:', error);
if (!res.headersSent) {
res.status(500).json({
error: 'Internal server error',
message: error instanceof Error ? error.message : String(error)
});
}
}
});
// Start server
const httpServer = app.listen(port, () => {
console.error(`Chhart MCP Server (Streamable HTTP) listening on port ${port}`);
console.error(`Health check: http://localhost:${port}/health`);
console.error(`MCP endpoint: http://localhost:${port}/mcp`);
});
// Increase timeouts
httpServer.headersTimeout = 65000;
httpServer.keepAliveTimeout = 61000;
return app;
}
