Update main.py

main.py

@@ -1,13 +1,37 @@
 import json
+import re
 import requests
 from fastapi import FastAPI, Request
 from fastapi.middleware.cors import CORSMiddleware
 from fastapi.responses import JSONResponse
 
+# =========================
+# Config
+# =========================
+
+GREENAPI_INSTANCE_ID = "7105210836"
+GREENAPI_TOKEN = "805b69f6c85d4e6caea0edaba692b889abecc9e6bb8b457e8f"
+
+GREENAPI_BASE = f"https://7105.api.greenapi.com/waInstance{GREENAPI_INSTANCE_ID}"
+
+# Interactive buttons endpoint (زي المثال بتاعك)
+GREENAPI_SEND_BUTTONS_URL = f"{GREENAPI_BASE}/sendInteractiveButtons/{GREENAPI_TOKEN}"
+
+# Plain text endpoint (لو عندك endpoint مختلف في GreenAPI غيّره هنا)
+GREENAPI_SEND_TEXT_URL = (
+    f"https://7105.api.greenapi.com/"
+    f"waInstance{GREENAPI_INSTANCE_ID}/sendMessage/{GREENAPI_TOKEN}"
+)
+
+COMPLAINT_FORM_URL = "https://www.google.com"  # <-- حط لينك فورم الشكوى الحقيقي
+AI_BOT_URL = "https://mr-help-adkbase.hf.space/processtext"  # <-- endpoint بتاع البوت
+
+TIMEOUT_SEC = 60
+
+# (لو عايز تفضل GAS زي ما هو موجود)
 GAS_WEBAPP_URL = "https://script.google.com/macros/s/AKfycbxFLlPzSvXM6xpVXR3-BjoK1lkNjYb8o1pctXI4Q2NZvv6wqKnIaSQA6hhL5lP_TQbTgQ/exec"
 
 app = FastAPI()
-
 app.add_middleware(
     CORSMiddleware,
     allow_origins=["*"],
@@ -16,36 +40,204 @@ app.add_middleware(
     allow_headers=["*"],
 )
 
+# =========================
+# Intent detection (بسيط)
+# =========================
+
+GREET_WORDS = [
+    "اهلا", "أهلا", "مرحبا", "هاي", "hello", "hi",
+    "السلام عليكم", "سلام عليكم", "مساء الخير", "صباح الخير",
+    "مساء الفل", "صباح الفل"
+]
+
+COMPLAINT_WORDS = [
+    "شكوى", "شكاوي", "اشتكي", "مشكلة", "مشكلتي", "تذمر", "زعلان",
+    "سيء", "خدمة سيئة", "عايز أشتكي", "عايز اشتكي", "complaint"
+]
+
+def detect_intent_simple(text: str) -> str:
+    t = (text or "").strip().lower()
+
+    if any(w in t for w in [x.lower() for x in GREET_WORDS]):
+        return "GREETING"
+
+    if any(w in t for w in [x.lower() for x in COMPLAINT_WORDS]):
+        return "COMPLAINT"
+
+    return "OTHER"
+
+# =========================
+# GreenAPI send helpers
+# =========================
+
+def send_interactive_buttons(chat_id: str, header: str, body: str, footer: str, buttons: list):
+    """
+    buttons example:
+      [{"buttonId":"1","buttonText":"..."}, ...]
+    OR url button:
+      {"type":"url","buttonId":"1","buttonText":"...","url":"..."}
+    """
+    payload = {
+        "chatId": chat_id,
+        "body": body,
+        "header": header,
+        "footer": footer,
+        "buttons": buttons
+    }
+    resp = requests.post(GREENAPI_SEND_BUTTONS_URL, json=payload, timeout=TIMEOUT_SEC)
+    return resp.status_code, (resp.text or "")[:1500]
+
+def send_text_message(chat_id: str, message: str):
+    payload = {
+        "chatId": chat_id,
+        "message": message
+    }
+    headers = {
+        "Content-Type": "application/json"
+    }
+
+    resp = requests.post(
+        GREENAPI_SEND_TEXT_URL,
+        json=payload,
+        headers=headers,
+        timeout=TIMEOUT_SEC
+    )
+
+    return resp.status_code, (resp.text or "")[:1500]
+
+# =========================
+# AI bot call
+# =========================
+
+def call_ai_bot(message: str):
+    payload = {"message": message}
+    resp = requests.post(AI_BOT_URL, json=payload, timeout=TIMEOUT_SEC)
+    resp.raise_for_status()
+    try:
+        return resp.json()
+    except Exception:
+        return {"ok": False, "raw": resp.text}
+
+# =========================
+# Webhook receiver
+# =========================
+
 @app.post("/recieve")
 async def webhook_receiver(req: Request):
     try:
         body = await req.json()
     except Exception:
-        body = await req.body()
+        raw = await req.body()
+        print("===== RECEIVED RAW =====")
+        print(raw)
+        print("========================")
+        return {"ok": True}
 
-    print("===== RECEIVED =====")
-    print(body)
-    print("====================")
+    print("===== RECEIVED JSON =====")
+    print(json.dumps(body, ensure_ascii=False, indent=2))
+    print("=========================")
 
-    return {"ok": True}
+    # 1) فلتر نوع الويبهوك
+    if body.get("typeWebhook") != "incomingMessageReceived":
+        return {"ok": True, "ignored": True}
+
+    # 2) استخرج wid + chatId + الرسالة
+    instance_wid = (body.get("instanceData") or {}).get("wid")  # ده wid بتاع الـ instance
+    sender_data = body.get("senderData") or {}
+    chat_id = sender_data.get("chatId")  # ده اللي لازم تبعت له الرد
+    msg_data = body.get("messageData") or {}
+
+    text_message = ""
+    if msg_data.get("typeMessage") == "textMessage":
+        text_message = ((msg_data.get("textMessageData") or {}).get("textMessage") or "").strip()
+
+    print(">>> instance_wid:", instance_wid)
+    print(">>> chat_id:", chat_id)
+    print(">>> text_message:", text_message)
+
+    # لو مفيش chat_id أو مفيش رسالة نصية، نوقف
+    if not chat_id or not text_message:
+        return {"ok": True, "skipped": True}
+
+    # 3) حدّد intent
+    intent = detect_intent_simple(text_message)
+    print(">>> intent:", intent)
+
+    # 4) ردود حسب intent
+    if intent == "GREETING":
+        header = "أهلاً بيك في ÄDK 👋"
+        body_txt = (
+            "منورنا! 😊\n"
+            "أنا مساعد ÄDK، تحب نساعدك في إيه؟"
+        )
+        footer = "ÄDK - German Courses"
+
+        buttons = [
+            {"buttonId": "1", "buttonText": "أنواع الكورسات"},
+            {"buttonId": "2", "buttonText": "تحديد مستوى"},
+            {"buttonId": "3", "buttonText": "تواصل معنا"},
+        ]
+
+        status, txt = send_interactive_buttons(chat_id, header, body_txt, footer, buttons)
+        print(">>> sent GREETING buttons:", status, txt)
+        return {"ok": True, "intent": intent}
+
+    if intent == "COMPLAINT":
+        header = "بنسمعك 🤝"
+        body_txt = "يسعدنا تواصلك. سجل الشكوى من الرابط ده، وفريقنا هيتواصل معاك في أقرب وقت."
+        footer = "شكراً لاختيار ÄDK"
+
+        buttons = [
+            {
+                "type": "url",
+                "buttonId": "1",
+                "buttonText": "تسجيل الشكوى",
+                "url": COMPLAINT_FORM_URL
+            }
+        ]
+
+        status, txt = send_interactive_buttons(chat_id, header, body_txt, footer, buttons)
+        print(">>> sent COMPLAINT url button:", status, txt)
+        return {"ok": True, "intent": intent}
+
+    # 5) غير كده → نبعته للـ AI bot
+    try:
+        bot_res = call_ai_bot(text_message)
+        # نتوقع {ok, intent, reply}
+        reply = ""
+        if isinstance(bot_res, dict):
+            reply = (bot_res.get("reply") or "").strip()
+        if not reply:
+            reply = "تمام — وصلت رسالتك. ممكن توضّحلي قصدك أكتر؟"
+
+        status, txt = send_text_message(chat_id, reply)
+        print(">>> sent AI reply:", status, txt)
+
+        return {"ok": True, "intent": "AI", "bot_intent": (bot_res.get("intent") if isinstance(bot_res, dict) else None)}
+
+    except Exception as e:
+        print("❌ AI bot failed:", str(e))
+        # fallback لطيف
+        status, txt = send_text_message(chat_id, "تمام — حصلت مشكلة بسيطة. ممكن تعيد إرسال رسالتك تاني؟")
+        print(">>> sent fallback:", status, txt)
+        return JSONResponse(status_code=200, content={"ok": True, "intent": "AI_FAILED", "error": str(e)})
+
+# =========================
+# Complaints proxy (زي ما هو عندك)
+# =========================
 
 @app.post("/complaints")
 async def complaints_proxy(req: Request):
-    # 1) اقرأ اللي جاي من الصفحة
     try:
         payload = await req.json()
     except Exception as e:
         print("❌ Failed to parse incoming JSON:", str(e))
-        return JSONResponse(
-            status_code=400,
-            content={"ok": False, "error": "invalid json body"}
-        )
+        return JSONResponse(status_code=400, content={"ok": False, "error": "invalid json body"})
 
     print("========== INCOMING PAYLOAD ==========")
     print(json.dumps(payload, ensure_ascii=False, indent=2))
     print("======================================")
 
-    # 2) ابعت لـ GAS (server-to-server)
     try:
         gas_resp = requests.post(
             GAS_WEBAPP_URL,
@@ -54,15 +246,10 @@ async def complaints_proxy(req: Request):
             timeout=60
         )
     except Exception as e:
-        # ✅ أهم جزء: ده كان غالبًا سبب الـ 500 عندك
         print("❌ ERROR calling GAS:", repr(e))
         return JSONResponse(
             status_code=502,
-            content={
-                "ok": False,
-                "error": "failed to reach GAS",
-                "details": str(e)
-            }
+            content={"ok": False, "error": "failed to reach GAS", "details": str(e)}
         )
 
     print("========== GAS STATUS ==========")
@@ -71,8 +258,6 @@ async def complaints_proxy(req: Request):
     print((gas_resp.text or "")[:1500])
     print("=====================================================")
 
-    # 3) رجّع نتيجة GAS للصفحة
-    # (حتى لو GAS رجّع HTML أو خطأ)
     try:
         gas_json = gas_resp.json()
         return JSONResponse(status_code=200, content=gas_json)