@@ -12,7 +12,7 @@ export default app
1212app . set ( 'query parser' , 'simple' )
1313app . set ( 'json spaces' , 2 )
1414
15- app . use ( createSiteMiddleware ( 'mcp' , { prefixOptional : true } ) )
15+ app . use ( createSiteMiddleware ( 'mcp' ) )
1616
1717// Store transports for each session type
1818const transports = {
@@ -27,7 +27,7 @@ const mcpServer = await MCPServer(config.dataFairUrl)
2727// Based on https://github.com/modelcontextprotocol/typescript-sdk?tab=readme-ov-file#with-session-management
2828
2929// Handle POST requests for client-to-server communication
30- app . post ( '/mcp' , async ( req : Request , res : Response ) => {
30+ app . post ( '/datasets/ mcp' , async ( req : Request , res : Response ) => {
3131 try {
3232 const transport : StreamableHTTPServerTransport = new StreamableHTTPServerTransport ( {
3333 sessionIdGenerator : undefined
@@ -68,14 +68,14 @@ const handleSessionRequest = async (req: Request, res: Response) => {
6868}
6969
7070// SSE notifications not supported in stateless mode
71- app . get ( '/mcp' , handleSessionRequest )
71+ app . get ( '/datasets/ mcp' , handleSessionRequest )
7272// Session termination not needed in stateless mode
73- app . delete ( '/mcp' , handleSessionRequest )
73+ app . delete ( '/datasets/ mcp' , handleSessionRequest )
7474
7575// -------------- Legacy Endpoints for SSE older clients --------------
7676// Based on https://github.com/modelcontextprotocol/typescript-sdk?tab=readme-ov-file#server-side-compatibility
7777
78- app . get ( '/sse' , async ( req : Request , res : Response ) => {
78+ app . get ( '/datasets/ sse' , async ( req : Request , res : Response ) => {
7979 const transport = new SSEServerTransport ( '/messages' , res )
8080 transports . sse [ transport . sessionId ] = transport
8181
@@ -86,7 +86,7 @@ app.get('/sse', async (req: Request, res: Response) => {
8686 await mcpServer . connect ( transport )
8787} )
8888
89- app . post ( '/messages' , async ( req : Request , res : Response ) => {
89+ app . post ( '/datasets/ messages' , async ( req : Request , res : Response ) => {
9090 const sessionId = req . query . sessionId as string
9191 const transport = transports . sse [ sessionId ]
9292 if ( transport ) {
0 commit comments