Update main.py

main.py

@@ -1,30 +1,23 @@
-import requests
+from fastapi import FastAPI
+import os, requests
 from datetime import datetime
 import pytz
 from dotenv import load_dotenv
-import os
 
 load_dotenv()
 
-# === CONFIG ===
+app = FastAPI()
+
 clickup_api = os.getenv('CLICKUP_API_KEY')
 telegram_bot_token = os.getenv('TELEGRAM_BOT_TOKEN')
 telegram_chat_id = os.getenv('TELEGRAM_CHAT_ID')
 TIMEZONE = 'Asia/Dhaka'
 
-# === LISTS TO PROCESS ===
 LISTS = [
-    {
-        "id": '901800830748',
-        "title": "*Developer Task Board:*"
-    },
-    {
-        "id": '901800835985',
-        "title": "*Designer Task Board:*"
-    }
+    {"id": '901800830748', "title": "*Developer Task Board:*"},
+    {"id": '901800835985', "title": "*Designer Task Board:*"}
 ]
 
-# === FETCH TODAY'S TASKS FROM CLICKUP LIST ===
 def get_tasks(list_id):
     headers = {"Authorization": clickup_api}
     url = f"https://api.clickup.com/api/v2/list/{list_id}/task"
@@ -40,22 +33,16 @@ def get_tasks(list_id):
         due_ts = task.get("due_date")
         status = task.get("status", {}).get("status", "").lower()
 
-        # Optional: skip completed tasks
         if status in ["done", "complete", "completed"]:
             continue
 
-        # Show tasks due today or later, OR with no due date
         if due_ts:
             due_dt = datetime.fromtimestamp(int(due_ts) / 1000, tz).date()
             if due_dt >= today:
                 filtered_tasks.append(task)
-        # else:
-        #     # No due date? Still include it
-        #     filtered_tasks.append(task)
 
     return filtered_tasks
 
-# === SEND TO TELEGRAM ===
 def send_to_telegram(message):
     url = f"https://api.telegram.org/bot{telegram_bot_token}/sendMessage"
     payload = {
@@ -63,15 +50,12 @@ def send_to_telegram(message):
         "text": message,
         "parse_mode": "Markdown"
     }
-    resp = requests.post(url, data=payload)
-    print("Telegram response:", resp.text)
+    return requests.post(url, data=payload)
 
-# === FORMAT AND SEND FOR EACH LIST ===
-def daily_task_summary(list_id, board_title):
+def format_and_send(list_id, board_title):
     tasks = get_tasks(list_id)
     if not tasks:
-        send_to_telegram(f"{board_title}\nNo tasks due today!")
-        return
+        return send_to_telegram(f"{board_title}\nNo tasks due today!")
 
     tz = pytz.timezone(TIMEZONE)
     task_map = {}
@@ -83,33 +67,23 @@ def daily_task_summary(list_id, board_title):
         due_ts = task.get("due_date")
         status = task.get("status", {}).get("status", "Unknown")
 
-        # Format due time
-        if due_ts:
-            due_dt = datetime.fromtimestamp(int(due_ts) / 1000, tz)
-            due_str = due_dt.strftime("%B %d, %Y")
-        else:
-            due_str = "No due time"
-
-        # Assignees
-        assignees = task.get("assignees", [])
-        if not assignees:
-            assignees = [{"name": "Unassigned"}]
+        due_str = datetime.fromtimestamp(int(due_ts) / 1000, tz).strftime("%B %d, %Y") if due_ts else "No due time"
+        assignees = task.get("assignees", []) or [{"name": "Unassigned"}]
 
         for a in assignees:
             name = a.get("name") or a.get("username") or a.get("email") or "Unassigned"
-            if name not in task_map:
-                task_map[name] = []
-            task_map[name].append(f"- [{task_name}]({task_url}) ({due_str}) - *{status}*")
+            task_map.setdefault(name, []).append(f"- [{task_name}]({task_url}) ({due_str}) - *{status}*")
 
-    # Compose final message
     msg = f"{board_title} ({today_str})\n"
     for name, items in task_map.items():
         msg += f"\n*{name}* is assigned at:\n" + "\n".join(items) + "\n"
 
-    send_to_telegram(msg + "\n")
+    return send_to_telegram(msg + "\n")
 
-# === MAIN ===
-if __name__ == "__main__":
-    print("Sending today's task summaries...")
+@app.get("/")
+def run_notifier():
+    results = []
     for board in LISTS:
-        daily_task_summary(board["id"], board["title"])
+        resp = format_and_send(board["id"], board["title"])
+        results.append(resp.json())
+    return {"status": "sent", "results": results}