Post a daily standup from Asana to Slack

from datetime import date, datetime, timedelta, timezone
from collections import defaultdict
from clickruntime import on_trigger, credentials, http, ai, notify, log

PROJECT_ID = "your-asana-project-id"

@on_trigger
def run(event):
    since = (datetime.now(timezone.utc) - timedelta(days=3 if date.today().weekday() == 0 else 1)).isoformat()
    tasks = http.get(f"https://app.asana.com/api/1.0/projects/{PROJECT_ID}/tasks",
                     headers={"Authorization": f"Bearer {credentials.secret('ASANA_TOKEN')}"},
                     params={"completed_since": since, "opt_fields": "name,completed,completed_at,due_on,assignee.name"}).json()["data"]
    today = date.today().isoformat()
    people = defaultdict(lambda: {"done": [], "today": [], "overdue": []})
    for t in tasks:
        who = (t.get("assignee") or {}).get("name", "Unassigned")
        if t["completed"]:
            people[who]["done"].append(t["name"])
        elif t.get("due_on") == today:
            people[who]["today"].append(t["name"])
        elif t.get("due_on") and t["due_on"] < today:
            people[who]["overdue"].append(t["name"])
    lines = [f"*{p}*: done {', '.join(v['done']) or '-'} | today {', '.join(v['today']) or '-'} | overdue {', '.join(v['overdue']) or '-'}"
             for p, v in people.items() if any(v.values())]
    text = "\n".join(lines) or "No task changes since the last standup."
    try:
        text = ai.generate(f"Rewrite as a short friendly standup, keep every task:\n{text}", max_output_tokens=600).text
    except ai.AIError as e:
        log.info("Posting plain standup", {"code": e.code})
    notify.slack(f"Standup for {today}\n{text}", channel="#team")
    return {"people": len(lines)}