Update app.py

app.py

@@ -919,9 +919,11 @@ def send_whatsjet_message(phone_number: str, message: str, media_type: str = Non
             }
             logger.info(f"[WhatsJet][DEBUG] Media API URL: {media_api_url}")
             logger.info(f"[WhatsJet][DEBUG] Media payload: {payload}")
+            headers = {"Authorization": f"Bearer {WHATSJET_API_TOKEN}"}
             response = httpx.post(
                 media_api_url,
                 json=payload,
+                headers=headers,
                 timeout=30
             )
             logger.info(f"[WhatsJet][DEBUG] Media response status: {response.status_code}")
@@ -969,10 +971,12 @@ def send_whatsjet_message(phone_number: str, message: str, media_type: str = Non
                 logger.info(f"[WhatsJet][DEBUG] URL: {url}")
                 logger.info(f"[WhatsJet][DEBUG] Multipart data: {data}")
                 logger.info(f"[WhatsJet][DEBUG] Multipart files: {list(files.keys())}")
+                headers = {"Authorization": f"Bearer {WHATSJET_API_TOKEN}"}
                 response = httpx.post(
                     url,
                     data=data,
                     files=files,
+                    headers=headers,
                     timeout=30
                 )
                 logger.info(f"[WhatsJet][DEBUG] Multipart response status: {response.status_code}")
@@ -1000,9 +1004,11 @@ def send_whatsjet_message(phone_number: str, message: str, media_type: str = Non
                 # Enhanced logging
                 logger.info(f"[WhatsJet][DEBUG] URL: {url}")
                 logger.info(f"[WhatsJet][DEBUG] Base64 payload: {{'phone_number': payload['phone_number'], 'media_type': payload['media_type'], 'media_filename': payload['media_filename'], 'message_body': payload['message_body'][:50] + '...', 'media_content_length': len(payload['media_content'])}}")
+                headers = {"Authorization": f"Bearer {WHATSJET_API_TOKEN}"}
                 response = httpx.post(
                     url,
                     json=payload,
+                    headers=headers,
                     timeout=30
                 )
                 logger.info(f"[WhatsJet][DEBUG] Base64 response status: {response.status_code}")
@@ -1034,9 +1040,11 @@ def send_whatsjet_message(phone_number: str, message: str, media_type: str = Non
             # Enhanced logging
             logger.info(f"[WhatsJet][DEBUG] URL: {url}")
             logger.info(f"[WhatsJet][DEBUG] Payload: {json.dumps(payload)}")
+            headers = {"Authorization": f"Bearer {WHATSJET_API_TOKEN}"}
             response = httpx.post(
                 url,
                 json=payload,
+                headers=headers,
                 timeout=15
             )
             logger.info(f"[WhatsJet][DEBUG] Response status: {response.status_code}")
@@ -3981,7 +3989,8 @@ async def test_whatsjet_payloads(phone: str):
     for test in test_payloads:
         try:
             logger.info(f"[WhatsJet] Testing payload format: {test['name']}")
-            response = httpx.post(url, json=test['payload'], timeout=30)
+            headers = {"Authorization": f"Bearer {WHATSJET_API_TOKEN}"}
+            response = httpx.post(url, json=test['payload'], headers=headers, timeout=30)
             
             results[test['name']] = {
                 "status_code": response.status_code,