Update app.py

app.py

@@ -107,25 +107,30 @@ async def create_task(request: Request):
     
     # Create ClickUp task according to task type
     description_text = ""
-
     task_type_lower = task_type.lower()
-
-    if task_type_lower == "strategy":
-        status = "to do"
-        description_text = description
-
-    elif task_type_lower == "content":
+    
+    # Template and field setup
+    template_ids = {
+        "content": "t-8698wwx4z",
+        "creative": "t-8698wwx4z",
+        "ads": "t-8698wwx4z"
+    }
+    custom_field_id = "64b6898b-eaee-4dd1-b819-a5b142226f69"
+    team_id = "9012303718"
+    
+    # Shared description builder
+    if task_type_lower == "content":
         status = "backlog"
-        description_text = f"{goal.strip()}".strip()
+        description_text = goal.strip()
         if platforms:
             description_text += "\n\nPlatforms: " + ", ".join(platforms)
-
+    
     elif task_type_lower == "creative":
         status = "to do"
-        description_text = f"{creative_type.strip()}".strip()
+        description_text = creative_type.strip()
         if platforms:
             description_text += "\n\nPlatforms: " + ", ".join(platforms)
-
+    
     elif task_type_lower == "ads":
         status = "ready"
         parts = []
@@ -136,56 +141,89 @@ async def create_task(request: Request):
         if platforms:
             parts.append("Platforms: " + ", ".join(platforms))
         description_text = "\n\n".join(parts)
-
-    elif task_type_lower == "posting":
-        status = "ready for posting"
-        parts = []
-        if posting_content:
-            parts.append(posting_content.strip())
-        if platforms:
-            parts.append("Platforms: " + ", ".join(platforms))
-        if attachment_link:
-            parts.append(f"Attachment: {attachment_link.strip()}")
-        description_text = "\n\n".join(parts)
-
-    elif task_type_lower == "ads report":
-        status = "ready"
-        platforms_text = ", ".join(platforms) if platforms else ""
-        description_text = f"Prepare an ads report for {platforms_text}"
-        if start_date and end_date:
-            description_text += f" from {start_date} to {end_date}"
-
-    else:
-        return {"error": f"Unsupported task type: {task_type}"}
     
-    # Construct ClickUp task payload
-    payload = {
-        "name": task_title,
-        "description": description_text,
-        "assignees": [int(uid) for uid in assignee_ids],
-        "status": status
-    }
-
-    # Handle due date
-    if deadline:
-        try:
-            due_timestamp = int(datetime.strptime(deadline, "%Y-%m-%d").timestamp() * 1000)
-            payload["due_date"] = due_timestamp
-            print(f"Due Date (timestamp): {due_timestamp}")
-        except ValueError:
-            print("Invalid deadline format. Skipping due_date.")
-
-    # Send request to ClickUp
-    create_url = f"{CLICKUP_URL_BASE}/list/{list_id}/task"
-    clickup_response = requests.post(create_url, headers=headers, json=payload)
-    clickup_data = clickup_response.json()
-    print(f"ClickUp Response: {clickup_response.status_code}, {clickup_data}")
-
+    if task_type_lower in template_ids:
+        # Create from template
+        template_id = template_ids[task_type_lower]
+        template_url = f"{CLICKUP_URL_BASE}/list/{list_id}/taskTemplate/{template_id}"
+        template_payload = {
+            "name": task_title
+        }
+    
+        response = requests.post(template_url, headers=headers, json=template_payload)
+        print("Template Creation Status:", response.status_code)
+    
+        if response.ok:
+            new_task = response.json()
+            new_task_id = new_task.get("id")
+            print("✅ Task created from template:", new_task_id)
+    
+            # Update custom field (used as description)
+            update_field_url = f"{CLICKUP_URL_BASE}/task/{new_task_id}/field/{custom_field_id}?custom_task_ids=true&team_id={team_id}"
+            field_payload = {"value": description_text}
+            field_update = requests.post(update_field_url, headers=headers, json=field_payload)
+    
+            print("📥 Field Update Status:", field_update.status_code)
+            print("📥 Field Update Response:", field_update.text)
     
-    # WhatsApp notification part is commented out for now
-    # We'll handle WhatsApp notification later
+            return {
+                "status": "Template-based task created",
+                "task_id": new_task_id
+            }
+        else:
+            print("❌ Failed to create task from template")
+            return {"error": "Template task creation failed"}
+    
+    # If not using template, fallback to normal creation
+    elif task_type_lower in ["strategy", "posting", "ads report"]:
+        if task_type_lower == "strategy":
+            status = "to do"
+            description_text = description
+    
+        elif task_type_lower == "posting":
+            status = "ready for posting"
+            parts = []
+            if posting_content:
+                parts.append(posting_content.strip())
+            if platforms:
+                parts.append("Platforms: " + ", ".join(platforms))
+            if attachment_link:
+                parts.append(f"Attachment: {attachment_link.strip()}")
+            description_text = "\n\n".join(parts)
+    
+        elif task_type_lower == "ads report":
+            status = "ready"
+            platforms_text = ", ".join(platforms) if platforms else ""
+            description_text = f"Prepare an ads report for {platforms_text}"
+            if start_date and end_date:
+                description_text += f" from {start_date} to {end_date}"
+    
+        payload = {
+            "name": task_title,
+            "description": description_text,
+            "assignees": [int(uid) for uid in assignee_ids],
+            "status": status
+        }
+    
+        # Handle due date
+        if deadline:
+            try:
+                due_timestamp = int(datetime.strptime(deadline, "%Y-%m-%d").timestamp() * 1000)
+                payload["due_date"] = due_timestamp
+                print(f"Due Date (timestamp): {due_timestamp}")
+            except ValueError:
+                print("Invalid deadline format. Skipping due_date.")
+    
+        create_url = f"{CLICKUP_URL_BASE}/list/{list_id}/task"
+        clickup_response = requests.post(create_url, headers=headers, json=payload)
+        clickup_data = clickup_response.json()
+        print(f"ClickUp Response: {clickup_response.status_code}, {clickup_data}")
+    
+        return {"status": "Standard task created", "clickup": clickup_data}
+    
+    else:
+        return {"error": f"Unsupported task type: {task_type}"}
 
-    return {"status": "Task data received and parsed"}
 
 # Function to get task name by task ID
 def get_task_name(task_id):