Update main.py

main.py

@@ -122,6 +122,50 @@ def call_ai_bot(message: str):
 # Webhook receiver
 # =========================
 
+def extract_text_message(msg_data: dict) -> str:
+    """
+    يحاول يطلع النص من messageData مهما كان typeMessage
+    """
+    if not isinstance(msg_data, dict):
+        return ""
+
+    t = (msg_data.get("typeMessage") or "").strip()
+
+    # 1) textMessage
+    if t == "textMessage":
+        return ((msg_data.get("textMessageData") or {}).get("textMessage") or "").strip()
+
+    # 2) extendedTextMessage (شائع جدًا)
+    if t == "extendedTextMessage":
+        return ((msg_data.get("extendedTextMessageData") or {}).get("text") or "").strip()
+
+    # 3) quotedMessage / reply (لو جاي مع رد)
+    if t == "quotedMessage":
+        q = msg_data.get("quotedMessageData") or {}
+        # أحيانًا يبقى جوّه نفس المفاتيح
+        return (
+            (q.get("textMessage") or "")
+            or (q.get("text") or "")
+            or ""
+        ).strip()
+
+    # 4) fallback عام: جرّب مفاتيح محتملة
+    # بعض الـ payloads بيكون النص تحت key = "text" أو "message"
+    for path in [
+        ("textMessageData", "textMessage"),
+        ("extendedTextMessageData", "text"),
+        ("textMessageData", "text"),
+        ("message",),
+        ("text",),
+    ]:
+        cur = msg_data
+        for k in path:
+            cur = cur.get(k) if isinstance(cur, dict) else None
+        if isinstance(cur, str) and cur.strip():
+            return cur.strip()
+
+    return ""
+
 @app.post("/recieve")
 async def webhook_receiver(req: Request):
     try:
@@ -147,12 +191,13 @@ async def webhook_receiver(req: Request):
     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()
+    type_message = (msg_data.get("typeMessage") or "")
+    text_message = extract_text_message(msg_data)
+
 
     print(">>> instance_wid:", instance_wid)
     print(">>> chat_id:", chat_id)
+    print(">>> typeMessage:", type_message)
     print(">>> text_message:", text_message)
 
     # لو مفيش chat_id أو مفيش رسالة نصية، نوقف
@@ -270,4 +315,4 @@ async def complaints_proxy(req: Request):
                 "gas_status": gas_resp.status_code,
                 "raw": (gas_resp.text or "")[:1500]
             }
-        )
+        )