mcp-hello-world

import { spawn } from 'child_process'; // Assume './my-mcp-client' is your custom client implementation // that connects to stdin/stdout streams. import { MCPClient } from './my-mcp-client'; describe('My MCP Client (STDIO mode)', () => { let mcpServerProcess: ReturnType<typeof spawn>; let client: MCPClient; // Assume MCPClient accepts Readable/Writable streams beforeAll(() => { // Start mcp-hello-world as a child process in STDIO mode mcpServerProcess = spawn('npx', ['mcp-hello-world']); // Instantiate your client and connect it to the spawned process's stdio streams client = new MCPClient(mcpServerProcess.stdin, mcpServerProcess.stdout); // Optional: Log server output for debugging purposes mcpServerProcess.stdout.on('data', (data) => console.log(`MCP Server STDOUT: ${data}`)); mcpServerProcess.stderr.on('data', (data) => console.error(`MCP Server STDERR: ${data}`)); }); afterAll(() => { // Ensure the server process is terminated after all tests are done if (mcpServerProcess) { mcpServerProcess.kill(); } }); it('should receive an echo response from the mock server', async () => { const request = { jsonrpc: '2.0', id: 1, method: 'tools/invoke', params: { name: 'echo', parameters: { message: 'hello test' } } }; // Assuming client.sendRequest handles JSON-RPC messaging over streams const response = await client.sendRequest(request); expect(response).toEqual({ jsonrpc: '2.0', id: 1, result: { content: [{ type: 'text', text: 'Hello hello test' }] } }); }); });