fixes for video posting
This commit is contained in:
55
bsky_post.py
55
bsky_post.py
@@ -318,6 +318,46 @@ def upload_image(
|
|||||||
logging.error(f"❌ Failed to upload image: {repr(e)}")
|
logging.error(f"❌ Failed to upload image: {repr(e)}")
|
||||||
return None
|
return None
|
||||||
|
|
||||||
|
def upload_video_and_wait(
|
||||||
|
client: Client,
|
||||||
|
video_data: bytes,
|
||||||
|
alt_text: str = ""
|
||||||
|
) -> models.AppBskyEmbedVideo.Main | None:
|
||||||
|
try:
|
||||||
|
logging.info("🎬 Uploading video to Bluesky Video Service...")
|
||||||
|
|
||||||
|
# 1. Upload the video (this goes to the dedicated video service)
|
||||||
|
# Note: In newer atproto versions, you can use client.upload_blob for videos too,
|
||||||
|
# but you MUST poll the video job status afterwards.
|
||||||
|
response = client.app.bsky.video.upload_video(video_data)
|
||||||
|
job_id = response.job_id
|
||||||
|
|
||||||
|
logging.info(f"⏳ Video uploaded! Job ID: {job_id}. Waiting for processing...")
|
||||||
|
|
||||||
|
# 2. Poll the job status
|
||||||
|
while True:
|
||||||
|
status_resp = client.app.bsky.video.get_job_status({'job_id': job_id})
|
||||||
|
state = status_resp.job_status.state
|
||||||
|
|
||||||
|
if state == 'JOB_STATE_COMPLETED':
|
||||||
|
logging.info("✅ Processing complete! Waiting 10s for CDN propagation...")
|
||||||
|
time.sleep(10) # Give the CDN time to distribute the file
|
||||||
|
|
||||||
|
return models.AppBskyEmbedVideo.Main(
|
||||||
|
video=status_resp.job_status.blob,
|
||||||
|
alt=alt_text
|
||||||
|
)
|
||||||
|
elif state == 'JOB_STATE_FAILED':
|
||||||
|
logging.error("❌ Video processing failed on Bluesky's servers.")
|
||||||
|
return None
|
||||||
|
|
||||||
|
logging.info(" ...still processing...")
|
||||||
|
time.sleep(3) # Wait 3 seconds before checking again
|
||||||
|
|
||||||
|
except Exception as e:
|
||||||
|
logging.error(f"❌ Failed to upload/process video: {repr(e)}")
|
||||||
|
return None
|
||||||
|
|
||||||
|
|
||||||
# ============================================================
|
# ============================================================
|
||||||
# Post
|
# Post
|
||||||
@@ -339,12 +379,17 @@ def post_to_bsky(
|
|||||||
with open(video_path, "rb") as f:
|
with open(video_path, "rb") as f:
|
||||||
video_data = f.read()
|
video_data = f.read()
|
||||||
|
|
||||||
logging.info(f"🚀 Sending video post (this may take a moment to process)...")
|
# Use our custom polling function
|
||||||
# client.send_video automatically handles the video service upload and processing wait
|
video_embed = upload_video_and_wait(client, video_data, alt_text)
|
||||||
result = client.send_video(
|
|
||||||
|
if not video_embed:
|
||||||
|
logging.error("❌ Aborting post: video upload/processing failed.")
|
||||||
|
return False
|
||||||
|
|
||||||
|
logging.info(f"🚀 Sending video post...")
|
||||||
|
result = client.send_post(
|
||||||
text=rich_text,
|
text=rich_text,
|
||||||
video=video_data,
|
embed=video_embed,
|
||||||
video_alt=alt_text,
|
|
||||||
langs=langs
|
langs=langs
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user