Function createTestServerWithSse

test/server/sse.test.ts:112–153

* Helper to create and start test HTTP server with MCP setup

(args: { mockRes: http.ServerResponse })

     * Helper to create and start test HTTP server with MCP setup
     */
    async function createTestServerWithSse(args: { mockRes: http.ServerResponse }): Promise<{
        server: Server;
        transport: SSEServerTransport;
        mcpServer: McpServer;
        baseUrl: URL;
        sessionId: string;
        serverPort: number;
    }> {
        const mcpServer = new McpServer({ name: 'test-server', version: '1.0.0' }, { capabilities: { logging: {} } });

        mcpServer.tool(
            'greet',
            'A simple greeting tool',
            { name: z.string().describe('Name to greet') },
            async ({ name }): Promise<CallToolResult> => {
                return { content: [{ type: 'text', text: `Hello, ${name}!` }] };
            }
        );

        const endpoint = '/messages';

        const transport = new SSEServerTransport(endpoint, args.mockRes);
        const sessionId = transport.sessionId;

        await mcpServer.connect(transport);

        const server = createServer(async (req, res) => {
            try {
                await transport.handlePostMessage(req, res);
            } catch (error) {
                console.error('Error handling request:', error);
                if (!res.headersSent) res.writeHead(500).end();
            }
        });

        const baseUrl = await listenOnRandomPort(server);

        const addr = server.address();
        const port = typeof addr === 'string' ? new URL(baseUrl).port : (addr as any).port;

        return { server, transport, mcpServer, baseUrl, sessionId, serverPort: Number(port) };
    }

    describe('SSEServerTransport', () => {
        async function initializeServer(baseUrl: URL): Promise<void> {