Triage new GitHub issues with AI and flag urgent ones

from clickruntime import on_event, credentials, http, notify, verify, 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)

SCHEMA = {"type": "object", "properties": {"type": {"type": "string", "enum": ["bug", "feature", "question"]},
          "priority": {"type": "string", "enum": ["high", "medium", "low"]}, "duplicate_of": {"type": "integer"}}}

@on_event
def handle(event):
    if not verify.github(event.body, event.header("X-Hub-Signature-256"), credentials.secret("GITHUB_WEBHOOK_SECRET")):
        return {"ignored": "bad signature"}
    body = event.json
    if event.header("X-GitHub-Event") != "issues" or body["action"] != "opened":
        return {"ignored": True}
    issue, repo = body["issue"], body["repository"]["full_name"]
    open_issues = gh("GET", f"/repos/{repo}/issues", params={"state": "open", "per_page": 50})
    others = "\n".join(f"#{i['number']} {i['title']}" for i in open_issues if i["number"] != issue["number"])
    t = ai.generate(f"New issue: {issue['title']}\n{(issue.get('body') or '')[:3000]}\n\nOpen issues:\n{others}", json_schema=SCHEMA, max_output_tokens=80,
                    system="Classify the new issue. Set duplicate_of only if it is clearly the same as an open issue, else 0.").json
    gh("POST", f"/repos/{repo}/issues/{issue['number']}/labels", json={"labels": [t["type"], f"priority: {t['priority']}"]})
    if t.get("duplicate_of"):
        gh("POST", f"/repos/{repo}/issues/{issue['number']}/comments", json={"body": f"This looks like it may be the same as #{t['duplicate_of']}."})
    if t["priority"] == "high":
        notify.slack(f"High-priority {t['type']}: <{issue['html_url']}|{issue['title']}>", channel="#eng")
    return t