Save new YouTube comments to Airtable

from clickruntime import on_trigger, credentials, http, state, report_fetched

CHANNEL_ID = "UCxxxxxxxxxxxxxxxxxxxxxx"
AT = "https://api.airtable.com/v0/appXXXXXXXXXXXXXX/Comments"

@on_trigger
def run(event):
    r = http.get("https://www.googleapis.com/youtube/v3/commentThreads", params={
        "part": "snippet", "allThreadsRelatedToChannelId": CHANNEL_ID, "order": "time",
        "maxResults": 100, "textFormat": "plainText", "key": credentials.secret("YOUTUBE_API_KEY")})
    r.raise_for_status()
    seen = state.get("seen") or []
    new = [t for t in r.json().get("items", []) if t["id"] not in seen]
    report_fetched(len(new))
    if not new:
        return {"saved": 0}
    ids = list({t["snippet"]["videoId"] for t in new})
    vids = http.get("https://www.googleapis.com/youtube/v3/videos", params={
        "part": "snippet", "id": ",".join(ids[:50]), "key": credentials.secret("YOUTUBE_API_KEY")}).json()["items"]
    titles = {v["id"]: v["snippet"]["title"] for v in vids}
    rows = []
    for t in reversed(new):
        c = t["snippet"]["topLevelComment"]["snippet"]
        vid = t["snippet"]["videoId"]
        rows.append({"fields": {"Video": titles.get(vid, vid), "Author": c["authorDisplayName"], "Comment": c["textDisplay"],
                                "Likes": c["likeCount"], "Posted": c["publishedAt"], "Status": "New",
                                "Link": f"https://www.youtube.com/watch?v={vid}&lc={t['id']}"}})
    headers = {"Authorization": f"Bearer {credentials.connection('airtable', 'work')}"}
    for i in range(0, len(rows), 10):
        http.post(AT, headers=headers, json={"records": rows[i:i + 10], "typecast": True}).raise_for_status()
    state.set("seen", (seen + [t["id"] for t in new])[-3000:])
    return {"saved": len(rows)}