Escalate overdue Jira tasks with a Telegram alert

from clickruntime import on_trigger, credentials, http, state

JIRA, SITE = "https://api.atlassian.com/ex/jira/your-cloud-id", "https://acme.atlassian.net/browse/"
adf = lambda text: {"type": "doc", "version": 1, "content": [{"type": "paragraph", "content": [{"type": "text", "text": text}]}]}

def jira(method, path, **kw):
    resp = http.request(method, JIRA + path, headers={"Authorization": f"Bearer {credentials.connection('jira', 'work')}", "Accept": "application/json"}, **kw)
    return resp.raise_for_status() or (resp.json() if resp.content else None)
CHAT_ID = "123456789"

def telegram(text, chat_id=CHAT_ID):
    http.post(f"https://api.telegram.org/bot{credentials.secret('TELEGRAM_BOT_TOKEN')}/sendMessage", json={"chat_id": chat_id, "text": text}).raise_for_status()

@on_trigger
def run(event):
    issues = jira("POST", "/rest/api/3/search/jql", json={"jql": "project = OPS AND duedate < now() AND statusCategory != Done ORDER BY duedate",
                  "fields": ["summary", "duedate", "assignee", "priority"], "maxResults": 100})["issues"]
    yesterday = set(state.get("escalated") or [])
    new = [i for i in issues if i["key"] not in yesterday]
    for i in new:
        if i["fields"]["priority"]["name"] not in ("High", "Highest"):
            jira("PUT", f"/rest/api/3/issue/{i['key']}", json={"fields": {"priority": {"name": "High"}}})
    if new:
        telegram("⏰ Overdue tasks\n" + "\n".join(f"{i['key']} {i['fields']['summary']} ({(i['fields']['assignee'] or {}).get('displayName', 'unassigned')}, "
                                                  f"due {i['fields']['duedate']})" for i in new))
    state.set("escalated", [i["key"] for i in issues])
    return {"overdue": len(issues), "escalated": len(new)}