Announce new starters and flag leavers

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

COMPANY = "northwind"

def bamboo(path, **params):
    resp = http.get(f"https://api.bamboohr.com/api/gateway.php/{COMPANY}/v1/{path}",
                    auth=(credentials.secret("BAMBOOHR_API_KEY"), "x"),
                    headers={"Accept": "application/json"}, params=params)
    resp.raise_for_status()
    return resp.json()

@on_trigger
def run(event):
    since = state.get("since") or datetime.now(timezone.utc).strftime("%Y-%m-%dT%H:%M:%SZ")
    changed = bamboo("employees/changed/", since=since).get("employees", {})
    report_fetched(len(changed))
    if not changed:
        return {"summary": "Nothing new"}
    notified = set(state.get("notified") or [])
    for emp_id in changed:
        e = bamboo(f"employees/{emp_id}/", fields="displayName,jobTitle,hireDate,terminationDate,status")
        if e.get("hireDate") and f"hire:{emp_id}" not in notified and e["hireDate"] >= since[:10]:
            notify.slack(f"Welcome {e['displayName']}, joining as {e['jobTitle']} on {e['hireDate']}!",
                         channel="#general")
            notified.add(f"hire:{emp_id}")
        if e.get("terminationDate") and e["terminationDate"] != "0000-00-00" and f"term:{emp_id}" not in notified:
            notify.email_me(f"Leaver: {e['displayName']}", f"Termination date set: {e['terminationDate']}")
            notified.add(f"term:{emp_id}")
    state.set("notified", sorted(notified))
    state.set("since", datetime.now(timezone.utc).strftime("%Y-%m-%dT%H:%M:%SZ"))
    return {"changed": len(changed)}