Turn meeting transcripts in Drive into Jira tasks

from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from clickruntime import on_trigger, credentials, http, notify, state, ai, report_fetched

JIRA, SITE = "https://api.atlassian.com/ex/jira/your-cloud-id", "https://acme.atlassian.net/browse/"
adf = lambda text: {"type": "doc", "version": 1, "content": [{"type": "paragraph", "content": [{"type": "text", "text": text}]}]}

def jira(method, path, **kw):
    resp = http.request(method, JIRA + path, headers={"Authorization": f"Bearer {credentials.connection('jira', 'work')}", "Accept": "application/json"}, **kw)
    return resp.raise_for_status() or (resp.json() if resp.content else None)

FOLDER = "transcripts-folder-id"
SCHEMA = {"type": "object", "properties": {"actions": {"type": "array", "items": {"type": "object", "properties": {
    "task": {"type": "string"}, "owner": {"type": "string"}, "due": {"type": "string"}}}}}}

@on_trigger
def run(event):
    drive = build("drive", "v3", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False).files()
    seen = set(state.get("seen") or [])
    files = [f for f in drive.list(q=f"'{FOLDER}' in parents and mimeType = 'application/vnd.google-apps.document' and trashed = false",
             fields="files(id,name)", orderBy="createdTime desc", pageSize=20).execute()["files"] if f["id"] not in seen]
    report_fetched(len(files))
    if not files:
        return {"tasks": 0}
    lines = []
    for f in files:
        text = drive.export(fileId=f["id"], mimeType="text/plain").execute().decode("utf-8")[:24000]
        actions = ai.generate(text, json_schema=SCHEMA, max_output_tokens=800,
                              system="List the agreed action items with owner name and due date (YYYY-MM-DD or empty).").json["actions"]
        for a in actions:
            fields = {"project": {"key": "PM"}, "issuetype": {"name": "Task"}, "summary": f"{a['task']} ({a['owner']})"[:250], "description": adf(f"From meeting: {f['name']}")}
            key = jira("POST", "/rest/api/3/issue", json={"fields": {**fields, **({"duedate": a["due"]} if a.get("due") else {})}})["key"]
            lines.append(f"• {key} {a['task']}, {a['owner']}")
        seen.add(f["id"])
    notify.slack("Action items from today's meetings\n" + "\n".join(lines), channel="#team")
    state.set("seen", sorted(seen)[-500:])
    return {"tasks": len(lines)}