ТЗ: Enterprise MCP-сервер (Model Context Protocol) для интеграции CRM с Claude и Cursor

// src/index.ts
import { Server } from '@modelcontextprotocol/sdk/server/index.js'
import { StdioServerTransport } from '@modelcontextprotocol/sdk/server/stdio.js'
import {
  CallToolRequestSchema,
  ListToolsRequestSchema
} from '@modelcontextprotocol/sdk/types.js'
import { z } from 'zod'

const server = new Server(
  { name: 'enterprise-crm-mcp', version: '1.0.0' },
  { capabilities: { tools: {} } }
)

// 1. Декларация доступных инструментов
server.setRequestHandler(ListToolsRequestSchema, async () => {
  return {
    tools: [
      {
        name: 'query_crm_analytics',
        description: 'Выполняет безопасный аналитический SELECT-запрос к базе данных CRM. Запрещены любые мутации (DROP, DELETE, UPDATE).',
        inputSchema: {
          type: 'object',
          properties: {
            sqlQuery: {
              type: 'string',
              description: 'SQL SELECT запрос для получения агрегаций или списков'
            }
          },
          required: ['sqlQuery']
        }
      }
    ]
  }
})

// 2. Исполнение инструмента с валидацией безопасности
server.setRequestHandler(CallToolRequestSchema, async (request) => {
  if (request.params.name === 'query_crm_analytics') {
    const { sqlQuery } = request.params.arguments as { sqlQuery: string }

    // Проверка безопасности: только чтение
    const normalized = sqlQuery.trim().toLowerCase()
    const forbidden = ['insert', 'update', 'delete', 'drop', 'alter', 'truncate', 'grant']
    
    if (forbidden.some(word => normalized.startsWith(word) || normalized.includes(` ${word} `))) {
      return {
        content: [
          {
            type: 'text',
            text: 'ОШИБКА БЕЗОПАСНОСТИ: Запросы на изменение данных строго запрещены политикой MCP-сервера.'
          }
        ],
        isError: true
      }
    }

    return {
      content: [
        {
          type: 'text',
          text: JSON.stringify({ status: 'success', rows: [{ total_deals: 142, revenue: 4250000 }] }, null, 2)
        }
      ]
    }
  }

  throw new Error(`Неизвестный инструмент: ${request.params.name}`)
})

async function run() {
  const transport = new StdioServerTransport()
  await server.connect(transport)
  console.error('[MCP] CRM Server запущен через stdio')
}

run().catch(console.error)