Model Context Protocol (MCP) in Practice: Building Tool Servers

[ AI Agent / IDE Host ] <--- (JSON-RPC 2.0 over STDIO) ---> [ MCP Server (Node.js) ]
     (MCP Client)                                                  |
          |                                                +-------+-------+
     - Capability Handshake                                |               |
     - CallTool(name, args)                          [ PostgreSQL ]   [ File System ]
     - ReadResource(uri)

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-DevOps-MCP", version: "1.0.0" },
  { capabilities: { tools: {}, resources: {} } }
);

// Схема валидации входных параметров инструмента через Zod
const GetWeatherInputSchema = z.object({
  city: z.string().min(1, "Название города обязательно для заполнения"),
  units: z.enum(["celsius", "fahrenheit"]).default("celsius"),
});

// 1. Декларация доступных инструментов
server.setRequestHandler(ListToolsRequestSchema, async () => {
  return {
    tools: [
      {
        name: "get_weather_telemetry",
        description: "Получить актуальную метеорологическую телеметрию для указанного города",
        inputSchema: {
          type: "object",
          properties: {
            city: { type: "string", description: "Название города" },
            units: { type: "string", enum: ["celsius", "fahrenheit"], description: "Единицы измерения" }
          },
          required: ["city"]
        }
      }
    ]
  };
});

// 2. Обработка вызовов инструментов с валидацией схемы
server.setRequestHandler(CallToolRequestSchema, async (request) => {
  if (request.params.name === "get_weather_telemetry") {
    const parseResult = GetWeatherInputSchema.safeParse(request.params.arguments);
    
    if (!parseResult.success) {
      return {
        content: [{ type: "text", text: `Ошибка валидации: ${parseResult.error.message}` }],
        isError: true,
      };
    }

    const { city, units } = parseResult.data;
    const temperature = units === "celsius" ? "21°C" : "70°F";
    const telemetry = `Погода в ${city}: ${temperature}, переменная облачность, влажность 45%.`;
    
    return {
      content: [{ type: "text", text: telemetry }],
      isError: false
    };
  }

  throw new Error(`Запрошенный инструмент не найден: ${request.params.name}`);
});

// 3. Запуск STDIO транспорта
async function main() {
  const transport = new StdioServerTransport();
  await server.connect(transport);
  
  // ВАЖНО: Все логи пишутся строго в stderr, чтобы не коррумпировать stdout JSON-RPC поток!
  console.error("MCP Server successfully started on STDIO transport");
}

main().catch((err) => {
  console.error("Fatal MCP Server Error:", err);
  process.exit(1);
});