freee__freee-mcp/scripts/test-mcp.js

#!/usr/bin/env node

/**
 * MCP Server 動作確認スクリプト
 * freee MCP serverのツールをテストするためのスクリプト
 */

import { spawn } from 'child_process';
import { createInterface } from 'readline';

// MCP メッセージを送信するヘルパー関数
function sendMcpMessage(process, message) {
  const jsonMessage = JSON.stringify(message);
  console.log(`\n📤 送信: ${jsonMessage}`);
  process.stdin.write(jsonMessage + '\n');
}

// MCP リクエストIDを生成
let requestId = 1;
function getNextRequestId() {
  return requestId++;
}

async function testMcpTools() {
  console.log('🚀 freee MCP Server 動作確認を開始します...\n');

  // MCP serverプロセスを起動
  const mcpProcess = spawn('bun', ['run', 'src/index.ts'], {
    stdio: 'pipe',
    cwd: process.cwd()
  });

  // 標準出力の監視
  mcpProcess.stdout.on('data', (data) => {
    console.log(`📥 受信: ${data.toString().trim()}`);
  });

  // 標準エラー出力の監視（ログ用）
  mcpProcess.stderr.on('data', (data) => {
    console.log(`📋 ログ: ${data.toString().trim()}`);
  });

  // プロセス終了時の処理
  mcpProcess.on('exit', (code) => {
    console.log(`\n🏁 MCP Server プロセスが終了しました (コード: ${code})`);
  });

  // 少し待ってからテスト開始
  await new Promise(resolve => setTimeout(resolve, 2000));

  console.log('\n=== MCP 初期化テスト ===');

  // 1. Initialize request
  sendMcpMessage(mcpProcess, {
    jsonrpc: '2.0',
    id: getNextRequestId(),
    method: 'initialize',
    params: {
      protocolVersion: '2024-11-05',
      capabilities: {
        tools: {}
      },
      clientInfo: {
        name: 'freee-mcp-test-client',
        version: '1.0.0'
      }
    }
  });

  await new Promise(resolve => setTimeout(resolve, 1000));

  // 2. List tools
  console.log('\n=== 利用可能ツール一覧取得 ===');
  sendMcpMessage(mcpProcess, {
    jsonrpc: '2.0',
    id: getNextRequestId(),
    method: 'tools/list',
    params: {}
  });

  await new Promise(resolve => setTimeout(resolve, 1000));

  // 3. Test freee_list_companies tool
  console.log('\n=== freee_list_companies ツールテスト ===');
  sendMcpMessage(mcpProcess, {
    jsonrpc: '2.0',
    id: getNextRequestId(),
    method: 'tools/call',
    params: {
      name: 'freee_list_companies',
      arguments: {}
    }
  });

  await new Promise(resolve => setTimeout(resolve, 2000));

  // 4. Test freee_auth_status tool
  console.log('\n=== freee_auth_status ツールテスト ===');
  sendMcpMessage(mcpProcess, {
    jsonrpc: '2.0',
    id: getNextRequestId(),
    method: 'tools/call',
    params: {
      name: 'freee_auth_status',
      arguments: {}
    }
  });

  await new Promise(resolve => setTimeout(resolve, 2000));

  // 5. Test freee_current_user tool
  console.log('\n=== freee_current_user ツールテスト ===');
  sendMcpMessage(mcpProcess, {
    jsonrpc: '2.0',
    id: getNextRequestId(),
    method: 'tools/call',
    params: {
      name: 'freee_current_user',
      arguments: {}
    }
  });

  await new Promise(resolve => setTimeout(resolve, 2000));

  // インタラクティブモード
  console.log('\n=== インタラクティブモード ===');
  console.log('ツール名を入力してテストしてください（例: freee_current_user）');
  console.log('終了するには "exit" と入力してください\n');

  const rl = createInterface({
    input: process.stdin,
    output: process.stdout
  });

  const askForTool = () => {
    rl.question('ツール名を入力 > ', (toolName) => {
      if (toolName.toLowerCase() === 'exit') {
        console.log('\n👋 テスト終了');
        mcpProcess.kill();
        rl.close();
        process.exit(0);
      }

      if (toolName.trim()) {
        console.log(`\n=== ${toolName} ツールテスト ===`);
        sendMcpMessage(mcpProcess, {
          jsonrpc: '2.0',
          id: getNextRequestId(),
          method: 'tools/call',
          params: {
            name: toolName,
            arguments: {}
          }
        });
        
        setTimeout(() => {
          askForTool();
        }, 2000);
      } else {
        askForTool();
      }
    });
  };

  askForTool();
}

// エラーハンドリング
process.on('uncaughtException', (error) => {
  console.error('❌ 未処理の例外:', error);
});

process.on('unhandledRejection', (reason, promise) => {
  console.error('❌ 未処理のPromise拒否:', reason);
});

// テスト開始
testMcpTools().catch(console.error);