Turn your morning watch list into Asana tasks and a Slack summary

from clickruntime import on_trigger, credentials, http, state, notify, ai, report_fetched

WATCH = ["Northwind Analytics", "Acme Metrics"]
PROJECT_ID = "your-asana-project-id"

@on_trigger
def run(event):
    seen, new = state.get("seen") or [], []
    for term in WATCH:
        for h in http.get("https://hn.algolia.com/api/v1/search_by_date", params={"query": term, "tags": "story"}).json()["hits"]:
            if h["objectID"] not in seen:
                new.append((h["objectID"], term, h["title"], f"https://news.ycombinator.com/item?id={h['objectID']}"))
    report_fetched(len(new))
    if not new:
        return {"new": 0}
    for oid, term, title, url in new:
        try:
            act = "yes" in ai.generate(f"We track '{term}'. Does this need action from our team? yes or no.\n{title}", max_output_tokens=3).text.lower()
        except ai.AIError:
            act = True
        if act:
            http.post("https://app.asana.com/api/1.0/tasks", headers={"Authorization": f"Bearer {credentials.secret('ASANA_TOKEN')}"},
                      json={"data": {"name": f"{term}: {title}"[:200], "notes": url, "projects": [PROJECT_ID]}})
        seen.append(oid)
    notify.slack("Watch list today:\n" + "\n".join(f"- {t}: {title} {u}" for _, t, title, u in new), channel="#market")
    state.set("seen", seen[-2000:])
    return {"new": len(new)}