ignore quoted messeges

app.py

@@ -19,6 +19,7 @@ GREEN_API_MEDIA_URL = os.getenv("GREEN_API_MEDIA_URL", "https://api.green-api.co
 GREEN_API_TOKEN = os.getenv("GREEN_API_TOKEN")
 GREEN_API_ID_INSTANCE = os.getenv("GREEN_API_ID_INSTANCE")
 WEBHOOK_AUTH_TOKEN = os.getenv("WEBHOOK_AUTH_TOKEN")
+PORT = int(os.getenv("PORT", 7860))
 image_dir = "/tmp/images"
 audio_dir = "/tmp/audio"
 
@@ -120,6 +121,7 @@ def response_audio(message_id, chat_id, prompt):
     logging.debug("Entering response_audio with prompt: %s", prompt)
     try:
         result = generate_voice_reply(prompt, model="openai-audio", voice="coral", audio_dir=audio_dir)
+        logging.debug("generate_voice_reply result: %s", result)
         if result and result[0]:
             audio_path, _ = result
             send_audio(message_id, chat_id, audio_path)
@@ -153,24 +155,24 @@ def index():
 
 @app.post("/whatsapp")
 async def whatsapp_webhook(request: Request):
-    # Auth
+    # 1) Auth
     auth = request.headers.get('Authorization', '').strip()
     if auth != f"Bearer {WEBHOOK_AUTH_TOKEN}":
         raise HTTPException(403, "Unauthorized")
 
-    # Parse JSON
+    # 2) Parse JSON
     try:
         data = await request.json()
     except:
         return JSONResponse({"error": "Invalid JSON"}, status_code=400)
 
-    # Only handle incoming messages
+    # 3) Only handle incoming messages
     if data.get('typeWebhook') != 'incomingMessageReceived':
         return {"success": True}
-    
+
     logging.debug(f"Received data: {data}")
 
-    # Extract core fields
+    # 4) Extract core fields
     try:
         chat_id = data['senderData']['chatId']
         message_id = data['idMessage']
@@ -178,38 +180,33 @@ async def whatsapp_webhook(request: Request):
     except KeyError as e:
         return JSONResponse({"error": f"Missing key: {e}"}, status_code=200)
 
-    # Get body
+    # --- NEW: IGNORE any WhatsApp “quotedMessage” payload entirely ---
+    if message_data.get('typeMessage') == 'quotedMessage' or 'quotedMessage' in message_data:
+        logging.debug("Ignoring WhatsApp quotedMessage payload")
+        return {"success": True}
+    # --------------------------------------------------------------------
+
+    # 5) Extract text body
     if 'textMessageData' in message_data:
         body = message_data['textMessageData'].get('textMessage', '').strip()
+        ctx  = message_data['textMessageData'].get('contextInfo', {})
     elif 'extendedTextMessageData' in message_data:
         body = message_data['extendedTextMessageData'].get('text', '').strip()
+        ctx  = message_data['extendedTextMessageData'].get('contextInfo', {})
     else:
         return {"success": True}
 
-    # --- IGNORE quoted replies & mentions ---
-    # 1) pull contextInfo from either textMessageData or extendedTextMessageData
-    ctx = {}
-    if 'extendedTextMessageData' in message_data:
-        ctx = message_data['extendedTextMessageData'].get('contextInfo', {})
-    elif 'textMessageData' in message_data:
-        ctx = message_data['textMessageData'].get('contextInfo', {})
-
-    if ctx.get('quotedMessageId'):
-        logging.debug(f"Ignoring quoted reply: {ctx['quotedMessageId']}")
-        return {"success": True}
-
-    # 2) structured mentions (WhatsApp native tagging)
+    # 6) IGNORE structured mentions
     if ctx.get('mentionedJid') or ctx.get('mentionedJidList'):
         logging.debug(f"Ignoring structured mention: {ctx.get('mentionedJid') or ctx.get('mentionedJidList')}")
         return {"success": True}
 
-    # 3) plain-text "@1234..." mentions in groups
+    # 7) IGNORE plain-text "@1234..." mentions in groups
     if chat_id.endswith('@g.us') and re.search(r'@\d+', body):
         logging.debug(f"Ignoring plain-text mention in body: {body}")
         return {"success": True}
-    # ----------------------------------------
 
-    # Enqueue work
+    # 8) Enqueue work
     if body.lower().startswith('/imagine'):
         prompt = body[len('/imagine'):].strip()
         if not prompt:
@@ -234,4 +231,4 @@ async def whatsapp_webhook(request: Request):
 
 if __name__ == '__main__':
     import uvicorn
-    uvicorn.run(app, host="0.0.0.0", port=7860)
+    uvicorn.run(app, host="0.0.0.0", port=PORT)