Post a daily engineering digest from GitHub in Slack

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)

ORG = "acme"

def search(q):
    return gh("GET", "/search/issues", params={"q": f"org:{ORG} {q}", "per_page": 30})["items"]

@on_trigger
def run(event):
    since = date.today() - timedelta(days=1)
    merged = search(f"is:pr is:merged merged:>={since}")
    waiting = search("is:pr is:open draft:false review:required")
    issues = search(f"is:issue created:>={since}")
    fmt = lambda items: "\n".join(f"• <{i['html_url']}|{i['title']}>" for i in items[:10]) or "• none"
    text = f"*Merged yesterday*\n{fmt(merged)}\n*Waiting for review*\n{fmt(waiting)}\n*New issues*\n{fmt(issues)}"
    try:
        titles = "\n".join(i["title"] for i in merged + issues)[:3000]
        text = ai.generate(titles, system="Summarise the themes of this engineering work in two plain sentences.", max_output_tokens=120).text + "\n\n" + text
    except (ai.AINotIncluded, ai.AILimitReached):
        pass
    notify.slack(text, channel="#eng")
    return {"merged": len(merged), "waiting": len(waiting), "issues": len(issues)}