مقدمة في بروتوكول سياق النموذج (MCP)

mkdir weather
cd weather
npm init -y

npm install @modelcontextprotocol/sdk zod
npm install -D @types/node typescript

mkdir src
touch src/index.ts

{
  "type": "module",
  "bin": {
    "weather": "./build/index.js"
  },
  "scripts": {
    "build": "tsc && node -e \"require('fs').chmodSync('build/index.js', '755')\""
  },
  "files": [
    "build"
  ]
}

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 NWS_API_BASE = "https://api.weather.gov";
const USER_AGENT = "weather-app/1.0";
 
const AlertsArgumentsSchema = z.object({
  state: z.string().length(2),
});
 
const ForecastArgumentsSchema = z.object({
  latitude: z.number().min(-90).max(90),
  longitude: z.number().min(-180).max(180),
});
 
const server = new Server(
  {
    name: "weather",
    version: "1.0.0",
  },
  {
    capabilities: {
      tools: {},
    },
  }
);

server.setRequestHandler(ListToolsRequestSchema, async () => {
  return {
    tools: [
      {
        name: "get-alerts",
        description: "الحصول على تنبيهات الطقس لولاية",
        inputSchema: {
          type: "object",
          properties: {
            state: {
              type: "string",
              description: "رمز الولاية من حرفين (مثال CA، NY)",
            },
          },
          required: ["state"],
        },
      },
      {
        name: "get-forecast",
        description: "الحصول على توقعات الطقس لموقع",
        inputSchema: {
          type: "object",
          properties: {
            latitude: {
              type: "number",
              description: "خط العرض للموقع",
            },
            longitude: {
              type: "number",
              description: "خط الطول للموقع",
            },
          },
          required: ["latitude", "longitude"],
        },
      },
    ],
  };
});

async function main() {
  const transport = new StdioServerTransport();
  await server.connect(transport);
  console.error("خادم MCP للطقس يعمل على stdio");
}
 
main().catch((error) => {
  console.error("خطأ فادح في main():", error);
  process.exit(1);
});

const { ClientSession, StdioServerParameters } = require('@modelcontextprotocol/sdk');
const { stdio_client } = require('@modelcontextprotocol/sdk/client/stdio');
 
async function connectToServer(serverScriptPath) {
  const serverParams = new StdioServerParameters({
    command: 'node',
    args: [serverScriptPath],
  });
 
  const transport = await stdio_client(serverParams);
  const session = new ClientSession(transport.stdio, transport.write);
 
  await session.initialize();
  return session;
}
 
async function main() {
  const session = await connectToServer('./build/index.js');
  const response = await session.listTools();
  console.log('الأدوات المتاحة:', response.tools);
}
 
main();