Post new comments on Google Drive files to Slack

from clickruntime import on_trigger, credentials, http, state, notify
import datetime

FOLDER_ID = "1AbCdEfDeliverablesId"
CHANNEL = "#reviews"

def drive(path, **params):
    resp = http.get(f"https://www.googleapis.com/drive/v3{path}", params=params,
                    headers={"Authorization": f"Bearer {credentials.connection('google', 'work')}"})
    resp.raise_for_status()
    return resp.json()

@on_trigger
def run(event):
    now = datetime.datetime.utcnow().strftime("%Y-%m-%dT%H:%M:%S.000Z")
    since = state.get("since")
    state.set("since", now)
    if since is None:
        return {"baseline": now}
    files = drive("/files", q=f"'{FOLDER_ID}' in parents and trashed = false and modifiedTime > '{since}'",
                  fields="files(id,name,webViewLink)", pageSize=100)["files"]
    posted = 0
    for f in files:
        comments = drive(f"/files/{f['id']}/comments", startModifiedTime=since, pageSize=100,
                         fields="comments(content,createdTime,resolved,author(displayName),quotedFileContent,replies(content,createdTime,action,author(displayName)))")["comments"]
        for c in comments:
            quote = (c.get("quotedFileContent") or {}).get("value")
            q = f"> {quote[:200]}\n" if quote else ""
            if c["createdTime"] > since:
                notify.slack(f"💬 {c['author']['displayName']} on *{f['name']}*\n{q}{c['content'][:1500]}\n{f['webViewLink']}", channel=CHANNEL)
                posted += 1
            for r in c.get("replies", []):
                if r["createdTime"] > since:
                    text = "marked this resolved" if r.get("action") == "resolve" else r["content"][:1500]
                    notify.slack(f"↳ {r['author']['displayName']} on *{f['name']}*: {text}\n{f['webViewLink']}", channel=CHANNEL)
                    posted += 1
    return {"posted": posted}