Sha256: bfd2ae39dbc2156fe08f4dea8cfd43f430ea2a213a0b44e3c27bd2900cdcb2dc
Contents?: true
Size: 1.88 KB
Versions: 7
Compression:
Stored size: 1.88 KB
Contents
require 'active_encode'
module Hydra::Derivatives::Processors
class ActiveEncodeError < StandardError
def initialize(status, source_path, errors = [])
msg = "ActiveEncode status was \"#{status}\" for #{source_path}"
msg = "#{msg}: #{errors.join(' ; ')}" if errors.any?
super(msg)
end
end
class ActiveEncode < Processor
class_attribute :timeout
attr_accessor :encode_class
attr_reader :encode_job
def initialize(source_path, directives, opts = {})
super
@encode_class = opts.delete(:encode_class) || ::ActiveEncode::Base
end
def process
@encode_job = encode_class.create(source_path, directives)
timeout ? wait_for_encode_job_with_timeout : wait_for_encode_job
encode_job.output.each do |output|
output_file_service.call(output, directives)
end
end
private
def wait_for_encode_job_with_timeout
Timeout.timeout(timeout) { wait_for_encode_job }
rescue Timeout::Error
cleanup_after_timeout
end
# Wait until the encoding job is finished. If the status
# is anything other than 'completed', raise an error.
def wait_for_encode_job
sleep Hydra::Derivatives.active_encode_poll_time while encode_job.reload.running?
raise ActiveEncodeError.new(encode_job.state, source_path, encode_job.errors) unless encode_job.completed?
end
# After a timeout error, try to cancel the encoding.
def cleanup_after_timeout
encode_job.cancel!
rescue StandardError => e
cancel_error = e
ensure
msg = "Unable to process ActiveEncode derivative: The command took longer than #{timeout} seconds to execute. Encoding will be cancelled."
msg = "#{msg} An error occurred while trying to cancel encoding: #{cancel_error}" if cancel_error
raise Hydra::Derivatives::TimeoutError, msg
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems