Update app.py

app.py

@@ -941,12 +941,25 @@ def send_whatsjet_message(phone_number: str, message: str, media_type: str = Non
                 }
                 
                 logger.info(f"[WhatsJet] Attempting multipart upload for {phone_number}")
+                logger.info(f"[WhatsJet] Multipart payload - data: {data}")
+                logger.info(f"[WhatsJet] Multipart payload - files: {list(files.keys())}")
+                
                 response = httpx.post(
                     url,
                     data=data,
                     files=files,
                     timeout=30
                 )
+                
+                # Log response details for debugging
+                logger.info(f"[WhatsJet] Multipart response status: {response.status_code}")
+                logger.info(f"[WhatsJet] Multipart response headers: {dict(response.headers)}")
+                try:
+                    response_text = response.text
+                    logger.info(f"[WhatsJet] Multipart response body: {response_text[:500]}...")
+                except:
+                    logger.info(f"[WhatsJet] Multipart response body: Unable to read")
+                
                 response.raise_for_status()
                 logger.info(f"[WhatsJet] Media image sent successfully via multipart upload to {phone_number}")
                 
@@ -982,11 +995,28 @@ def send_whatsjet_message(phone_number: str, message: str, media_type: str = Non
                     }
                     
                     logger.info(f"[WhatsJet] Attempting base64 upload for {phone_number}")
+                    logger.info(f"[WhatsJet] Base64 payload keys: {list(payload.keys())}")
+                    logger.info(f"[WhatsJet] Base64 payload - phone_number: {payload['phone_number']}")
+                    logger.info(f"[WhatsJet] Base64 payload - media_type: {payload['media_type']}")
+                    logger.info(f"[WhatsJet] Base64 payload - media_filename: {payload['media_filename']}")
+                    logger.info(f"[WhatsJet] Base64 payload - message_body: '{payload['message_body']}'")
+                    logger.info(f"[WhatsJet] Base64 payload - media_content length: {len(payload['media_content'])} chars")
+                    
                     response = httpx.post(
                         url,
                         json=payload,
                         timeout=30
                     )
+                    
+                    # Log response details for debugging
+                    logger.info(f"[WhatsJet] Base64 response status: {response.status_code}")
+                    logger.info(f"[WhatsJet] Base64 response headers: {dict(response.headers)}")
+                    try:
+                        response_text = response.text
+                        logger.info(f"[WhatsJet] Base64 response body: {response_text[:500]}...")
+                    except:
+                        logger.info(f"[WhatsJet] Base64 response body: Unable to read")
+                    
                     response.raise_for_status()
                     logger.info(f"[WhatsJet] Media image sent successfully via base64 to {phone_number}")
                     
@@ -3949,6 +3979,110 @@ async def debug_whatsjet():
     except Exception as e:
         return {"error": str(e), "timestamp": datetime.now().isoformat()}
 
+@app.get("/test-whatsjet-payloads")
+async def test_whatsjet_payloads(phone: str):
+    """
+    Test different WhatsJet API payload formats to identify the correct one for image sending.
+    """
+    if not all([WHATSJET_API_URL, WHATSJET_VENDOR_UID, WHATSJET_API_TOKEN]):
+        return {"error": "WhatsJet not configured"}
+    
+    url = f"{WHATSJET_API_URL}/{WHATSJET_VENDOR_UID}/contact/send-message?token={WHATSJET_API_TOKEN}"
+    test_image_url = "https://www.w3schools.com/w3images/lights.jpg"
+    
+    # Download test image
+    try:
+        response = requests.get(test_image_url, timeout=10)
+        response.raise_for_status()
+        image_content = response.content
+        image_b64 = base64.b64encode(image_content).decode('utf-8')
+    except Exception as e:
+        return {"error": f"Failed to download test image: {e}"}
+    
+    results = {}
+    
+    # Test different payload formats
+    test_payloads = [
+        {
+            "name": "Format 1: Standard with media_content",
+            "payload": {
+                "phone_number": phone,
+                "media_type": "image/jpeg",
+                "media_content": image_b64,
+                "media_filename": "test.jpg",
+                "message_body": ""
+            }
+        },
+        {
+            "name": "Format 2: With media_url instead of media_content",
+            "payload": {
+                "phone_number": phone,
+                "media_type": "image/jpeg",
+                "media_url": test_image_url,
+                "media_filename": "test.jpg",
+                "message_body": ""
+            }
+        },
+        {
+            "name": "Format 3: With file field",
+            "payload": {
+                "phone_number": phone,
+                "file": image_b64,
+                "file_type": "image/jpeg",
+                "filename": "test.jpg",
+                "message_body": ""
+            }
+        },
+        {
+            "name": "Format 4: With attachment field",
+            "payload": {
+                "phone_number": phone,
+                "attachment": image_b64,
+                "attachment_type": "image/jpeg",
+                "attachment_name": "test.jpg",
+                "message_body": ""
+            }
+        },
+        {
+            "name": "Format 5: With image field",
+            "payload": {
+                "phone_number": phone,
+                "image": image_b64,
+                "image_type": "image/jpeg",
+                "image_name": "test.jpg",
+                "message_body": ""
+            }
+        }
+    ]
+    
+    for test in test_payloads:
+        try:
+            logger.info(f"[WhatsJet] Testing payload format: {test['name']}")
+            response = httpx.post(url, json=test['payload'], timeout=30)
+            
+            results[test['name']] = {
+                "status_code": response.status_code,
+                "success": response.status_code == 200,
+                "response_body": response.text[:200] if response.text else "No response body"
+            }
+            
+            logger.info(f"[WhatsJet] {test['name']} - Status: {response.status_code}")
+            
+        except Exception as e:
+            results[test['name']] = {
+                "status_code": "Error",
+                "success": False,
+                "error": str(e)
+            }
+            logger.error(f"[WhatsJet] {test['name']} - Error: {e}")
+    
+    return {
+        "timestamp": datetime.now().isoformat(),
+        "phone": phone,
+        "test_image_url": test_image_url,
+        "results": results
+    }
+
 if __name__ == "__main__":
     # Launch FastAPI app
     import uvicorn