Turn Slack requests into Jira issues

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

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)

CHANNEL = "C0123ITREQ"

@on_trigger
def run(event):
    token = credentials.connection("slack", "work")
    slack = WebClient(token=token)
    oldest = state.get("oldest") or "0"
    msgs = [m for m in slack.conversations_history(channel=CHANNEL, oldest=oldest, limit=100)["messages"] if not m.get("thread_ts") and not m.get("bot_id")]
    report_fetched(len(msgs))
    if not msgs:
        return {"created": 0}
    for m in sorted(msgs, key=lambda m: m["ts"]):
        title = m["text"].splitlines()[0][:120]
        try:
            title = ai.generate(m["text"][:3000], system="Write a short, specific IT ticket title.", max_output_tokens=30).text.strip()
        except (ai.AINotIncluded, ai.AILimitReached):
            pass
        issue = jira("POST", "/rest/api/3/issue", json={"fields": {"project": {"key": "IT"}, "issuetype": {"name": "Task"}, "summary": title, "description": adf(m["text"])}})
        for f in m.get("files", []):
            data = http.get(f["url_private"], headers={"Authorization": f"Bearer {token}"}).content
            http.post(f"{JIRA}/rest/api/3/issue/{issue['key']}/attachments", files={"file": (f["name"], data)},
                      headers={"Authorization": f"Bearer {credentials.connection('jira', 'work')}", "X-Atlassian-Token": "no-check"})
        slack.chat_postMessage(channel=CHANNEL, thread_ts=m["ts"], text=f"Logged as <{SITE}{issue['key']}|{issue['key']}>. We'll update you there.")
    state.set("oldest", max(m["ts"] for m in msgs))
    return {"created": len(msgs)}