كيف تبني وكيل ذكاء اصطناعي متعدد المنصات باستخدام Vercel Chat SDK

npx create-next-app@latest my-agent --typescript --app
cd my-agent

pnpm add ai @ai-sdk/anthropic chat @chat-adapter/slack @chat-adapter/telegram @chat-adapter/whatsapp @chat-adapter/state-redis

# .env.local
 
# AI
ANTHROPIC_API_KEY=sk-ant-...
 
# State (Redis)
REDIS_URL=redis://...
 
# Slack
SLACK_BOT_TOKEN=xoxb-...
SLACK_SIGNING_SECRET=...
 
# Telegram
TELEGRAM_BOT_TOKEN=...
 
# WhatsApp
WHATSAPP_ACCESS_TOKEN=...
WHATSAPP_VERIFY_TOKEN=...
WHATSAPP_PHONE_NUMBER_ID=...

import { Chat } from "chat";
import { createSlackAdapter } from "@chat-adapter/slack";
import { createTelegramAdapter } from "@chat-adapter/telegram";
import { createWhatsAppAdapter } from "@chat-adapter/whatsapp";
import { createRedisState } from "@chat-adapter/state-redis";
 
export const bot = new Chat({
  userName: "my-agent",
  adapters: {
    slack: createSlackAdapter(),
    telegram: createTelegramAdapter(),
    whatsapp: createWhatsAppAdapter(),
  },
  state: createRedisState(),
});

import { streamText } from "ai";
import { anthropic } from "@ai-sdk/anthropic";
 
const SYSTEM_PROMPT = `You are a helpful assistant deployed across multiple
communication platforms. Be concise and direct. When answering questions,
focus on being actionable rather than verbose.`;
 
// عندما يذكر شخص الوكيل في محادثة جديدة
bot.onNewMention(async (thread, message) => {
  await thread.subscribe();
  await thread.startTyping();
 
  const result = streamText({
    model: anthropic("claude-sonnet-4-6"),
    system: SYSTEM_PROMPT,
    messages: [{ role: "user", content: message.text }],
  });
 
  // نشر البث مباشرة — Chat SDK يتعامل مع
  // التحديثات المجزأة والتنسيق الأصلي لكل منصة
  await thread.post(result.fullStream);
});
 
// عندما يرد شخص في محادثة يراقبها الوكيل
bot.onSubscribedMessage(async (thread, message) => {
  if (message.author.isBot) return;
 
  await thread.startTyping();
 
  // بناء سجل المحادثة من المحادثة
  const history: Array<{ role: "user" | "assistant"; content: string }> = [];
  for await (const msg of thread.messages) {
    history.push({
      role: msg.author.isBot ? "assistant" : "user",
      content: msg.text,
    });
  }
 
  const result = streamText({
    model: anthropic("claude-sonnet-4-6"),
    system: SYSTEM_PROMPT,
    messages: history,
  });
 
  await thread.post(result.fullStream);
});

// app/api/slack/route.ts
import { bot } from "@/lib/bot";
 
export async function POST(request: Request) {
  return bot.webhooks.slack(request);
}

// app/api/telegram/route.ts
import { bot } from "@/lib/bot";
 
export async function POST(request: Request) {
  return bot.webhooks.telegram(request);
}

// app/api/whatsapp/route.ts
import { bot } from "@/lib/bot";
 
export async function GET(request: Request) {
  // التحقق من webhook WhatsApp
  return bot.webhooks.whatsapp(request);
}
 
export async function POST(request: Request) {
  return bot.webhooks.whatsapp(request);
}

const platformInstructions: Record<string, string> = {
  slack:
    "Use Slack markdown: *bold*, `code`, ```code blocks```. Use threaded replies naturally.",
  telegram:
    "Use Telegram markdown: **bold**, `code`, ```code blocks```. Keep responses focused and under 4096 characters.",
  whatsapp:
    "Keep responses short and concise. No code blocks. Use *bold* sparingly. Break long responses into short paragraphs.",
};
 
bot.onNewMention(async (thread, message) => {
  await thread.subscribe();
  await thread.startTyping();
 
  const adapterName = thread.adapter.name;
 
  const result = streamText({
    model: anthropic("claude-sonnet-4-6"),
    system: `${SYSTEM_PROMPT}\n\nFormatting: ${platformInstructions[adapterName] ?? "Be concise."}`,
    messages: [{ role: "user", content: message.text }],
  });
 
  await thread.post(result.fullStream);
});

import { streamText, tool, stepCountIs } from "ai";
import { anthropic } from "@ai-sdk/anthropic";
import { z } from "zod";
 
const tools = {
  getTopStories: tool({
    description: "Get the current top stories from Hacker News",
    inputSchema: z.object({
      count: z
        .number()
        .min(1)
        .max(10)
        .default(5)
        .describe("Number of stories to return"),
    }),
    execute: async ({ count }) => {
      const idsRes = await fetch(
        "https://hacker-news.firebaseio.com/v0/topstories.json",
      );
      const ids = (await idsRes.json()).slice(0, count);
 
      const stories = await Promise.all(
        ids.map(async (id: number) => {
          const res = await fetch(
            `https://hacker-news.firebaseio.com/v0/item/${id}.json`,
          );
          const story = await res.json();
          return {
            title: story.title,
            url: story.url,
            score: story.score,
            by: story.by,
          };
        }),
      );
 
      return { stories };
    },
  }),
};
 
bot.onNewMention(async (thread, message) => {
  await thread.subscribe();
  await thread.startTyping();
 
  const result = streamText({
    model: anthropic("claude-sonnet-4-6"),
    system: SYSTEM_PROMPT,
    messages: [{ role: "user", content: message.text }],
    tools,
    stopWhen: stepCountIs(3),
  });
 
  // fullStream يتعامل مع خطوات استدعاء الأدوات الوسيطة تلقائياً
  await thread.post(result.fullStream);
});

pnpm build