Open Jira issues and ping Telegram for provider incidents

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)
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()

PAGES = {"Cloudflare": "https://www.cloudflarestatus.com/api/v2/incidents/unresolved.json",
         "Payments": "https://status.payments-provider.example/api/v2/incidents/unresolved.json"}

@on_trigger
def run(event):
    seen = set(state.get("seen") or [])
    new = [(name, i) for name, url in PAGES.items() for i in http.get(url).json()["incidents"] if i["id"] not in seen]
    report_fetched(len(new))
    if not new:
        return {"new": 0}
    for name, inc in new:
        note = inc["name"]
        try:
            note = ai.generate(f"{name}: {inc['name']}\n{(inc.get('incident_updates') or [{}])[0].get('body', '')}", max_output_tokens=60,
                               system="In one sentence, say what this provider incident may mean for an online shop.").text
        except (ai.AINotIncluded, ai.AILimitReached):
            pass
        key = jira("POST", "/rest/api/3/issue", json={"fields": {"project": {"key": "OPS"}, "issuetype": {"name": "Task"},
                   "summary": f"{name} incident: {inc['name']}"[:250], "description": adf(f"{note}\n{inc['shortlink']}")}})["key"]
        telegram(f"⚠️ {name}: {inc['name']} ({inc['impact']})\n{note}\nTracking in {key}")
        seen.add(inc["id"])
    state.set("seen", sorted(seen)[-500:])
    return {"new": len(new)}