mirror of
https://github.com/discourse/discourse.git
synced 2026-08-06 05:42:36 +08:00
390cfb7820Configure the aws mediaconvert adapter to use a subdirectory for the output of video conversions. This way mediaconvert doesn't need full access to the uploads directory and only needs access to the subdirectory. This adds a new site setting for the media convert subdirectory to use.
40 lines
1.3 KiB
Ruby
Vendored
40 lines
1.3 KiB
Ruby
Vendored
# frozen_string_literal: true
|
|
module Jobs
|
|
class CheckVideoConversionStatus < ::Jobs::Base
|
|
sidekiq_options queue: "low", concurrency: 5
|
|
|
|
def execute(args)
|
|
return if args[:upload_id].blank? || args[:job_id].blank? || args[:adapter_type].blank?
|
|
|
|
upload = Upload.find_by(id: args[:upload_id])
|
|
return if upload.blank?
|
|
|
|
adapter =
|
|
VideoConversion::AdapterFactory.get_adapter(upload, adapter_type: args[:adapter_type])
|
|
|
|
status = adapter.check_status(args[:job_id])
|
|
|
|
case status
|
|
when :complete
|
|
if adapter.handle_completion(args[:job_id], args[:new_sha1])
|
|
# Successfully completed
|
|
Rails.logger.info(
|
|
"Completed video conversion for upload ID #{upload.id} and job ID #{args[:job_id]}",
|
|
)
|
|
else
|
|
# Handle completion failed
|
|
Rails.logger.error(
|
|
"Failed to handle video conversion completion for upload ID #{upload.id} and job ID #{args[:job_id]}",
|
|
)
|
|
end
|
|
when :error
|
|
Rails.logger.error(
|
|
"Video conversion job failed for upload ID #{upload.id} and job ID #{args[:job_id]}",
|
|
)
|
|
when :pending
|
|
# Re-enqueue the job to check again
|
|
Jobs.enqueue_in(30.seconds, :check_video_conversion_status, args)
|
|
end
|
|
end
|
|
end
|
|
end
|
