Get a morning digest of new pull requests

from datetime import datetime, timedelta, timezone
from clickruntime import on_trigger, credentials, http, state, notify

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)
    resp.raise_for_status()
    return resp.json() if resp.content else None

REPOS = ["acme/app", "acme/api"]

@on_trigger
def run(event):
    since = state.get("since") or (datetime.now(timezone.utc) - timedelta(days=1)).strftime("%Y-%m-%dT%H:%M:%SZ")
    sections = []
    for repo in REPOS:
        prs = [p for p in gh("GET", f"/repos/{repo}/pulls", params={"state": "open", "sort": "created",
               "direction": "desc", "per_page": 50}) if p["created_at"] > since]
        if prs:
            sections.append(f"{repo}\n" + "\n".join(
                f"  #{p['number']} {p['title']} · {p['user']['login']} · "
                f"{'draft' if p['draft'] else (str(len(p['requested_reviewers'])) + ' reviewers requested')}\n  {p['html_url']}"
                for p in prs))
    state.set("since", datetime.now(timezone.utc).strftime("%Y-%m-%dT%H:%M:%SZ"))
    if sections:
        notify.email_me("New pull requests", "\n\n".join(sections))
    return {"repos_with_prs": len(sections)}