Assign new issues automatically

from datetime import datetime, timezone
from clickruntime import on_trigger, credentials, http, state, report_fetched

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

REPO = "acme/app"
RULES = {"bug": "sam", "docs": "lee"}

@on_trigger
def run(event):
    since = state.get("since") or datetime.now(timezone.utc).strftime("%Y-%m-%dT%H:%M:%SZ")
    issues = [i for i in gh("GET", f"/repos/{REPO}/issues", params={"since": since, "state": "open", "per_page": 50})
              if "pull_request" not in i and not i["assignees"]]
    comments = [c for c in gh("GET", f"/repos/{REPO}/issues/comments", params={"since": since, "per_page": 50})
                if c["body"].strip().lower().startswith("/assign")]
    report_fetched(len(issues) + len(comments))
    state.set("since", datetime.now(timezone.utc).strftime("%Y-%m-%dT%H:%M:%SZ"))
    if not issues and not comments:
        return {"assigned": 0}
    for issue in issues:
        who = next((RULES[l["name"]] for l in issue["labels"] if l["name"] in RULES), None)
        if who:
            gh("POST", f"/repos/{REPO}/issues/{issue['number']}/assignees", json={"assignees": [who]})
    for c in comments:
        number, user = c["issue_url"].rsplit("/", 1)[1], c["user"]["login"]
        gh("POST", f"/repos/{REPO}/issues/{number}/assignees", json={"assignees": [user]})
        gh("POST", f"/repos/{REPO}/issues/{number}/comments", json={"body": f"Assigned to @{user}."})
    return {"issues": len(issues), "commands": len(comments)}