Function runServer

scripts/cli.ts:60–131

(port: number | null)

}

async function runServer(port: number | null) {
    if (port !== null) {
        const app = express();

        let servers: Server[] = [];

        app.get('/sse', async (req, res) => {
            console.log('Got new SSE connection');

            const transport = new SSEServerTransport('/message', res);
            const server = new Server(
                {
                    name: 'mcp-typescript test server',
                    version: '0.1.0'
                },
                {
                    capabilities: {}
                }
            );

            servers.push(server);

            server.onclose = () => {
                console.log('SSE connection closed');
                servers = servers.filter(s => s !== server);
            };

            await server.connect(transport);
        });

        app.post('/message', async (req, res) => {
            console.log('Received message');

            const sessionId = req.query.sessionId as string;
            const transport = servers.map(s => s.transport as SSEServerTransport).find(t => t.sessionId === sessionId);
            if (!transport) {
                res.status(404).send('Session not found');
                return;
            }

            await transport.handlePostMessage(req, res);
        });

        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 {
        const server = new Server(
            {
                name: 'mcp-typescript test server',
                version: '0.1.0'
            },
            {
                capabilities: {