Post a daily Asana status update to Slack

from datetime import date, timedelta
from clickruntime import on_trigger, http, credentials, notify

PROJECTS = ["PROJECT_GID_1", "PROJECT_GID_2"]

def asana(method, path, body=None, **params):
    r = http.request(method, f"https://app.asana.com/api/1.0{path}", params=params,
                     json={"data": body} if body else None,
                     headers={"Authorization": f"Bearer {credentials.secret('ASANA_TOKEN')}"})
    r.raise_for_status()
    return r.json().get("data")

@on_trigger
def run(event):
    today = date.today().isoformat()
    yesterday = (date.today() - timedelta(days=1)).isoformat()
    blocks = []
    for gid in PROJECTS:
        name = asana("GET", f"/projects/{gid}", opt_fields="name")["name"]
        tasks = asana("GET", f"/projects/{gid}/tasks", completed_since=yesterday,
                      opt_fields="name,completed,completed_at,due_on")
        done = [t["name"] for t in tasks if t["completed"] and t["completed_at"][:10] == yesterday]
        due = [t["name"] for t in tasks if not t["completed"] and t["due_on"] == today]
        late = [t["name"] for t in tasks if not t["completed"] and t["due_on"] and t["due_on"] < today]
        blocks.append(f"*{name}*\nDone yesterday: {', '.join(done) or '-'}\n"
                      f"Due today: {', '.join(due) or '-'}\nOverdue: {', '.join(late) or '-'}")
    notify.slack("\n\n".join(blocks), channel="#standup")
    return {"projects": len(blocks)}