Post videos and images from Drive to LinkedIn

from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from clickruntime import on_trigger, credentials, http, notify

QUEUE, POSTED = "queue-folder-id", "posted-folder-id"

@on_trigger
def run(event):
    drive = build("drive", "v3", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False)
    files = drive.files().list(q=f"'{QUEUE}' in parents and trashed = false and mimeType contains 'image/'",
                               orderBy="createdTime", pageSize=1, fields="files(id,name,description)").execute()["files"]
    if not files:
        return {"posted": False}
    f = files[0]
    data = drive.files().get_media(fileId=f["id"]).execute()
    headers = {"Authorization": "Bearer " + credentials.connection("linkedin", "main"), "LinkedIn-Version": "202405"}
    me = "urn:li:person:" + http.get("https://api.linkedin.com/v2/userinfo", headers=headers).json()["sub"]
    init = http.post("https://api.linkedin.com/rest/images?action=initializeUpload", headers=headers,
                     json={"initializeUploadRequest": {"owner": me}}).json()["value"]
    http.put(init["uploadUrl"], data=data, headers={"Authorization": headers["Authorization"]}).raise_for_status()
    http.post("https://api.linkedin.com/rest/posts", headers=headers, json={
        "author": me, "commentary": f.get("description") or f["name"], "visibility": "PUBLIC", "lifecycleState": "PUBLISHED",
        "content": {"media": {"id": init["image"]}},
        "distribution": {"feedDistribution": "MAIN_FEED", "targetEntities": [], "thirdPartyDistributionChannels": []}}).raise_for_status()
    drive.files().update(fileId=f["id"], addParents=POSTED, removeParents=QUEUE).execute()
    notify.email_me(f"Posted on LinkedIn: {f['name']}", f.get("description") or "")
    return {"posted": f["name"]}