Final: Clean bot structure with Cloudflare Worker proxy and voice support & Add Messenger bot webhook endpoint

main.py

@@ -16,6 +16,10 @@ from api.endpoints import router as api_router
 from api.auth import fastapi_users, auth_backend, current_active_user, get_auth_router 
 from utils.telegram_bot import router as telegram_router
 
+from utils.whatsapp_bot import router as whatsapp_router
+from utils.messenger_bot import router as messenger_router
+
+
 from api.database import User, Conversation, get_db, init_db
 from api.models import UserRead, UserCreate, UserUpdate
 from motor.motor_asyncio import AsyncIOMotorClient
@@ -171,6 +175,9 @@ logger.debug("CORS middleware configured with allowed origins")
 app.include_router(api_router)
 app.include_router(telegram_router, prefix="/api")
 
+app.include_router(whatsapp_router, prefix="/api")
+app.include_router(messenger_router, prefix="/api")
+
 get_auth_router(app)
 logger.debug("API and auth routers included")
 

utils/messenger_bot.py

@@ -0,0 +1,290 @@
+# utils/messenger_bot.py
+# Facebook Messenger Bot Webhook Handler - Global Production Ready
+# Supports ALL languages (Same as Telegram bot)
+
+import os
+import json
+import logging
+import httpx
+from typing import Dict, Any, Optional
+from fastapi import APIRouter, Request, HTTPException, Response
+from utils.generation import request_generation
+from api.endpoints import enhance_system_prompt
+from utils.constants import API_ENDPOINT, MODEL_NAME
+from utils.generation import HF_TOKEN, BACKUP_HF_TOKEN
+
+logger = logging.getLogger(__name__)
+router = APIRouter()
+
+# ============================================================
+# Configuration
+# ============================================================
+MESSENGER_PAGE_TOKEN = os.getenv("MESSENGER_PAGE_TOKEN")
+MESSENGER_VERIFY_TOKEN = os.getenv("MESSENGER_VERIFY_TOKEN", "mgzon_messenger_verify_123")
+CLOUDFLARE_WORKER_URL = os.getenv("CLOUDFLARE_WORKER_URL", "https://mgzon-tg-proxy.amarlasfar0.workers.dev")
+
+if not MESSENGER_PAGE_TOKEN:
+    logger.warning("⚠️ MESSENGER_PAGE_TOKEN is not set. Messenger bot will not work.")
+
+# ============================================================
+# Language Detection Helper (Same as Telegram)
+# ============================================================
+
+def detect_language(text: str) -> str:
+    """Detect user's language from their message. Returns ISO 639-1 language code."""
+    if not text:
+        return "en"
+    
+    if any(0x0600 <= ord(char) <= 0x06FF for char in text):
+        return "ar"
+    if any(0x4E00 <= ord(char) <= 0x9FFF for char in text):
+        return "zh"
+    if any(0x0400 <= ord(char) <= 0x04FF for char in text):
+        return "ru"
+    if any(char in "áéíóúñü¿¡" for char in text.lower()):
+        return "es"
+    if any(char in "àâçéèêëîïôûùÿæœ" for char in text.lower()):
+        return "fr"
+    if any(char in "äöüß" for char in text.lower()):
+        return "de"
+    
+    return "en"
+
+# ============================================================
+# Multilingual Response Messages
+# ============================================================
+
+def get_welcome_message(lang: str) -> str:
+    """Welcome message in user's language"""
+    messages = {
+        "en": "🤖 *Welcome to MGZon AI Assistant on Messenger!*\n\nI'm your intelligent AI companion. Ask me anything! 🚀",
+        "ar": "🤖 *مرحباً بك في مساعد MGZon AI على ماسنجر!*\n\nأنا مساعدك الذكي. اسألني أي شيء! 🚀",
+        "zh": "🤖 *欢迎使用 Messenger 版 MGZon AI 助手！*\n\n我是你的智能伙伴。有什么可以帮你的？🚀",
+        "ru": "🤖 *Добро пожаловать в MGZon AI Assistant в Messenger!*\n\nЯ ваш интеллектуальный помощник. Спрашивайте что угодно! 🚀",
+        "es": "🤖 *¡Bienvenido a MGZon AI Assistant en Messenger!*\n\n¡Soy tu compañero IA. Pregúntame cualquier cosa! 🚀",
+        "fr": "🤖 *Bienvenue sur MGZon AI Assistant sur Messenger!*\n\nJe suis votre compagnon IA. Demandez-moi n'importe quoi! 🚀",
+        "de": "🤖 *Willkommen bei MGZon AI Assistant auf Messenger!*\n\nIch bin Ihr KI-Begleiter. Fragen Sie mich alles! 🚀"
+    }
+    return messages.get(lang, messages["en"])
+
+def get_error_message(lang: str) -> str:
+    """Error message in user's language"""
+    messages = {
+        "en": "⚠️ An error occurred. Please try again in a few moments.",
+        "ar": "⚠️ حدث خطأ. يرجى المحاولة مرة أخرى بعد قليل.",
+        "zh": "⚠️ 发生错误。请稍后再试。",
+        "ru": "⚠️ Произошла ошибка. Пожалуйста, попробуйте позже.",
+        "es": "⚠️ Ocurrió un error. Por favor, inténtelo de nuevo en unos momentos.",
+        "fr": "⚠️ Une erreur s'est produite. Veuillez réessayer dans quelques instants.",
+        "de": "⚠️ Ein Fehler ist aufgetreten. Bitte versuchen Sie es in einigen Augenblicken noch einmal."
+    }
+    return messages.get(lang, messages["en"])
+
+def get_empty_response_message(lang: str) -> str:
+    """Message when AI returns empty response"""
+    messages = {
+        "en": "🤔 I couldn't generate a proper response. Could you rephrase your question?",
+        "ar": "🤔 لم أتمكن من إنشاء رد مناسب. هل يمكنك إعادة صياغة سؤالك؟",
+        "zh": "🤔 我无法生成合适的回复。你能重新表述一下你的问题吗？",
+        "ru": "🤔 Я не смог сгенерировать подходящий ответ. Можете переформулировать вопрос?",
+        "es": "🤔 No pude generar una respuesta adecuada. ¿Podrías reformular tu pregunta?",
+        "fr": "🤔 Je n'ai pas pu générer une réponse appropriée. Pouvez-vous reformuler votre question?",
+        "de": "🤔 Ich konnte keine angemessene Antwort generieren. Könnten Sie Ihre Frage umformulieren?"
+    }
+    return messages.get(lang, messages["en"])
+
+# ============================================================
+# Messenger API Helpers (via Cloudflare Worker)
+# ============================================================
+
+async def send_messenger_message(recipient_id: str, text: str) -> bool:
+    """Send message to Facebook Messenger via Cloudflare Worker"""
+    if not MESSENGER_PAGE_TOKEN:
+        logger.error("Messenger page token not configured")
+        return False
+    
+    url = f"{CLOUDFLARE_WORKER_URL}/api/v19.0/me/messages"
+    
+    payload = {
+        "recipient": {"id": recipient_id},
+        "message": {"text": text[:2000]},
+        "messaging_type": "RESPONSE"
+    }
+    
+    headers = {
+        "Authorization": f"Bearer {MESSENGER_PAGE_TOKEN}",
+        "Content-Type": "application/json"
+    }
+    
+    async with httpx.AsyncClient(timeout=30.0) as client:
+        try:
+            response = await client.post(url, json=payload, headers=headers)
+            if response.status_code in (200, 201):
+                logger.info(f"✅ Messenger message sent to {recipient_id}")
+                return True
+            else:
+                logger.error(f"❌ Messenger send failed: {response.text}")
+                return False
+        except Exception as e:
+            logger.error(f"❌ Error sending Messenger: {e}")
+            return False
+
+async def send_typing_action(recipient_id: str) -> None:
+    """Send typing indicator to Messenger"""
+    if not MESSENGER_PAGE_TOKEN:
+        return
+    
+    url = f"{CLOUDFLARE_WORKER_URL}/api/v19.0/me/messages"
+    
+    payload = {
+        "recipient": {"id": recipient_id},
+        "sender_action": "typing_on"
+    }
+    
+    async with httpx.AsyncClient(timeout=10.0) as client:
+        try:
+            await client.post(url, json=payload, headers={"Authorization": f"Bearer {MESSENGER_PAGE_TOKEN}"})
+        except Exception as e:
+            logger.warning(f"Could not send typing indicator: {e}")
+
+# ============================================================
+# AI Call with Multi-Token Fallback
+# ============================================================
+
+async def call_ai_with_fallback(user_message: str, enhanced_prompt: str) -> str:
+    """Calls the AI with automatic fallback to backup tokens"""
+    available_tokens = []
+    if HF_TOKEN:
+        available_tokens.append(HF_TOKEN)
+    if BACKUP_HF_TOKEN:
+        available_tokens.append(BACKUP_HF_TOKEN)
+    
+    if not available_tokens:
+        logger.error("No HF tokens available!")
+        user_lang = detect_language(user_message)
+        return get_error_message(user_lang)
+    
+    for i, token in enumerate(available_tokens):
+        try:
+            logger.info(f"🔄 Trying token #{i+1} for Messenger...")
+            
+            response_chunks = []
+            stream = request_generation(
+                api_key=token,
+                api_base=API_ENDPOINT,
+                message=user_message,
+                system_prompt=enhanced_prompt,
+                model_name=MODEL_NAME,
+                temperature=0.7,
+                max_new_tokens=2000,
+                deep_search=True,
+                input_type="text",
+                output_format="text"
+            )
+            
+            for chunk in stream:
+                if isinstance(chunk, str) and chunk not in ["analysis", "assistantfinal"]:
+                    response_chunks.append(chunk)
+            
+            bot_reply = "".join(response_chunks).strip()
+            if bot_reply and len(bot_reply) >= 5:
+                logger.info(f"✅ Token #{i+1} succeeded for Messenger")
+                return bot_reply
+            else:
+                raise Exception("Empty or insufficient response")
+                
+        except Exception as e:
+            logger.warning(f"⚠️ Token #{i+1} failed: {e}")
+            continue
+    
+    logger.error("❌ All tokens failed for Messenger")
+    user_lang = detect_language(user_message)
+    return get_error_message(user_lang)
+
+# ============================================================
+# Webhook Endpoints
+# ============================================================
+
+@router.get("/messenger/webhook")
+async def verify_messenger_webhook(request: Request):
+    """Verify webhook with Facebook (GET request)"""
+    mode = request.query_params.get("hub.mode")
+    token = request.query_params.get("hub.verify_token")
+    challenge = request.query_params.get("hub.challenge")
+    
+    if mode == "subscribe" and token == MESSENGER_VERIFY_TOKEN:
+        logger.info("✅ Messenger webhook verified successfully!")
+        return Response(content=challenge, media_type="text/plain")
+    else:
+        logger.warning(f"❌ Messenger verification failed: mode={mode}, token={token}")
+        raise HTTPException(status_code=403, detail="Verification failed")
+
+@router.post("/messenger/webhook")
+async def messenger_webhook(request: Request):
+    """Receive Facebook Messenger messages and reply (Supports ALL languages)"""
+    try:
+        body = await request.json()
+        logger.debug(f"📩 Messenger webhook received: {json.dumps(body)[:500]}")
+        
+        for entry in body.get("entry", []):
+            for messaging in entry.get("messaging", []):
+                sender_id = messaging.get("sender", {}).get("id")
+                message = messaging.get("message", {})
+                message_text = message.get("text")
+                
+                if not sender_id:
+                    continue
+                
+                # Detect language from user's message
+                user_lang = detect_language(message_text or "")
+                
+                if not message_text:
+                    await send_messenger_message(sender_id, get_non_text_message(user_lang))
+                    continue
+                
+                logger.info(f"💬 Messenger from {sender_id} ({user_lang}): {message_text[:100]}...")
+                
+                # Send typing indicator
+                await send_typing_action(sender_id)
+                
+                # Prepare system prompt (language-aware)
+                enhanced_prompt = enhance_system_prompt("", message_text, user=None)
+                
+                # Call AI
+                bot_reply = await call_ai_with_fallback(message_text, enhanced_prompt)
+                
+                if not bot_reply or len(bot_reply) < 5:
+                    bot_reply = get_empty_response_message(user_lang)
+                
+                await send_messenger_message(sender_id, bot_reply)
+        
+        return {"status": "ok"}
+        
+    except Exception as e:
+        logger.error(f"❌ Messenger webhook error: {e}", exc_info=True)
+        return {"status": "error", "message": str(e)}
+
+def get_non_text_message(lang: str) -> str:
+    """Message for non-text content"""
+    messages = {
+        "en": "📎 I can only process text messages for now. Please send me a text message.",
+        "ar": "📎 يمكنني معالجة الرسائل النصية فقط حالياً. يرجى إرسال رسالة نصية.",
+        "zh": "📎 我目前只能处理文本消息。请发送文本消息。",
+        "ru": "📎 Пока я могу обрабатывать только текстовые сообщения. Пожалуйста, отправьте текстовое сообщение.",
+        "es": "📎 Por ahora solo puedo procesar mensajes de texto. Por favor, envíame un mensaje de texto.",
+        "fr": "📎 Je ne peux traiter que les messages texte pour l'instant. Veuillez m'envoyer un message texte.",
+        "de": "📎 Ich kann derzeit nur Textnachrichten verarbeiten. Bitte senden Sie mir eine Textnachricht."
+    }
+    return messages.get(lang, messages["en"])
+
+# ============================================================
+# Health Check
+# ============================================================
+
+@router.get("/messenger/health")
+async def messenger_health():
+    """Health check endpoint"""
+    return {
+        "status": "healthy",
+        "page_token_configured": bool(MESSENGER_PAGE_TOKEN)
+    }

utils/whatsapp_bot.py

@@ -0,0 +1,315 @@
+# utils/whatsapp_bot.py
+# WhatsApp Business API Webhook Handler - Global Production Ready
+# Supports ALL languages (Same as Telegram bot)
+
+import os
+import json
+import re
+import logging
+import httpx
+from typing import Dict, Any, Optional
+from fastapi import APIRouter, Request, HTTPException, Response
+from utils.generation import request_generation
+from api.endpoints import enhance_system_prompt
+from utils.constants import API_ENDPOINT, MODEL_NAME
+from utils.generation import HF_TOKEN, BACKUP_HF_TOKEN
+
+logger = logging.getLogger(__name__)
+router = APIRouter()
+
+# ============================================================
+# Configuration
+# ============================================================
+WHATSAPP_TOKEN = os.getenv("WHATSAPP_TOKEN")
+WHATSAPP_VERIFY_TOKEN = os.getenv("WHATSAPP_VERIFY_TOKEN")
+WHATSAPP_PHONE_NUMBER_ID = os.getenv("WHATSAPP_PHONE_NUMBER_ID")
+CLOUDFLARE_WORKER_URL = os.getenv("CLOUDFLARE_WORKER_URL", "https://mgzon-tg-proxy.amarlasfar0.workers.dev")
+
+if not WHATSAPP_TOKEN:
+    logger.warning("⚠️ WHATSAPP_TOKEN is not set. Bot will not work.")
+if not WHATSAPP_PHONE_NUMBER_ID:
+    logger.warning("⚠️ WHATSAPP_PHONE_NUMBER_ID is not set.")
+
+# ============================================================
+# Language Detection Helper (Same as Telegram)
+# ============================================================
+
+def detect_language(text: str) -> str:
+    """Detect user's language from their message. Returns ISO 639-1 language code."""
+    if not text:
+        return "en"
+    
+    if any(0x0600 <= ord(char) <= 0x06FF for char in text):
+        return "ar"
+    if any(0x4E00 <= ord(char) <= 0x9FFF for char in text):
+        return "zh"
+    if any(0x0400 <= ord(char) <= 0x04FF for char in text):
+        return "ru"
+    if any(char in "áéíóúñü¿¡" for char in text.lower()):
+        return "es"
+    if any(char in "àâçéèêëîïôûùÿæœ" for char in text.lower()):
+        return "fr"
+    if any(char in "äöüß" for char in text.lower()):
+        return "de"
+    
+    return "en"
+
+# ============================================================
+# Multilingual Response Messages
+# ============================================================
+
+def get_welcome_message(lang: str) -> str:
+    """Welcome message in user's language"""
+    messages = {
+        "en": "🤖 *Welcome to MGZon AI Assistant on WhatsApp!*\n\nI'm your intelligent AI companion. Ask me anything! 🚀",
+        "ar": "🤖 *مرحباً بك في مساعد MGZon AI على واتساب!*\n\nأنا مساعدك الذكي. اسألني أي شيء! 🚀",
+        "zh": "🤖 *欢迎使用 WhatsApp 版 MGZon AI 助手！*\n\n我是你的智能伙伴。有什么可以帮你的？🚀",
+        "ru": "🤖 *Добро пожаловать в MGZon AI Assistant в WhatsApp!*\n\nЯ ваш интеллектуальный помощник. Спрашивайте что угодно! 🚀",
+        "es": "🤖 *¡Bienvenido a MGZon AI Assistant en WhatsApp!*\n\n¡Soy tu compañero IA. Pregúntame cualquier cosa! 🚀",
+        "fr": "🤖 *Bienvenue sur MGZon AI Assistant sur WhatsApp!*\n\nJe suis votre compagnon IA. Demandez-moi n'importe quoi! 🚀",
+        "de": "🤖 *Willkommen bei MGZon AI Assistant auf WhatsApp!*\n\nIch bin Ihr KI-Begleiter. Fragen Sie mich alles! 🚀"
+    }
+    return messages.get(lang, messages["en"])
+
+def get_error_message(lang: str) -> str:
+    """Error message in user's language"""
+    messages = {
+        "en": "⚠️ An error occurred. Please try again in a few moments.",
+        "ar": "⚠️ حدث خطأ. يرجى المحاولة مرة أخرى بعد قليل.",
+        "zh": "⚠️ 发生错误。请稍后再试。",
+        "ru": "⚠️ Произошла ошибка. Пожалуйста, попробуйте позже.",
+        "es": "⚠️ Ocurrió un error. Por favor, inténtelo de nuevo en unos momentos.",
+        "fr": "⚠️ Une erreur s'est produite. Veuillez réessayer dans quelques instants.",
+        "de": "⚠️ Ein Fehler ist aufgetreten. Bitte versuchen Sie es in einigen Augenblicken noch einmal."
+    }
+    return messages.get(lang, messages["en"])
+
+def get_empty_response_message(lang: str) -> str:
+    """Message when AI returns empty response"""
+    messages = {
+        "en": "🤔 I couldn't generate a proper response. Could you rephrase your question?",
+        "ar": "🤔 لم أتمكن من إنشاء رد مناسب. هل يمكنك إعادة صياغة سؤالك؟",
+        "zh": "🤔 我无法生成合适的回复。你能重新表述一下你的问题吗？",
+        "ru": "🤔 Я не смог сгенерировать подходящий ответ. Можете переформулировать вопрос?",
+        "es": "🤔 No pude generar una respuesta adecuada. ¿Podrías reformular tu pregunta?",
+        "fr": "🤔 Je n'ai pas pu générer une réponse appropriée. Pouvez-vous reformuler votre question?",
+        "de": "🤔 Ich konnte keine angemessene Antwort generieren. Könnten Sie Ihre Frage umformulieren?"
+    }
+    return messages.get(lang, messages["en"])
+
+# ============================================================
+# WhatsApp API Helpers (via Cloudflare Worker)
+# ============================================================
+
+async def send_whatsapp_message(to_number: str, text: str, reply_to_id: Optional[str] = None) -> bool:
+    """Send message to WhatsApp via Cloudflare Worker"""
+    if not WHATSAPP_TOKEN or not WHATSAPP_PHONE_NUMBER_ID:
+        logger.error("WhatsApp credentials not configured")
+        return False
+    
+    # Clean phone number
+    to_number = to_number.replace("+", "").strip()
+    if not to_number.startswith("20"):
+        to_number = f"20{to_number}"
+    
+    url = f"{CLOUDFLARE_WORKER_URL}/api/v25.0/{WHATSAPP_PHONE_NUMBER_ID}/messages"
+    
+    payload = {
+        "messaging_product": "whatsapp",
+        "to": to_number,
+        "text": {"body": text[:4096]},
+        "type": "text"
+    }
+    if reply_to_id:
+        payload["context"] = {"message_id": reply_to_id}
+    
+    headers = {
+        "Authorization": f"Bearer {WHATSAPP_TOKEN}",
+        "Content-Type": "application/json"
+    }
+    
+    async with httpx.AsyncClient(timeout=30.0) as client:
+        try:
+            response = await client.post(url, json=payload, headers=headers)
+            if response.status_code in (200, 201):
+                logger.info(f"✅ WhatsApp message sent to {to_number}")
+                return True
+            else:
+                logger.error(f"❌ WhatsApp send failed: {response.text}")
+                return False
+        except Exception as e:
+            logger.error(f"❌ Error sending WhatsApp: {e}")
+            return False
+
+async def send_typing_indicator(to_number: str) -> None:
+    """Send typing indicator to WhatsApp"""
+    if not WHATSAPP_TOKEN or not WHATSAPP_PHONE_NUMBER_ID:
+        return
+    
+    url = f"{CLOUDFLARE_WORKER_URL}/api/v25.0/{WHATSAPP_PHONE_NUMBER_ID}/messages"
+    
+    payload = {
+        "messaging_product": "whatsapp",
+        "to": to_number,
+        "type": "reaction",
+        "reaction": {"message_id": "typing_indicator", "emoji": "⏳"}
+    }
+    
+    async with httpx.AsyncClient(timeout=10.0) as client:
+        try:
+            await client.post(url, json=payload, headers={"Authorization": f"Bearer {WHATSAPP_TOKEN}"})
+        except Exception as e:
+            logger.warning(f"Could not send typing indicator: {e}")
+
+# ============================================================
+# AI Call with Multi-Token Fallback
+# ============================================================
+
+async def call_ai_with_fallback(user_message: str, enhanced_prompt: str) -> str:
+    """Calls the AI with automatic fallback to backup tokens"""
+    available_tokens = []
+    if HF_TOKEN:
+        available_tokens.append(HF_TOKEN)
+    if BACKUP_HF_TOKEN:
+        available_tokens.append(BACKUP_HF_TOKEN)
+    
+    if not available_tokens:
+        logger.error("No HF tokens available!")
+        user_lang = detect_language(user_message)
+        return get_error_message(user_lang)
+    
+    for i, token in enumerate(available_tokens):
+        try:
+            logger.info(f"🔄 Trying token #{i+1} for WhatsApp...")
+            
+            response_chunks = []
+            stream = request_generation(
+                api_key=token,
+                api_base=API_ENDPOINT,
+                message=user_message,
+                system_prompt=enhanced_prompt,
+                model_name=MODEL_NAME,
+                temperature=0.7,
+                max_new_tokens=2000,
+                deep_search=True,
+                input_type="text",
+                output_format="text"
+            )
+            
+            for chunk in stream:
+                if isinstance(chunk, str) and chunk not in ["analysis", "assistantfinal"]:
+                    response_chunks.append(chunk)
+            
+            bot_reply = "".join(response_chunks).strip()
+            if bot_reply and len(bot_reply) >= 5:
+                logger.info(f"✅ Token #{i+1} succeeded for WhatsApp")
+                return bot_reply
+            else:
+                raise Exception("Empty or insufficient response")
+                
+        except Exception as e:
+            logger.warning(f"⚠️ Token #{i+1} failed: {e}")
+            continue
+    
+    logger.error("❌ All tokens failed for WhatsApp")
+    user_lang = detect_language(user_message)
+    return get_error_message(user_lang)
+
+# ============================================================
+# Webhook Endpoints
+# ============================================================
+
+@router.get("/whatsapp/webhook")
+async def verify_whatsapp_webhook(request: Request):
+    """Verify webhook with Meta (GET request)"""
+    mode = request.query_params.get("hub.mode")
+    token = request.query_params.get("hub.verify_token")
+    challenge = request.query_params.get("hub.challenge")
+    
+    if mode == "subscribe" and token == WHATSAPP_VERIFY_TOKEN:
+        logger.info("✅ WhatsApp webhook verified successfully!")
+        return Response(content=challenge, media_type="text/plain")
+    else:
+        logger.warning(f"❌ WhatsApp verification failed: mode={mode}, token={token}")
+        raise HTTPException(status_code=403, detail="Verification failed")
+
+@router.post("/whatsapp/webhook")
+async def whatsapp_webhook(request: Request):
+    """Receive WhatsApp messages and reply (Supports ALL languages)"""
+    try:
+        body = await request.json()
+        logger.debug(f"📩 WhatsApp webhook received: {json.dumps(body)[:500]}")
+        
+        for entry in body.get("entry", []):
+            for change in entry.get("changes", []):
+                value = change.get("value", {})
+                messages = value.get("messages", [])
+                
+                for message in messages:
+                    from_number = message.get("from")
+                    msg_type = message.get("type")
+                    msg_id = message.get("id")
+                    
+                    if msg_type == "text":
+                        user_text = message.get("text", {}).get("body", "")
+                    else:
+                        user_text = None
+                    
+                    if not from_number:
+                        continue
+                    
+                    # Detect language from user's message
+                    user_lang = detect_language(user_text or "")
+                    
+                    # Handle non-text messages
+                    if not user_text:
+                        await send_whatsapp_message(from_number, get_non_text_message(user_lang), reply_to_id=msg_id)
+                        continue
+                    
+                    logger.info(f"📨 WhatsApp from {from_number} ({user_lang}): {user_text[:100]}...")
+                    
+                    # Send typing indicator
+                    await send_typing_indicator(from_number)
+                    
+                    # Prepare system prompt (language-aware)
+                    enhanced_prompt = enhance_system_prompt("", user_text, user=None)
+                    
+                    # Call AI
+                    bot_reply = await call_ai_with_fallback(user_text, enhanced_prompt)
+                    
+                    if not bot_reply or len(bot_reply) < 5:
+                        bot_reply = get_empty_response_message(user_lang)
+                    
+                    await send_whatsapp_message(from_number, bot_reply, reply_to_id=msg_id)
+        
+        return {"status": "ok"}
+        
+    except Exception as e:
+        logger.error(f"❌ WhatsApp webhook error: {e}", exc_info=True)
+        return {"status": "error", "message": str(e)}
+
+def get_non_text_message(lang: str) -> str:
+    """Message for non-text content"""
+    messages = {
+        "en": "📎 I can only process text messages for now. Please send me a text message.",
+        "ar": "📎 يمكنني معالجة الرسائل النصية فقط حالياً. يرجى إرسال رسالة نصية.",
+        "zh": "📎 我目前只能处理文本消息。请发送文本消息。",
+        "ru": "📎 Пока я могу обрабатывать только текстовые сообщения. Пожалуйста, отправьте текстовое сообщение.",
+        "es": "📎 Por ahora solo puedo procesar mensajes de texto. Por favor, envíame un mensaje de texto.",
+        "fr": "📎 Je ne peux traiter que les messages texte pour l'instant. Veuillez m'envoyer un message texte.",
+        "de": "📎 Ich kann derzeit nur Textnachrichten verarbeiten. Bitte senden Sie mir eine Textnachricht."
+    }
+    return messages.get(lang, messages["en"])
+
+# ============================================================
+# Health Check
+# ============================================================
+
+@router.get("/whatsapp/health")
+async def whatsapp_health():
+    """Health check endpoint"""
+    return {
+        "status": "healthy",
+        "token_configured": bool(WHATSAPP_TOKEN),
+        "phone_id_configured": bool(WHATSAPP_PHONE_NUMBER_ID)
+    }