Post a video to LinkedIn from a link

from clickruntime import on_event, notify, http, credentials

API = "https://api.linkedin.com/rest"

@on_event
def handle(event):
    body = event.json or {}
    token = credentials.connection("linkedin", "main")
    headers = {"Authorization": f"Bearer {token}", "LinkedIn-Version": "202405", "X-Restli-Protocol-Version": "2.0.0"}
    owner = "urn:li:person:" + http.get("https://api.linkedin.com/v2/userinfo", headers=headers).json()["sub"]
    video = http.get(body["video_url"], timeout=60).content
    init = http.post(f"{API}/videos?action=initializeUpload", headers=headers, json={"initializeUploadRequest": {
        "owner": owner, "fileSizeBytes": len(video), "uploadCaptions": False, "uploadThumbnail": False}}).json()["value"]
    etags = []
    for part in init["uploadInstructions"]:
        chunk = video[part["firstByte"]:part["lastByte"] + 1]
        etags.append(http.put(part["uploadUrl"], data=chunk, timeout=120).headers["etag"])
    http.post(f"{API}/videos?action=finalizeUpload", headers=headers, json={"finalizeUploadRequest": {
        "video": init["video"], "uploadToken": init.get("uploadToken", ""), "uploadedPartIds": etags}}).raise_for_status()
    resp = http.post(f"{API}/posts", headers=headers, json={
        "author": owner, "commentary": body.get("caption", ""), "visibility": "PUBLIC",
        "distribution": {"feedDistribution": "MAIN_FEED", "targetEntities": [], "thirdPartyDistributionChannels": []},
        "content": {"media": {"id": init["video"]}}, "lifecycleState": "PUBLISHED",
    })
    resp.raise_for_status()
    notify.email_me("Your LinkedIn video is live", f"https://www.linkedin.com/feed/update/{resp.headers['x-restli-id']}")
    return {"posted": True}