Post a daily digest of Jira and GitHub activity

from datetime import date, timedelta
from clickruntime import on_trigger, credentials, http, notify, ai

def gh(method, path, **kw):
    resp = http.request(method, f"https://api.github.com{path}", headers={
        "Authorization": f"Bearer {credentials.connection('github', 'work')}", "Accept": "application/vnd.github+json"}, **kw)
    return resp.raise_for_status() or (resp.json() if resp.content else None)
JIRA = "https://api.atlassian.com/ex/jira/your-cloud-id"

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)

def adf(text):
    return {"type": "doc", "version": 1, "content": [{"type": "paragraph", "content": [{"type": "text", "text": text}]}]}

REPO, PROJECT = "acme/app", "ENG"

@on_trigger
def run(event):
    since = date.today() - timedelta(days=3 if date.today().weekday() == 0 else 1)
    tickets = jira("POST", "/rest/api/3/search/jql", json={"jql": f"project = {PROJECT} AND updated >= '{since}'",
                   "fields": ["summary", "status", "assignee"], "maxResults": 100})["issues"]
    prs = gh("GET", "/search/issues", params={"q": f"repo:{REPO} is:pr updated:>={since}", "per_page": 50})["items"]
    text = ("Jira:\n" + "\n".join(f"{t['key']} [{t['fields']['status']['name']}] {t['fields']['summary']}" for t in tickets)
            + "\n\nPull requests:\n" + "\n".join(f"#{p['number']} [{'merged' if p.get('pull_request', {}).get('merged_at') else p['state']}] {p['title']}" for p in prs))
    summary = ai.generate(text[:15000], system="Summarise yesterday's engineering progress in 4 short plain sentences. Mention blockers.", max_output_tokens=250).text
    notify.slack(f"Engineering digest\n{summary}\n_{len(tickets)} tickets moved, {len(prs)} pull requests active_", channel="#eng")
    return {"tickets": len(tickets), "prs": len(prs)}