Send a Slack DM when you're assigned a monday.com item

from slack_sdk import WebClient
from slack_sdk.errors import SlackApiError
from clickruntime import on_event, credentials, http

ITEM = """query ($id: [ID!]) { items(ids: $id) { name url board { name }
  column_values(ids: ["date", "status"]) { id text } } }"""
USERS = """query ($ids: [ID!]) { users(ids: $ids) { id email } }"""
def monday(query, **variables):
    resp = http.post("https://api.monday.com/v2", json={"query": query, "variables": variables},
                     headers={"Authorization": credentials.secret("MONDAY_API_TOKEN"), "API-Version": "2024-10"})
    resp.raise_for_status()
    return resp.json()["data"]

def people(value):
    return {str(p["id"]) for p in (value or {}).get("personsAndTeams", []) if p.get("kind") == "person"}

@on_event
def handle(event):
    body = event.json or {}
    if "challenge" in body:
        return {"challenge": body["challenge"]}
    ev = body.get("event", {})
    if ev.get("columnId") != "person":
        return {"skipped": "other column"}
    added = people(ev.get("value")) - people(ev.get("previousValue"))
    if not added:
        return {"skipped": "nobody added"}
    item = monday(ITEM, id=[ev["pulseId"]])["items"][0]
    c = {v["id"]: v["text"] for v in item["column_values"]}
    text = (f"👋 You were assigned *{item['name']}* on {item['board']['name']}\n"
            f"Due: {c.get('date') or 'no date'} · Status: {c.get('status') or 'none'}\n{item['url']}")
    slack = WebClient(token=credentials.connection("slack", "work"))
    sent = []
    for u in monday(USERS, ids=list(added))["users"]:
        try:
            uid = slack.users_lookupByEmail(email=u["email"])["user"]["id"]
        except SlackApiError:
            continue
        slack.chat_postMessage(channel=uid, text=text)
        sent.append(u["email"])
    return {"messaged": sent}