Email a weekly changelog from merged pull requests

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)

REPO = "acme/app"
SKIP = {"internal", "chore", "dependencies"}

@on_trigger
def run(event):
    since = date.today() - timedelta(days=7)
    prs = gh("GET", "/search/issues", params={"q": f"repo:{REPO} is:pr is:merged merged:>={since}", "per_page": 100})["items"]
    prs = [p for p in prs if not SKIP & {l["name"] for l in p["labels"]}]
    if not prs:
        return {"prs": 0}
    lines = []
    for p in prs:
        files = gh("GET", f"/repos/{REPO}/pulls/{p['number']}/files", params={"per_page": 50})
        lines.append(f"#{p['number']} {p['title']}\n{(p.get('body') or '')[:400]}\nFiles: {', '.join(f['filename'] for f in files)[:300]}")
    draft = ai.generate("\n\n".join(lines)[:20000], max_output_tokens=1000,
                        system="Write a short customer-friendly changelog with bullet points. Then a section 'Risky changes' listing PRs touching billing, auth or data.").text
    notify.email_me(f"Changelog draft, week of {since:%d %b}", draft)
    return {"prs": len(prs)}