MCPサーバー実装まとめ

src/
├── handlers/         # 各ツールのハンドラー関数
│   ├── create-memo.ts
│   └── index.ts
├── services/         # 外部APIとの通信を担当
│   ├── api-service.ts
│   └── index.ts
├── types/            # 型定義
│   ├── create-memo.ts
│   └── index.ts
├── utils/            # ユーティリティ関数
│   └── error-handler.ts
├── tool.ts           # ツール定義
├── server.ts         # サーバー設定
└── index.ts          # エントリーポイント

import { Server } from '@modelcontextprotocol/sdk/server/index.js';
import { StdioServerTransport } from '@modelcontextprotocol/sdk/server/stdio.js';

export class MCPServer {
  private server: Server;

  constructor() {
    // 環境変数から設定を取得
    const apiKey = process.env.API_KEY;
    
    // サーバーの初期化
    this.server = new Server(
      { name: 'my-mcp-server', version: '1.0.0' },
      { capabilities: { tools: {} } }
    );
    
    // ツールとエラーハンドリングのセットアップ
    setupTools(this.server, apiKey);
    setupErrorHandling(this.server);
  }

  async run(): Promise<void> {
    const transport = new StdioServerTransport();
    await this.server.connect(transport);
  }
}

server.setRequestHandler(
  ListToolsRequestSchema,
  async () => ({
    tools: [{
      name: "service_action_name",
      description: "ツールの説明文",
      inputSchema: {
        type: "object",
        properties: {
          param1: {
            type: "string",
            description: "パラメータ1の説明"
          },
          // 他のパラメータ...
        },
        required: ["param1"]
      }
    }]
  })
);

// ツール呼び出しハンドラー
server.setRequestHandler(
  CallToolRequestSchema,
  async (request) => {
    switch (request.params.name) {
      case "service_action_name":
        return await handleAction(request.params.arguments);
      default:
        return { content: [{ type: "text", text: "未知のツール" }], isError: true };
    }
  }
);

async function handleAction(args: Record<string, unknown> | undefined) {
  // 1. パラメータの検証
  if (!args || typeof args.param1 !== 'string') {
    return {
      content: [{ type: 'text', text: "パラメータが不正です" }],
      isError: true
    };
  }

  // 2. パラメータの構築
  const params = {
    param1: args.param1,
    // オプションパラメータの処理
    param2: typeof args.param2 === 'boolean' ? args.param2 : false
  };

  try {
    // 3. APIリクエスト
    const result = await apiService.callAction(params);
    
    // 4. 結果の処理
    if (!result.success) {
      return {
        content: [{ type: 'text', text: `エラー: ${result.error}` }],
        isError: true
      };
    }
    
    // 5. 成功レスポンス
    return {
      content: [{ type: 'text', text: "処理が完了しました" }]
    };
  } catch (error) {
    // 6. エラーハンドリング
    return {
      content: [{ type: 'text', text: `例外が発生: ${error.message}` }],
      isError: true
    };
  }
}

# 環境変数を設定してサーバーを起動
API_KEY=your_key npm run dev

console.error('デバッグ:', JSON.stringify(data, null, 2));

echo '{"jsonrpc":"2.0","id":"test","method":"mcp.listTools","params":{}}' | node dist/index.js

server.onerror = (error) => {
  console.error('[MCP Error]', error);
};

process.on('uncaughtException', (error) => {
  console.error('未捕捉の例外:', error);
});

{
  content: [{ type: 'text', text: 'エラーメッセージ' }],
  isError: true
}

"mcpServers": {
  "service_name": {
    "command": "node",
    "args": ["path/to/dist/index.js"],
    "env": {
      "API_KEY": "your_api_key"
    }
  }
}

"ai.mcpServers": [
  {
    "name": "service_name",
    "command": "node",
    "args": ["path/to/dist/index.js"],
    "env": { "API_KEY": "your_api_key" }
  }
]