server.integration.test.ts — mcp Source File

Source Code

/**
 * Integration tests for the MCP server.
 * Tests the JSON-RPC protocol, tool listing, and basic operations.
 */

import { describe, it, expect, beforeAll, afterAll } from '@jest/globals';
import { spawn, ChildProcess } from 'child_process';
import { existsSync } from 'fs';
import * as readline from 'readline';
import * as path from 'path';

const SERVER_STARTUP_TIMEOUT_MS = 5000;
const STARTUP_POLL_INTERVAL_MS = 100;

describe('MCP Server Integration', () => {
  let server: ChildProcess;
  let requestId = 0;
  let responseQueue: Map<number, { resolve: (value: any) => void; reject: (err: Error) => void }> = new Map();
  let rl: readline.Interface;

  function sendRequest(method: string, params: Record<string, unknown> = {}): Promise<any> {
    return new Promise((resolve, reject) => {
      const id = ++requestId;
      const request = {
        jsonrpc: '2.0',
        id,
        method,
        params
      };
      responseQueue.set(id, { resolve, reject });
      server.stdin!.write(JSON.stringify(request) + '\n');

      setTimeout(() => {
        if (responseQueue.has(id)) {
          responseQueue.delete(id);
          reject(new Error(`Request ${method} timed out`));
        }
      }, 5000);
    });
  }

  beforeAll(async () => {
    const distPath = path.join(__dirname, '..', 'dist', 'index.js');
    if (!existsSync(distPath)) {
      throw new Error(
        `Server build not found at ${distPath}. Run 'npm run build' first.`
      );
    }

    server = spawn('node', [distPath, '--no-api-fallback'], {
      stdio: ['pipe', 'pipe', 'pipe'],
      env: { ...process.env }
    });

    server.on('error', (err) => {
      throw new Error(`Failed to start MCP server: ${err.message}`);
    });

    rl = readline.createInterface({
      input: server.stdout!,
// ... (135 more lines)