Create Jira tickets from Telegram messages

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

ALLOWED = {111111111, 222222222}
SCHEMA = {"type": "object", "properties": {"title": {"type": "string"}, "description": {"type": "string"},
          "priority": {"type": "string", "enum": ["High", "Medium", "Low"]}}}

@on_event
def handle(event):
    msg = (event.json or {}).get("message") or {}
    if not msg.get("text"):
        return {"ignored": True}
    chat, user = msg["chat"]["id"], msg["from"]
    if user["id"] not in ALLOWED:
        telegram("Sorry, this bot is only for Acme staff.", chat)
        return {"refused": user["id"]}
    t = ai.generate(msg["text"][:3000], json_schema=SCHEMA, max_output_tokens=200, system="Turn this IT problem report into a ticket.").json
    key = jira("POST", "/rest/api/3/issue", json={"fields": {"project": {"key": "IT"}, "issuetype": {"name": "Task"}, "summary": t["title"][:250],
               "priority": {"name": t["priority"]}, "description": adf(f"{t['description']}\n\nReported by {user.get('first_name', '')} via Telegram: {msg['text']}")}})["key"]
    telegram(f"Thanks! Logged as {key}. IT will be in touch.", chat)
    return {"issue": key}