Turn process notes into SOP documents

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

NOTES_FOLDER, SOP_FOLDER = "your-notes-folder-id", "your-sops-folder-id"

@on_trigger
def run(event):
    creds = Credentials(credentials.connection("google", "work"))
    drive = build("drive", "v3", credentials=creds, cache_discovery=False).files()
    done = state.get("done") or []
    files = [f for f in drive.list(q=f"'{NOTES_FOLDER}' in parents and mimeType='application/vnd.google-apps.document' and trashed=false",
                                   fields="files(id,name)").execute()["files"] if f["id"] not in done]
    report_fetched(len(files))
    if not files:
        return {"summary": "Nothing new"}
    docs = build("docs", "v1", credentials=creds, cache_discovery=False).documents()
    for f in files:
        notes = drive.export(fileId=f["id"], mimeType="text/plain").execute().decode("utf-8")[:15000]
        sop = ai.generate(f"Turn these notes into an SOP with sections Purpose, Who it is for, Steps (numbered), Common mistakes:\n{notes}",
                          max_output_tokens=1800).text
        new = drive.create(body={"name": f"SOP: {f['name']}", "mimeType": "application/vnd.google-apps.document",
                                 "parents": [SOP_FOLDER]}, fields="id").execute()
        docs.batchUpdate(documentId=new["id"], body={"requests": [{"insertText": {"location": {"index": 1}, "text": sop}}]}).execute()
        notify.slack(f"New SOP: {f['name']} https://docs.google.com/document/d/{new['id']}/edit", channel="#ops")
        done.append(f["id"])
    state.set("done", done[-500:])
    return {"created": len(files)}