Alert Slack on production errors with one Jira bug per error

import hashlib
from clickruntime import on_event, credentials, http, notify, ai

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)

@on_event
def handle(event):
    err = event.json or {}
    text = f"{err.get('name')} in {err.get('service')}: {err.get('message', '')}"
    notify.slack(f"[{err.get('severity', 'error')}] {text}", channel="#alerts")
    fp = "err-" + hashlib.sha1(f"{err.get('service')}|{err.get('name')}".encode()).hexdigest()[:10]
    found = jira("POST", "/rest/api/3/search/jql", json={"jql": f'project = ENG AND labels = "{fp}" AND statusCategory != Done', "fields": ["key"], "maxResults": 1})["issues"]
    if found:
        jira("POST", f"/rest/api/3/issue/{found[0]['key']}/comment", json={"body": adf(f"Happened again at {event.received_at}: {text}")})
        return {"issue": found[0]["key"], "new": False}
    note = ""
    try:
        note = ai.generate(f"{text}\n{(err.get('stack') or '')[:3000]}", system="Give the likely cause in 2 sentences.", max_output_tokens=120).text
    except (ai.AINotIncluded, ai.AILimitReached):
        pass
    issue = jira("POST", "/rest/api/3/issue", json={"fields": {"project": {"key": "ENG"}, "issuetype": {"name": "Bug"}, "labels": [fp],
                 "summary": f"[Error] {err.get('name')} in {err.get('service')}"[:250], "description": adf(f"{text}\n\n{note}")}})
    notify.slack(f"New bug {issue['key']} opened for this error: {SITE}{issue['key']}", channel="#alerts")
    return {"issue": issue["key"], "new": True}