Transloadit blocking assembly runner

transloadit_blocking_assembly_runner.rb

# Blocks until response received
# Designed to be run from a background job, not in request-response
# Usage:
#   assembly = Transloadit::Rails::Engine.template :my_template
#   response = TransloaditBlockingAssemblyRunner.run assembly
#   results = response['results']
module TransloaditBlockingAssemblyRunner
  class Error < StandardError; end
  class TimeoutError < Error; end
  class AssemblyError < Error; end

  MAX_RESPONSE_CHECKS = 60 * 5

  def self.run assembly
    response = assembly.submit!

    response_checks = 0

    until response.finished?
      response_checks += 1

      if response_checks > MAX_RESPONSE_CHECKS
        raise TimeoutError, "MAX_RESPONSE_CHECKS exceeded"
      end

      sleep 1
      response.reload!
    end

    if response.error?
      raise AssemblyError, response['message']
    else
      response
    end
  end
end