Publish queued posts to Facebook and Instagram

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

G = "https://graph.facebook.com/v21.0"
PAGE_ID = "104857600000000"

def page_token():
    user = credentials.connection("facebook", "work")
    return http.get(f"{G}/{PAGE_ID}", params={"fields": "access_token", "access_token": user}).json()["access_token"]

IG_USER_ID = "17841400000000000"

@on_event
def enqueue(event):
    queue = state.get("queue") or []
    queue.append({"image_url": event.json["image_url"], "caption": event.json.get("caption", "")})
    state.set("queue", queue)
    return {"queued": len(queue)}

@on_trigger
def publish(event):
    queue = state.get("queue") or []
    if not queue:
        return {"published": False}
    item = queue[0]
    try:
        token = page_token()
        http.post(f"{G}/{PAGE_ID}/photos", data={"url": item["image_url"], "caption": item["caption"],
                                                 "access_token": token}).raise_for_status()
        container = http.post(f"{G}/{IG_USER_ID}/media", data={"image_url": item["image_url"], "caption": item["caption"],
                                                               "access_token": token}).json()["id"]
        http.post(f"{G}/{IG_USER_ID}/media_publish", data={"creation_id": container, "access_token": token}).raise_for_status()
    except Exception as e:
        notify.email_me("Scheduled post failed", f"{item['caption'][:80]}\n\n{e}")
        raise
    state.set("queue", queue[1:])
    return {"published": True, "left": len(queue) - 1}