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

fix build

Browse source
This commit is contained in:
ihrpr 2025-04-18 11:52:51 +01:00
commit ea04be4cf8
No known key found for this signature in database
2 changed files with 35 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

28
README.md
View file

@ -313,16 +313,29 @@ const app = express();
app.use(express.json());
const transport: StreamableHTTPServerTransport = new StreamableHTTPServerTransport({
sessionIdGenerator: undefined,
sessionIdGenerator: undefined, // set to undefined for stateless servers
});
await server.connect(transport);
// Setup routes for the server
const setupServer = async () => {
await server.connect(transport);
};
app.post('/mcp', async (req: Request, res: Response) => {
console.log('Received MCP request:', req.body);
try {
await transport.handleRequest(req, res, req.body);
} catch (error) {
// ... handle error
console.error('Error handling MCP request:', error);
if (!res.headersSent) {
res.status(500).json({
jsonrpc: '2.0',
error: {
code: -32603,
message: 'Internal server error',
},
id: null,
});
}
}
});
@ -353,8 +366,13 @@ app.delete('/mcp', async (req: Request, res: Response) => {
// Start the server
const PORT = 3000;
app.listen(PORT, () => {
console.log(`Stateless MCP Streamable HTTP Server listening on port ${PORT}`);
setupServer().then(() => {
app.listen(PORT, () => {
console.log(`MCP Streamable HTTP Server listening on port ${PORT}`);
});
}).catch(error => {
console.error('Failed to set up the server:', error);
process.exit(1);
});
```

15
src/examples/server/simpleStatelessStreamableHttp.ts
View file

@ -96,7 +96,11 @@ app.use(express.json());
const transport: StreamableHTTPServerTransport = new StreamableHTTPServerTransport({
sessionIdGenerator: undefined,
});
await server.connect(transport);
// Setup routes for the server
const setupServer = async () => {
await server.connect(transport);
};
app.post('/mcp', async (req: Request, res: Response) => {
console.log('Received MCP request:', req.body);
@ -143,8 +147,13 @@ app.delete('/mcp', async (req: Request, res: Response) => {
// Start the server
const PORT = 3000;
app.listen(PORT, () => {
console.log(`MCP Streamable HTTP Server listening on port ${PORT}`);
setupServer().then(() => {
app.listen(PORT, () => {
console.log(`MCP Streamable HTTP Server listening on port ${PORT}`);
});
}).catch(error => {
console.error('Failed to set up the server:', error);
process.exit(1);
});
// Handle server shutdown