diff --git a/src/cli.ts b/src/cli.ts index b5000896d..f580a624f 100644 --- a/src/cli.ts +++ b/src/cli.ts @@ -102,7 +102,11 @@ async function runServer(port: number | null) { await transport.handlePostMessage(req, res); }); - app.listen(port, () => { + app.listen(port, (error) => { + if (error) { + console.error('Failed to start server:', error); + process.exit(1); + } console.log(`Server running on http://localhost:${port}/sse`); }); } else { diff --git a/src/examples/server/demoInMemoryOAuthProvider.ts b/src/examples/server/demoInMemoryOAuthProvider.ts index 274a504a1..c83748d35 100644 --- a/src/examples/server/demoInMemoryOAuthProvider.ts +++ b/src/examples/server/demoInMemoryOAuthProvider.ts @@ -200,7 +200,11 @@ export const setupAuthServer = ({authServerUrl, mcpServerUrl, strictResource}: { const auth_port = authServerUrl.port; // Start the auth server - authApp.listen(auth_port, () => { + authApp.listen(auth_port, (error) => { + if (error) { + console.error('Failed to start server:', error); + process.exit(1); + } console.log(`OAuth Authorization Server listening on port ${auth_port}`); }); diff --git a/src/examples/server/jsonResponseStreamableHttp.ts b/src/examples/server/jsonResponseStreamableHttp.ts index 04b14470b..d6501d275 100644 --- a/src/examples/server/jsonResponseStreamableHttp.ts +++ b/src/examples/server/jsonResponseStreamableHttp.ts @@ -158,7 +158,11 @@ app.get('/mcp', async (req: Request, res: Response) => { // Start the server const PORT = 3000; -app.listen(PORT, () => { +app.listen(PORT, (error) => { + if (error) { + console.error('Failed to start server:', error); + process.exit(1); + } console.log(`MCP Streamable HTTP Server listening on port ${PORT}`); }); diff --git a/src/examples/server/simpleSseServer.ts b/src/examples/server/simpleSseServer.ts index c34179206..f8bdd4662 100644 --- a/src/examples/server/simpleSseServer.ts +++ b/src/examples/server/simpleSseServer.ts @@ -145,7 +145,11 @@ app.post('/messages', async (req: Request, res: Response) => { // Start the server const PORT = 3000; -app.listen(PORT, () => { +app.listen(PORT, (error) => { + if (error) { + console.error('Failed to start server:', error); + process.exit(1); + } console.log(`Simple SSE Server (deprecated protocol version 2024-11-05) listening on port ${PORT}`); }); diff --git a/src/examples/server/simpleStatelessStreamableHttp.ts b/src/examples/server/simpleStatelessStreamableHttp.ts index d235265cd..b5a1e291e 100644 --- a/src/examples/server/simpleStatelessStreamableHttp.ts +++ b/src/examples/server/simpleStatelessStreamableHttp.ts @@ -158,7 +158,11 @@ app.delete('/mcp', async (req: Request, res: Response) => { // Start the server const PORT = 3000; -app.listen(PORT, () => { +app.listen(PORT, (error) => { + if (error) { + console.error('Failed to start server:', error); + process.exit(1); + } console.log(`MCP Stateless Streamable HTTP Server listening on port ${PORT}`); }); diff --git a/src/examples/server/simpleStreamableHttp.ts b/src/examples/server/simpleStreamableHttp.ts index 029fff77a..98f9d351c 100644 --- a/src/examples/server/simpleStreamableHttp.ts +++ b/src/examples/server/simpleStreamableHttp.ts @@ -648,7 +648,11 @@ if (useOAuth && authMiddleware) { app.delete('/mcp', mcpDeleteHandler); } -app.listen(MCP_PORT, () => { +app.listen(MCP_PORT, (error) => { + if (error) { + console.error('Failed to start server:', error); + process.exit(1); + } console.log(`MCP Streamable HTTP Server listening on port ${MCP_PORT}`); }); diff --git a/src/examples/server/sseAndStreamableHttpCompatibleServer.ts b/src/examples/server/sseAndStreamableHttpCompatibleServer.ts index 7b18578a5..e097ca70e 100644 --- a/src/examples/server/sseAndStreamableHttpCompatibleServer.ts +++ b/src/examples/server/sseAndStreamableHttpCompatibleServer.ts @@ -210,7 +210,11 @@ app.post("/messages", async (req: Request, res: Response) => { // Start the server const PORT = 3000; -app.listen(PORT, () => { +app.listen(PORT, (error) => { + if (error) { + console.error('Failed to start server:', error); + process.exit(1); + } console.log(`Backwards compatible MCP server listening on port ${PORT}`); console.log(` ============================================== diff --git a/src/examples/server/standaloneSseWithGetStreamableHttp.ts b/src/examples/server/standaloneSseWithGetStreamableHttp.ts index 8c8c3baaa..279818139 100644 --- a/src/examples/server/standaloneSseWithGetStreamableHttp.ts +++ b/src/examples/server/standaloneSseWithGetStreamableHttp.ts @@ -112,7 +112,11 @@ app.get('/mcp', async (req: Request, res: Response) => { // Start the server const PORT = 3000; -app.listen(PORT, () => { +app.listen(PORT, (error) => { + if (error) { + console.error('Failed to start server:', error); + process.exit(1); + } console.log(`Server listening on port ${PORT}`); });