mirror of
https://github.com/blw1138/Zordon.git
synced 2025-12-17 08:48:13 +00:00
56 lines
2.2 KiB
Python
56 lines
2.2 KiB
Python
import json
|
|
import logging
|
|
import os
|
|
import subprocess
|
|
import threading
|
|
|
|
import requests
|
|
|
|
from .ffmpeg_helper import generate_thumbnail, save_first_frame
|
|
from lib.render_workers.render_worker import RenderStatus
|
|
|
|
logger = logging.getLogger()
|
|
|
|
|
|
def post_job_to_server(input_path, job_list, hostname, server_port=8080):
|
|
# Pack job data and submit to server
|
|
job_files = {'file': (os.path.basename(input_path), open(input_path, 'rb'), 'application/octet-stream'),
|
|
'json': (None, json.dumps(job_list), 'application/json')}
|
|
|
|
req = requests.post(f'http://{hostname}:{server_port}/api/add_job', files=job_files)
|
|
return req
|
|
|
|
|
|
def generate_thumbnail_for_job(job, thumb_video_path, thumb_image_path, max_width=320):
|
|
|
|
# Simple thread to generate thumbs in background
|
|
def generate_thumb_thread(source):
|
|
in_progress_path = thumb_video_path + '_IN-PROGRESS'
|
|
subprocess.run(['touch', in_progress_path])
|
|
try:
|
|
generate_thumbnail(source_path=source, dest_path=thumb_video_path, max_width=max_width)
|
|
except Exception as e:
|
|
logger.error(f"Error generating thumbnail for {source}: {e}")
|
|
finally:
|
|
os.remove(in_progress_path)
|
|
|
|
# Determine best source file to use for thumbs
|
|
if job.render_status() == RenderStatus.COMPLETED: # use finished file for thumb
|
|
source_path = job.file_list()
|
|
elif len(job.file_list()) > 1: # if image sequence, use second to last file (last may be in use)
|
|
source_path = [job.file_list()[-2]]
|
|
else:
|
|
source_path = [job.input_path] # use source if nothing else
|
|
|
|
if source_path:
|
|
# Todo: convert image sequence to animated movie
|
|
valid_formats = ['.mp4', '.mov', '.avi', '.mpg', '.mpeg', '.jpg', '.png', '.exr', '.mxf']
|
|
is_valid_file_type = any(ele in source_path[0] for ele in valid_formats)
|
|
if is_valid_file_type and not os.path.exists(thumb_video_path):
|
|
try:
|
|
save_first_frame(source_path=source_path[0], dest_path=thumb_image_path, max_width=max_width)
|
|
except Exception as e:
|
|
logger.error(f"Exception saving first frame: {e}")
|
|
x = threading.Thread(target=generate_thumb_thread, args=(source_path[0],))
|
|
x.start()
|