Archive monday.com items Done for 30 days

import json
from datetime import datetime, timedelta, timezone
from clickruntime import on_trigger, credentials, http, notify

BOARD, DAYS = 1234567890, 30
FIRST = """query ($board: [ID!]) { boards(ids: $board) { name items_page(limit: 500) { cursor
  items { id name column_values(ids: ["status"]) { text value } } } } }"""
NEXT = """query ($cursor: String!) { next_items_page(limit: 500, cursor: $cursor) { cursor
  items { id name column_values(ids: ["status"]) { text value } } } }"""
ARCHIVE = """mutation ($id: ID!) { archive_item(item_id: $id) { 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):
    board = monday(FIRST, board=[BOARD])["boards"][0]
    page, items = board["items_page"], []
    while True:
        items += page["items"]
        if not page["cursor"]:
            break
        page = monday(NEXT, cursor=page["cursor"])["next_items_page"]
    cutoff = datetime.now(timezone.utc) - timedelta(days=DAYS)
    archived = []
    for i in items:
        status = i["column_values"][0]
        if status["text"] != "Done" or not status["value"]:
            continue
        changed = json.loads(status["value"]).get("changed_at")
        if not changed:
            continue
        when = datetime.fromisoformat(changed.replace("Z", "+00:00"))
        if when < cutoff:
            monday(ARCHIVE, id=i["id"])
            archived.append(f"• {i['name']} (Done since {when:%b %-d})")
    if archived:
        notify.email_me(f"Archived {len(archived)} old items from {board['name']}",
                        f"Archived {len(archived)} items that were Done for {DAYS}+ days:\n" + "\n".join(archived))
    return {"archived": len(archived)}