modelcontextprotocol/servers
Watch
1
0
Fork
You've already forked servers
 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix: passing body to handleRequest, and optionally adding a response id if it exists

Browse source
This commit is contained in:
Shiv Deepak Muddada 2025-04-19 16:21:41 -07:00
commit d1d79444f7
1 changed files with 9 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

16
src/everything/streamableHttp.ts
View file

@ -50,7 +50,7 @@ app.post('/mcp', async (req: Request, res: Response) => {
// so responses can flow back through the same transport // so responses can flow back through the same transport
await server.connect(transport); await server.connect(transport);
await transport.handleRequest(req, res); await transport.handleRequest(req, res, req.body);
return; // Already handled return; // Already handled
} else { } else {
// Invalid request - no session ID or not initialization request // Invalid request - no session ID or not initialization request
@ -60,14 +60,14 @@ app.post('/mcp', async (req: Request, res: Response) => {
code: -32000, code: -32000,
message: 'Bad Request: No valid session ID provided', message: 'Bad Request: No valid session ID provided',
}, },
id: null, id: req?.body?.id,
}); });
return; return;
} }
// Handle the request with existing transport - no need to reconnect // Handle the request with existing transport - no need to reconnect
// The existing transport is already connected to the server // The existing transport is already connected to the server
await transport.handleRequest(req, res); await transport.handleRequest(req, res, req.body);
} catch (error) { } catch (error) {
console.error('Error handling MCP request:', error); console.error('Error handling MCP request:', error);
if (!res.headersSent) { if (!res.headersSent) {
@ -77,8 +77,9 @@ app.post('/mcp', async (req: Request, res: Response) => {
code: -32603, code: -32603,
message: 'Internal server error', message: 'Internal server error',
}, },
id: null, id: req?.body?.id,
}); });
return;
} }
} }
}); });
@ -93,7 +94,7 @@ app.get('/mcp', async (req: Request, res: Response) => {
code: -32000, code: -32000,
message: 'Bad Request: No valid session ID provided', message: 'Bad Request: No valid session ID provided',
}, },
id: null, id: req?.body?.id,
}); });
return; return;
} }
@ -120,7 +121,7 @@ app.delete('/mcp', async (req: Request, res: Response) => {
code: -32000, code: -32000,
message: 'Bad Request: No valid session ID provided', message: 'Bad Request: No valid session ID provided',
}, },
id: null, id: req?.body?.id,
}); });
return; return;
} }
@ -139,8 +140,9 @@ app.delete('/mcp', async (req: Request, res: Response) => {
code: -32603, code: -32603,
message: 'Error handling session termination', message: 'Error handling session termination',
}, },
id: null, id: req?.body?.id,
}); });
return;
} }
} }
}); });