Celebrate each new hire in Slack

from datetime import datetime, timezone
from clickruntime import on_trigger, credentials, http, state, notify, report_fetched

def harvest(path, **params):
    resp = http.get(f"https://harvest.greenhouse.io/v1/{path}",
                    auth=(credentials.secret("GREENHOUSE_API_KEY"), ""), params=params)
    resp.raise_for_status()
    return resp.json()

@on_trigger
def run(event):
    since = state.get("since") or datetime.now(timezone.utc).isoformat()
    started = datetime.now(timezone.utc).isoformat()
    announced = set(state.get("announced") or [])
    hired = [a for a in harvest("applications", status="hired", last_activity_after=since, per_page=100)
             if a["id"] not in announced]
    report_fetched(len(hired))
    if not hired:
        state.set("since", started)
        return {"summary": "Nothing new"}
    for a in hired:
        c = harvest(f"candidates/{a['candidate_id']}")
        notify.slack(f"🎉 Please welcome {c['first_name']} {c['last_name']}, who's joining as {a['jobs'][0]['name']}!",
                     channel="#general")
        announced.add(a["id"])
    state.set("announced", sorted(announced))
    state.set("since", started)
    return {"announced": len(hired)}