بناء بوت واتساب لمطعم بكلود AI — دليل عملي كامل

restaurant-bot/
├── src/
│   ├── index.js          # Entry point
│   ├── webhook.js        # WhatsApp webhook handler
│   ├── claude.js         # Claude AI integration
│   ├── whatsapp.js       # WhatsApp message sender
│   ├── database.js       # DB operations
│   ├── orders.js         # Order management
│   └── menu.js           # Menu data & availability
├── .env
├── package.json
└── README.md

mkdir restaurant-bot && cd restaurant-bot
npm init -y
npm install express @anthropic-ai/sdk axios dotenv mysql2 uuid

PORT=3000
ANTHROPIC_API_KEY=sk-ant-xxxxxxxxxxxxxxxxxxxx
WHATSAPP_TOKEN=EAAxxxxxxxxxxxxx
PHONE_NUMBER_ID=123456789012345
WEBHOOK_VERIFY_TOKEN=my_secret_verify_token_2026
DB_HOST=localhost
DB_USER=root
DB_PASSWORD=your_password
DB_NAME=restaurant_bot
PAYMENT_LINK_BASE=https://pay.example.com/order

require('dotenv').config();
const express = require('express');
const { handleWebhook, verifyWebhook } = require('./webhook');

const app = express();
app.use(express.json());

// Webhook verification (GET) - required by Meta
app.get('/webhook', verifyWebhook);

// Incoming messages (POST)
app.post('/webhook', handleWebhook);

app.listen(process.env.PORT, () => {
  console.log(`Bot running on port ${process.env.PORT}`);
});

const { processMessage } = require('./claude');
const { sendMessage } = require('./whatsapp');
const { getConversation, saveConversation } = require('./database');

const verifyWebhook = (req, res) => {
  const mode  = req.query['hub.mode'];
  const token = req.query['hub.verify_token'];
  const challenge = req.query['hub.challenge'];

  if (mode === 'subscribe' && token === process.env.WEBHOOK_VERIFY_TOKEN) {
    res.status(200).send(challenge);
  } else {
    res.sendStatus(403);
  }
};

const handleWebhook = async (req, res) => {
  // Always respond 200 immediately to avoid Meta retries
  res.sendStatus(200);

  try {
    const entry = req.body?.entry?.[0];
    const changes = entry?.changes?.[0];
    const value = changes?.value;

    if (!value?.messages) return; // Status updates, not messages

    const message = value.messages[0];
    const from = message.from; // Customer phone number
    const text = message?.text?.body || '';

    // Load conversation history from DB
    const history = await getConversation(from);

    // Process with Claude
    const { reply, updatedHistory } = await processMessage(from, text, history);

    // Save updated conversation
    await saveConversation(from, updatedHistory);

    // Send reply via WhatsApp
    await sendMessage(from, reply);

  } catch (err) {
    console.error('Webhook error:', err.message);
  }
};

module.exports = { verifyWebhook, handleWebhook };

const Anthropic = require('@anthropic-ai/sdk');
const { getMenuItems, checkAvailability } = require('./menu');
const { createOrder, getOrderStatus } = require('./orders');
const { getCustomerHistory } = require('./database');

const client = new Anthropic({ apiKey: process.env.ANTHROPIC_API_KEY });

const SYSTEM_PROMPT = `أنت "لؤي"، مساعد مطعم "بيت الشاورما" الذكي على واتساب.
شخصيتك: ودود، سريع، محترف، تتحدث بالعامية المصرية المهذبة.

## قواعد أساسية:
- رسائلك قصيرة وواضحة — لا أكثر من 3-4 أسطر في كل رد
- استخدم الإيموجي باعتدال (🍕🎉✅)
- إذا سأل العميل عن صنف غير موجود، اعتذر بلطف واقترح بديلاً
- دائماً تأكد من الطلب قبل طلب الدفع
- لا تذكر أبداً أنك AI أو بوت — أنت "لؤي" فقط

## إجراءات الطلب:
1. عرض القائمة → 2. اختيار الأصناف → 3. تأكيد الطلب → 4. بيانات التوصيل → 5. الدفع → 6. التأكيد

## الأوامر الخاصة:
- "موظف" أو "بشري" → حوّل للمدير
- "قائمة" → أرسل قائمة الأصناف
- "طلبي" + رقم → أعطِ حالة الطلب
- "إلغاء" → ابدأ إجراء الإلغاء`;

const processMessage = async (phone, text, history) => {
  // Add new message to history
  const messages = [
    ...history,
    { role: 'user', content: text }
  ];

  // Get customer purchase history for personalization
  const customerHistory = await getCustomerHistory(phone);
  const systemWithContext = customerHistory.length > 0
    ? `${SYSTEM_PROMPT}\n\n## تاريخ العميل:\n${JSON.stringify(customerHistory.slice(-5))}`
    : SYSTEM_PROMPT;

  const response = await client.messages.create({
    model: 'claude-3-5-sonnet-20241022',
    max_tokens: 500,
    system: systemWithContext,
    messages: messages.slice(-20), // Keep last 20 turns
  });

  const reply = response.content[0].text;

  // Handle special actions detected in response
  await handleActions(phone, text, reply);

  return {
    reply,
    updatedHistory: [...messages, { role: 'assistant', content: reply }]
  };
};

const handleActions = async (phone, userMsg, botReply) => {
  // Detect order confirmation and create order
  if (botReply.includes('رقم طلبك') || botReply.includes('تم تأكيد طلبك')) {
    await createOrder({ phone, message: userMsg });
  }
};

module.exports = { processMessage };

const axios = require('axios');

const WA_URL = `https://graph.facebook.com/v20.0/${process.env.PHONE_NUMBER_ID}/messages`;

const sendMessage = async (to, text) => {
  await axios.post(WA_URL, {
    messaging_product: 'whatsapp',
    to,
    type: 'text',
    text: { body: text }
  }, {
    headers: {
      'Authorization': `Bearer ${process.env.WHATSAPP_TOKEN}`,
      'Content-Type': 'application/json'
    }
  });
};

const sendPaymentLink = async (to, orderId, total) => {
  const payLink = `${process.env.PAYMENT_LINK_BASE}/${orderId}`;
  const msg = `✅ طلبك جاهز للدفع!\n\nالإجمالي: ${total} جنيه\n\n💳 ادفع هنا:\n${payLink}\n\nالرابط صالح لمدة 15 دقيقة`;
  await sendMessage(to, msg);
};

module.exports = { sendMessage, sendPaymentLink };

-- جدول المحادثات
CREATE TABLE conversations (
  phone VARCHAR(20) PRIMARY KEY,
  history JSON NOT NULL,
  updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP
);

-- جدول الطلبات
CREATE TABLE orders (
  id VARCHAR(36) PRIMARY KEY,
  phone VARCHAR(20) NOT NULL,
  items JSON NOT NULL,
  total DECIMAL(10,2) NOT NULL,
  status ENUM('pending','confirmed','preparing','delivering','delivered','cancelled') DEFAULT 'pending',
  address TEXT,
  payment_status ENUM('unpaid','paid') DEFAULT 'unpaid',
  created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);

-- جدول القائمة
CREATE TABLE menu_items (
  id INT AUTO_INCREMENT PRIMARY KEY,
  name VARCHAR(100) NOT NULL,
  category VARCHAR(50),
  price DECIMAL(8,2) NOT NULL,
  available BOOLEAN DEFAULT TRUE,
  description TEXT
);

const mysql = require('mysql2/promise');

const pool = mysql.createPool({
  host: process.env.DB_HOST,
  user: process.env.DB_USER,
  password: process.env.DB_PASSWORD,
  database: process.env.DB_NAME,
  waitForConnections: true,
  connectionLimit: 10
});

const getConversation = async (phone) => {
  const [rows] = await pool.execute(
    'SELECT history FROM conversations WHERE phone = ?', [phone]
  );
  return rows[0] ? JSON.parse(rows[0].history) : [];
};

const saveConversation = async (phone, history) => {
  await pool.execute(
    'INSERT INTO conversations (phone, history) VALUES (?, ?) ON DUPLICATE KEY UPDATE history = ?',
    [phone, JSON.stringify(history), JSON.stringify(history)]
  );
};

const getCustomerHistory = async (phone) => {
  const [rows] = await pool.execute(
    'SELECT items, total, created_at FROM orders WHERE phone = ? AND status = "delivered" ORDER BY created_at DESC LIMIT 10',
    [phone]
  );
  return rows;
};

module.exports = { getConversation, saveConversation, getCustomerHistory, pool };

// في claude.js — بناء context الاقتراحات
const buildRecommendationContext = async (phone) => {
  const history = await getCustomerHistory(phone);
  if (history.length === 0) return '';

  // Count most ordered items
  const itemCounts = {};
  history.forEach(order => {
    const items = JSON.parse(order.items);
    items.forEach(item => {
      itemCounts[item.name] = (itemCounts[item.name] || 0) + item.qty;
    });
  });

  const topItems = Object.entries(itemCounts)
    .sort((a, b) => b[1] - a[1])
    .slice(0, 3)
    .map(([name]) => name);

  return `
## تفضيلات هذا العميل (استخدم للاقتراحات):
- أكثر الأصناف طلباً: ${topItems.join(', ')}
- عدد الطلبات السابقة: ${history.length}
- متوسط الفاتورة: ${Math.round(history.reduce((a,b) => a + parseFloat(b.total), 0) / history.length)} جنيه
- اقترح هذه الأصناف عند المناسبة بشكل طبيعي في المحادثة
`;
};

const buildOffersContext = async (phone) => {
  const [rows] = await pool.execute(
    'SELECT created_at FROM orders WHERE phone = ? ORDER BY created_at DESC LIMIT 1',
    [phone]
  );

  if (rows.length === 0) {
    return '## عرض خاص: هذا أول طلب للعميل — اعرض خصم 15% على الطلب الأول كود: WELCOME15';
  }

  const daysSinceLast = Math.floor(
    (Date.now() - new Date(rows[0].created_at)) / 86400000
  );

  if (daysSinceLast >= 14) {
    return `## عرض خاص: العميل لم يطلب منذ ${daysSinceLast} يوم — اعرض عليه "اشتقنالك! خصم 20% طلبتك الجاية" كود: WELCOME_BACK20`;
  }

  return '';
};

# Install Railway CLI
npm install -g @railway/cli

# Login and init
railway login
railway init

# Add MySQL database
railway add --plugin mysql

# Set environment variables
railway variables set ANTHROPIC_API_KEY=sk-ant-xxx
railway variables set WHATSAPP_TOKEN=EAAxxxx
railway variables set PHONE_NUMBER_ID=12345
railway variables set WEBHOOK_VERIFY_TOKEN=my_secret

# Deploy
railway up

# Get your URL (use this as Webhook URL in Meta)
railway domain

npm install -g pm2

# Start bot with auto-restart
pm2 start src/index.js --name restaurant-bot

# Auto-start on server reboot
pm2 startup
pm2 save

# Monitor logs in real-time
pm2 logs restaurant-bot

# Restart after code update
pm2 restart restaurant-bot