Get Slack alerts for new Asana tasks and comments

from clickruntime import on_event, http, credentials, notify

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_event
def handle(event):
    secret = event.header("X-Hook-Secret")
    if secret:  # Asana's handshake when the webhook is created
        return {"handshake": True}
    posted = 0
    for e in (event.json or {}).get("events", []):
        res = e.get("resource", {})
        if e.get("action") == "added" and res.get("resource_type") == "task":
            task = asana("GET", f"/tasks/{res['gid']}", opt_fields="name,permalink_url")
            notify.slack(f"New task: {task['name']}\n{task['permalink_url']}", channel="#marketing")
            posted += 1
        elif e.get("action") == "added" and res.get("resource_subtype") == "comment_added":
            story = asana("GET", f"/stories/{res['gid']}", opt_fields="text,created_by.name,target.name,target.permalink_url")
            notify.slack(f"{story['created_by']['name']} on {story['target']['name']}: {story['text'][:300]}\n"
                         f"{story['target']['permalink_url']}", channel="#marketing")
            posted += 1
    return {"posted": posted}