Turn Slack #requests messages into monday.com items

from slack_sdk import WebClient
from clickruntime import on_trigger, credentials, http, state

CHANNEL, BOARD = "C04REQUESTS", 1234567890
CREATE = """mutation ($board: ID!, $name: String!) { create_item(board_id: $board, item_name: $name) { id url } }"""
UPDATE = """mutation ($item: ID!, $body: String!) { create_update(item_id: $item, body: $body) { id } }"""
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"]

@on_trigger
def run(event):
    slack = WebClient(token=credentials.connection("slack", "work"))
    last = state.get("last_ts")
    if not last:
        latest = slack.conversations_history(channel=CHANNEL, limit=1)["messages"]
        state.set("last_ts", latest[0]["ts"] if latest else "0")
        return {"created": 0, "note": "starting point saved"}
    msgs = slack.conversations_history(channel=CHANNEL, oldest=last, limit=200)["messages"]
    created = 0
    for m in sorted(msgs, key=lambda m: float(m["ts"])):
        last = m["ts"]
        if m.get("bot_id") or m.get("subtype") or m.get("thread_ts", m["ts"]) != m["ts"]:
            continue
        text = m.get("text", "").strip()
        if not text:
            continue
        author = slack.users_info(user=m["user"])["user"]["real_name"]
        item = monday(CREATE, board=BOARD, name=text.splitlines()[0][:200])["create_item"]
        monday(UPDATE, item=item["id"], body=f"From {author} in #requests:\n\n{text}")
        slack.chat_postMessage(channel=CHANNEL, thread_ts=m["ts"], text=f"Logged on the Requests board: *{text.splitlines()[0][:120]}*\n{item['url']}")
        created += 1
    state.set("last_ts", last)
    return {"created": created}