Tick off Google Tasks when a commit finishes them

from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from clickruntime import on_event, credentials, notify, ai

SCHEMA = {"type": "object", "properties": {"done": {"type": "array", "items": {"type": "object", "properties": {
    "task_id": {"type": "string"}, "commit": {"type": "string"}}}}}}

@on_event
def handle(event):
    if not event.is_verified:
        return {"skipped": "unverified"}
    commits = [c["message"].splitlines()[0] for c in (event.json or {}).get("commits", [])]
    if not commits:
        return {"completed": 0}
    tasks = build("tasks", "v1", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False).tasks()
    open_tasks = {t["id"]: t["title"] for t in tasks.list(tasklist="@default", showCompleted=False).execute().get("items", [])}
    if not open_tasks:
        return {"completed": 0}
    matches = ai.generate("Which tasks do these commits clearly finish? Only include certain matches.\nTasks:\n"
                          + "\n".join(f"{i}: {t}" for i, t in open_tasks.items()) + "\nCommits:\n" + "\n".join(commits),
                          json_schema=SCHEMA, max_output_tokens=300).json["done"]
    lines = []
    for m in matches:
        if m["task_id"] in open_tasks:
            tasks.patch(tasklist="@default", task=m["task_id"], body={"status": "completed"}).execute()
            lines.append(f"• {open_tasks[m['task_id']]} ← {m['commit']}")
    if lines:
        notify.slack(f"Completed by push to {event.json['repository']['name']}:\n" + "\n".join(lines), channel="#dev")
    return {"completed": len(lines)}