Label new issues and flag duplicates

from clickruntime import on_trigger, credentials, http, ai, 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"
SCHEMA = {"type": "object", "properties": {"label": {"enum": ["bug", "feature", "question"]},
          "duplicate_of": {"type": ["integer", "null"]}}}

@on_trigger
def run(event):
    last = state.get("last_number") or 0
    open_issues = [i for i in gh("GET", f"/repos/{REPO}/issues", params={"state": "open", "per_page": 100})
                   if "pull_request" not in i]
    new = [i for i in open_issues if i["number"] > last]
    report_fetched(len(new))
    if not new:
        return {"triaged": 0}
    for issue in sorted(new, key=lambda i: i["number"]):
        others = "\n".join(f"#{i['number']} {i['title']}" for i in open_issues if i["number"] != issue["number"])[:6000]
        out = ai.generate(f"New issue: {issue['title']}\n{(issue['body'] or '')[:2000]}\n\nOpen issues:\n{others}",
                          system="Label the new issue and give the number of an open issue it duplicates, or null.",
                          json_schema=SCHEMA, max_output_tokens=40).json
        gh("POST", f"/repos/{REPO}/issues/{issue['number']}/labels", json={"labels": [out["label"]]})
        if out.get("duplicate_of"):
            gh("POST", f"/repos/{REPO}/issues/{issue['number']}/comments",
               json={"body": f"This looks like a duplicate of #{out['duplicate_of']}."})
    state.set("last_number", max(i["number"] for i in new))
    return {"triaged": len(new)}