Update app.py

app.py

@@ -93,39 +93,56 @@ async def task_update(request: Request):
     data = await request.json()
     logging.info(f"Received task update from ClickUp: {data}")
 
-    # Extract necessary fields
+    event_type = data.get("event")
     task_id = data.get("task_id", "Unknown ID")
     task_name = data.get("task", {}).get("name", "Unknown Task")
-
-    # Extract the new status after update
-    history_items = data.get("history_items", [])
-    if history_items:
-        new_status = history_items[0].get("after", {}).get("status", "").lower()
-        action_timestamp = history_items[0].get("date", 0)
-    else:
-        logging.error("No history items found in the update payload.")
-        return {"error": "No history items found."}
-
-    # Convert action timestamp to readable format
-    action_date_human = datetime.utcfromtimestamp(int(action_timestamp) / 1000).strftime('%Y-%m-%d %H:%M:%S') if action_timestamp else "Unknown Date"
-
-    logging.info(f"Extracted Status: {new_status}, Task: {task_name}, Date: {action_date_human}")
-
-    # If status is "Ready for Review", send WhatsApp notification
-    if new_status == "ready for review":
-        task_link = f"https://app.clickup.com/t/{task_id}"
-
-        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."
-        }
-
-        logging.info(f"Sending WhatsApp notification with payload: {whatsapp_payload}")
-
-        # Send WhatsApp request
-        whatsapp_response = requests.post(WHATSAPP_URL, json=whatsapp_payload, headers=whatsapp_headers)
-
-        logging.info(f"WhatsApp API Response Code: {whatsapp_response.status_code}")
-        logging.info(f"WhatsApp API Response: {whatsapp_response.text}")
+    task_link = f"https://app.clickup.com/t/{task_id}"
+
+    if event_type == "taskUpdated":
+        # Extract the new status
+        history_items = data.get("history_items", [])
+        if history_items:
+            new_status = history_items[0].get("after", {}).get("status", "").lower()
+            action_timestamp = history_items[0].get("date", 0)
+        else:
+            logging.error("No history items found in taskUpdated event.")
+            return {"error": "No history items found."}
+
+        # Convert action timestamp to readable date
+        action_date_human = datetime.utcfromtimestamp(int(action_timestamp) / 1000).strftime('%Y-%m-%d %H:%M:%S') if action_timestamp else "Unknown Date"
+
+        logging.info(f"Task: {task_name}, New Status: {new_status}, Action Date: {action_date_human}")
+
+        if new_status == "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."
+            }
+
+            logging.info(f"Sending WhatsApp notification: {whatsapp_payload}")
+            whatsapp_response = requests.post(WHATSAPP_URL, json=whatsapp_payload, headers=WHATSAPP_HEADERS)
+            logging.info(f"WhatsApp API Response: {whatsapp_response.status_code} - {whatsapp_response.text}")
+
+    elif event_type == "taskTagUpdated":
+        # Extract tag information
+        history_items = data.get("history_items", [])
+        if history_items:
+            added_tags = history_items[0].get("after", [])
+            due_date_timestamp = data.get("task", {}).get("due_date", 0)
+        else:
+            logging.error("No history items found in taskTagUpdated event.")
+            return {"error": "No history items found."}
+
+        if "missed due date" in added_tags:
+            due_date_human = datetime.utcfromtimestamp(int(due_date_timestamp) / 1000).strftime('%Y-%m-%d %H:%M:%S') if due_date_timestamp else "Unknown Date"
+
+            whatsapp_payload = {
+                "chatId": "201092003112@c.us",
+                "message": f"⚠️ *Task Overdue!*\n\n📌 *Task:* {task_name}\n⏳ *Due Date:* {due_date_human}\n\n🔗 *View Task:* {task_link}\n\nPlease take action as soon as possible."
+            }
+
+            logging.info(f"Sending Overdue Task Notification: {whatsapp_payload}")
+            whatsapp_response = requests.post(WHATSAPP_URL, json=whatsapp_payload, headers=WHATSAPP_HEADERS)
+            logging.info(f"WhatsApp API Response: {whatsapp_response.status_code} - {whatsapp_response.text}")
 
     return {"status": "Update received"}