Turn meeting transcripts into action items and follow-ups

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

FOLDER_ID = "your-meet-recordings-folder-id"
SCHEMA = {"type": "object", "properties": {"actions": {"type": "array", "items": {"type": "string"}},
          "followups": {"type": "array", "items": {"type": "object", "properties": {"title": {"type": "string"}, "start": {"type": "string"}, "end": {"type": "string"}}}}}}

@on_trigger
def run(event):
    creds = Credentials(credentials.connection("google", "work"))
    drive, cal = build("drive", "v3", credentials=creds, cache_discovery=False), build("calendar", "v3", credentials=creds, cache_discovery=False)
    seen = set(state.get("seen") or [])
    files = drive.files().list(q=f"'{FOLDER_ID}' in parents and mimeType='application/vnd.google-apps.document' and trashed=false", fields="files(id,name)").execute()["files"]
    new = [f for f in files if f["id"] not in seen]
    report_fetched(len(new))
    if not new:
        return {"summary": "Nothing new"}
    for f in new:
        text = drive.files().export(fileId=f["id"], mimeType="text/plain").execute().decode()[:25000]
        r = ai.generate(f"From this transcript list action items with owners and follow-up meetings with ISO start/end times:\n{text}", json_schema=SCHEMA, max_output_tokens=800).json
        notify.email_me(f"Action items: {f['name']}", "\n".join(f"- {a}" for a in r.get("actions", [])) or "No action items found.")
        for fu in r.get("followups", []):
            cal.events().insert(calendarId="primary", body={"summary": fu["title"], "start": {"dateTime": fu["start"]}, "end": {"dateTime": fu["end"]}}).execute()
        seen.add(f["id"])
    state.set("seen", list(seen)[-500:])
    return {"processed": len(new)}