Custom MCP Client Integration

import { Client } from '@modelcontextprotocol/sdk/client/index.js';
import { StdioClientTransport } from '@modelcontextprotocol/sdk/client/stdio.js';
import { spawn } from 'child_process';

class FinMCPClient {
  private client: Client;
  private serverProcess: any;
  private transport: StdioClientTransport;

  async connect() {
    // Spawn the FinMCP server
    this.serverProcess = spawn('npx', ['-y', 'finmcp'], {
      stdio: ['pipe', 'pipe', 'pipe'],
      env: process.env
    });

    // Optionally log server errors
    this.serverProcess.stderr.on('data', (data: Buffer) => {
      console.error('FinMCP Server:', data.toString());
    });

    // Create transport
    this.transport = new StdioClientTransport({
      stdin: this.serverProcess.stdin,
      stdout: this.serverProcess.stdout,
      stderr: this.serverProcess.stderr
    });

    // Initialize client
    this.client = new Client({
      name: 'finmcp-custom-client',
      version: '1.0.0'
    }, {
      capabilities: {}
    });

    // Connect to server
    await this.client.connect(this.transport);
    console.log('Connected to FinMCP server');
  }

  async listTools() {
    const response = await this.client.listTools();
    return response.tools;
  }

  async getStockPrice(symbol: string) {
    const result = await this.client.callTool({
      name: 'get_stock_price',
      arguments: { symbol }
    });
    return result;
  }

  async getHistoricalData(symbol: string, period: string) {
    const result = await this.client.callTool({
      name: 'get_historical_data',
      arguments: { symbol, period }
    });
    return result;
  }

  async close() {
    await this.client.close();
    this.serverProcess.kill();
    console.log('Disconnected from FinMCP server');
  }
}

// Usage example
async function main() {
  const finmcp = new FinMCPClient();
  
  try {
    await finmcp.connect();
    
    // List available tools
    const tools = await finmcp.listTools();
    console.log('Available tools:', tools.map(t => t.name));
    
    // Get stock price
    const price = await finmcp.getStockPrice('AAPL');
    console.log('AAPL price:', price);
    
    // Get historical data
    const history = await finmcp.getHistoricalData('TSLA', '1mo');
    console.log('TSLA history:', history);
    
  } finally {
    await finmcp.close();
  }
}

main().catch(console.error);