Triage support requests into Jira and alert the right Slack channel

from clickruntime import on_event, credentials, http, notify, state, 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)

CHANNELS = {"billing": "#billing", "bug": "#eng-support", "account": "#support", "question": "#support"}
SCHEMA = {"type": "object", "properties": {"category": {"type": "string", "enum": list(CHANNELS)},
          "priority": {"type": "string", "enum": ["High", "Medium", "Low"]}, "summary": {"type": "string"}}}

@on_event
def handle(event):
    if state.get(event.event_id):
        return {"duplicate": True}
    req = event.json or {}
    t = ai.generate(f"Subject: {req.get('subject')}\n{req.get('message', '')[:4000]}", json_schema=SCHEMA, max_output_tokens=120,
                    system="Triage this support request. The summary is one short line.").json
    issue = jira("POST", "/rest/api/3/issue", json={"fields": {"project": {"key": "SUP"}, "issuetype": {"name": "Task"},
                 "summary": t["summary"][:250], "priority": {"name": t["priority"]}, "labels": [t["category"]],
                 "description": adf(f"From {req.get('email')}\n\n{req.get('message', '')}")}})
    notify.slack(f"[{t['priority']}] {t['summary']} from {req.get('email')} <{SITE}{issue['key']}|{issue['key']}>", channel=CHANNELS[t["category"]])
    state.set(event.event_id, issue["key"])
    return {"issue": issue["key"], **t}