MCP — Model Context Protocol

// Три примитива MCP

// 1. Tools — функции, которые LLM может вызвать
//    (аналог function calling, но через протокол)
server.tool("send_email", "Отправляет email", {
  to: z.string(),
  subject: z.string(),
  body: z.string()
}, async (args) => {
  await sendEmail(args)
  return { content: [{ type: "text", text: "Отправлено" }] }
})

// 2. Resources — данные, которые агент может прочитать
//    (статические или динамические, по URI)
server.resource("schema", "db://users/schema", async (uri) => ({
  contents: [{
    uri: uri.href,
    mimeType: "application/json",
    text: JSON.stringify(usersSchema)
  }]
}))

// 3. Prompts — шаблоны промптов, переиспользуемые
//    (агент может загрузить готовый промпт с сервера)
server.prompt("code-review", async () => ({
  messages: [{
    role: "user",
    content: { type: "text", text: "Проверь код на ошибки и уязвимости..." }
  }]
}))

// Два транспорта MCP

// 1. stdio — для локальных серверов (CLI-инструменты, скрипты)
import { StdioServerTransport } from ".../stdio.js"
const transport = new StdioServerTransport()
// ↓ JSON-RPC сообщения идут через stdin/stdout процесса

// 2. Streamable HTTP — для удалённых серверов (веб-сервисы)
import { StreamableHTTPServerTransport } from ".../streamableHttp.js"
const transport = new StreamableHTTPServerTransport({
  sessionIdGenerator: () => crypto.randomUUID(),
})
// ↓ JSON-RPC сообщения идут через HTTP POST + SSE
//   Клиент: POST /mcp → ответ
//   Сервер: SSE-стрим для уведомлений

// MCP Server на TypeScript SDK
import { McpServer } from "@modelcontextprotocol/sdk/server/mcp.js"
import { StdioServerTransport } from "@modelcontextprotocol/sdk/server/stdio.js"
import { z } from "zod"

const server = new McpServer({
  name: "filesystem-server",
  version: "1.0.0",
})

// Tool: читать файл
server.tool(
  "read_file",
  "Читает содержимое файла по пути",
  { path: z.string().describe("Абсолютный путь к файлу") },
  async ({ path }) => {
    const content = await fs.readFile(path, "utf-8")
    return { content: [{ type: "text", text: content }] }
  }
)

// Tool: список файлов в директории
server.tool(
  "list_files",
  "Возвращает список файлов в директории",
  { dir: z.string().describe("Путь к директории") },
  async ({ dir }) => {
    const files = await fs.readdir(dir)
    return { content: [{ type: "text", text: files.join("\n") }] }
  }
)

// Resource: метаданные сервера
server.resource(
  "server-info",
  "info://server",
  async (uri) => ({
    contents: [{
      uri: uri.href,
      mimeType: "application/json",
      text: JSON.stringify({ name: "filesystem-server", tools: 2 })
    }]
  })
)

// Запуск через stdio-транспорт
const transport = new StdioServerTransport()
await server.connect(transport)

// MCP Client — внутри агента
import { Client } from "@modelcontextprotocol/sdk/client/index.js"
import { StdioClientTransport } from "@modelcontextprotocol/sdk/client/stdio.js"

// 1. Подключаемся к MCP-серверу
const transport = new StdioClientTransport({
  command: "node",
  args: ["filesystem-server.js"],
})

const client = new Client({
  name: "my-agent",
  version: "1.0.0",
})
await client.connect(transport)

// 2. Discovery — узнаём, что умеет сервер
const { tools } = await client.listTools()
console.log(tools)
// → [
//   { name: "read_file",  description: "Читает файл",  inputSchema: {...} },
//   { name: "list_files", description: "Список файлов", inputSchema: {...} }
// ]

// 3. Преобразуем MCP-tools в формат function calling для LLM
const llmTools = tools.map(t => ({
  type: "function",
  function: {
    name: t.name,
    description: t.description,
    parameters: t.inputSchema,
  },
}))

// 4. LLM выбирает инструмент
const response = await llm.chat(messages, llmTools)
const toolCall = response.tool_calls[0]

// 5. Вызываем инструмент через MCP
const result = await client.callTool({
  name: toolCall.function.name,
  arguments: JSON.parse(toolCall.function.arguments),
})

// 6. Результат — обратно в LLM
messages.push({ role: "tool", content: result.content[0].text })
const final = await llm.chat(messages)