Check how each new TikTok is doing after two days

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

API = "https://open.tiktokapis.com/v2"

@on_trigger
def run(event):
    auth = {"Authorization": "Bearer " + credentials.connection("tiktok", "main")}
    waiting = state.get("waiting") or {}
    videos = http.post(f"{API}/video/list/", params={"fields": "id,create_time"}, headers=auth, json={"max_count": 10}).json()["data"]["videos"]
    seen = set(state.get("seen") or [])
    new = [v for v in videos if v["id"] not in seen]
    due = [vid for vid, t in waiting.items() if time.time() - t >= 48 * 3600]
    report_fetched(len(new) + len(due))
    if not new and not due:
        return {"summary": "Nothing new or due"}
    for v in new:
        waiting[v["id"]] = v["create_time"]
        seen.add(v["id"])
    if due:
        fields = "id,title,view_count,like_count,comment_count,share_count,share_url"
        stats = http.post(f"{API}/video/query/", params={"fields": fields}, headers=auth,
                          json={"filters": {"video_ids": due}}).json()["data"]["videos"]
        for v in stats:
            notify.email_me(f"48h check-in: {v['title'][:60]}", f"Views {v['view_count']:,} · Likes {v['like_count']:,} · Comments {v['comment_count']} · Shares {v['share_count']}\n{v['share_url']}")
            waiting.pop(v["id"], None)
    state.set("waiting", waiting)
    state.set("seen", list(seen)[-200:])
    return {"new": len(new), "reported": len(due)}