Post a daily Jira digest in Slack

from collections import defaultdict
from datetime import date, timedelta
from clickruntime import on_trigger, 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)

PROJECT = "ENG"

def search(jql):
    return jira("POST", "/rest/api/3/search/jql", json={"jql": jql, "fields": ["summary", "status", "assignee", "duedate"], "maxResults": 100})["issues"]

@on_trigger
def run(event):
    since = date.today() - timedelta(days=3 if date.today().weekday() == 0 else 1)
    moved = search(f"project = {PROJECT} AND updated >= '{since}'")
    blocked = search(f"project = {PROJECT} AND (status = Blocked OR flagged is not EMPTY) AND statusCategory != Done")
    due = search(f"project = {PROJECT} AND duedate <= 3d AND statusCategory != Done")
    groups = defaultdict(list)
    for t in moved:
        groups[t["fields"]["status"]["name"]].append(f"<{SITE}{t['key']}|{t['key']}> {t['fields']['summary']}")
    fmt = lambda ts: "\n".join(f"• <{SITE}{t['key']}|{t['key']}> {t['fields']['summary']}" for t in ts) or "• none"
    text = "\n".join(f"*{s}*\n" + "\n".join(f"• {x}" for x in xs) for s, xs in groups.items())
    text += f"\n*Blocked*\n{fmt(blocked)}\n*Due in 3 days*\n{fmt(due)}"
    try:
        text = ai.generate(text[:10000], system="Summarise this Jira activity in 2 plain sentences, mentioning blockers.", max_output_tokens=120).text + "\n\n" + text
    except (ai.AINotIncluded, ai.AILimitReached):
        pass
    notify.slack(text, channel="#eng")
    return {"moved": len(moved), "blocked": len(blocked), "due": len(due)}