Update app.py

app.py

@@ -221,6 +221,18 @@ def get_task_details(task_id):
 
     return task_data
 
+def send_whatsapp_notification(chat_id: str, message: str):
+    payload = {
+        "chatId": chat_id,
+        "message": message
+    }
+    try:
+        response = requests.post(WHATSAPP_URL, json=payload, headers=whatsapp_headers)
+        response.raise_for_status()
+        logging.info(f"WhatsApp sent to {chat_id} - {response.status_code}: {response.text}")
+    except requests.RequestException as e:
+        logging.error(f"WhatsApp send failed for {chat_id}: {e}")
+
 @app.post("/updates")
 async def task_update(request: Request):
     data = await request.json()
@@ -250,17 +262,15 @@ async def task_update(request: Request):
                 logging.info(f"Task: {task_name}, New Status: {after_status}, Action Date: {action_date_human}")
 
                 if after_status.lower() == "ready for review":
-                    whatsapp_payload = {
-                        "chatId": "201092003112@c.us",
-                        "message": f"📝 *Task Submitted for Review!*\n\n📌 *Task:* {task_name}\n📅 *Submitted On:* {action_date_human}\n\n🔗 *View Task:* {task_link}\n\nPlease review the task and provide feedback."
-                    }
-
-                    try:
-                        whatsapp_response = requests.post(WHATSAPP_URL, json=whatsapp_payload, headers=whatsapp_headers)
-                        whatsapp_response.raise_for_status()
-                        logging.info(f"WhatsApp API Response: {whatsapp_response.status_code} - {whatsapp_response.text}")
-                    except requests.RequestException as e:
-                        logging.error(f"Failed to send WhatsApp notification: {e}")
+                    chat_id = "201092003112@c.us"
+                    message = (
+                        f"📝 *Task Submitted for Review!*\n\n"
+                        f"📌 *Task:* {task_name}\n"
+                        f"📅 *Submitted On:* {action_date_human}\n\n"
+                        f"🔗 *View Task:* {task_link}\n\n"
+                        f"Please review the task and provide feedback."
+                    )
+                    send_whatsapp_notification(chat_id, message)
 
     elif event_type == "taskTagUpdated":
         history_items = data.get("history_items", [])
@@ -277,16 +287,14 @@ async def task_update(request: Request):
 
                             logging.info(f"Missed Due Date Tag Added for Task: {task_name}, Due Date: {due_date}")
 
-                            whatsapp_payload = {
-                                "chatId": "201092003112@c.us",
-                                "message": f"⚠️ *Task Missed Due Date!*\n\n📌 *Task:* {task_name}\n📅 *Due Date:* {due_date}\n\n🔗 *View Task:* {task_link}\n\nPlease take action immediately."
-                            }
-
-                            try:
-                                whatsapp_response = requests.post(WHATSAPP_URL, json=whatsapp_payload, headers=whatsapp_headers)
-                                whatsapp_response.raise_for_status()
-                                logging.info(f"WhatsApp API Response: {whatsapp_response.status_code} - {whatsapp_response.text}")
-                            except requests.RequestException as e:
-                                logging.error(f"Failed to send WhatsApp notification: {e}")
+                            chat_id = "201092003112@c.us"
+                            message = (
+                                f"⚠️ *Task Missed Due Date!*\n\n"
+                                f"📌 *Task:* {task_name}\n"
+                                f"📅 *Due Date:* {due_date}\n\n"
+                                f"🔗 *View Task:* {task_link}\n\n"
+                                f"Please take action immediately."
+                            )
+                            send_whatsapp_notification(chat_id, message)
 
     return {"status": "Update received"}