Method connectStdio

src/mcp/client/MCPClient.ts:270–301

* Stdio 连接

(config: MCPConnectionConfig)

   * Stdio 连接
   */
  private async connectStdio(config: MCPConnectionConfig): Promise<any> {
    const { spawn } = await import('child_process');

    if (!config.command) {
      throw new Error('Command is required for stdio transport');
    }

    const childProcess = spawn(config.command, config.args || [], {
      stdio: ['pipe', 'pipe', 'pipe'],
      env: { ...process.env, ...config.env },
    });

    return new Promise((resolve, reject) => {
      const timeout = setTimeout(() => {
        reject(new Error('Process start timeout'));
      }, config.timeout || 10000);

      childProcess.on('spawn', () => {
        clearTimeout(timeout);
        resolve(childProcess);
      });

      childProcess.on('error', (error: Error) => {
        clearTimeout(timeout);
        reject(error);
      });

      childProcess.stdout?.on('data', (data: Buffer) => {
        this.handleMessage(data.toString());
      });
    });
  }

  /**
   * 处理消息