codevise/pageflow

module Pageflow
  class PollZencoderJob < ApplicationJob
    queue_as :resizing

    include StateMachineJob

    def perform_with_result(file, options, api = ZencoderApi.instance)
      options ||= {}

      catch(:halt) do
        poll_zencoder(file, api)
        fetch_input_details(file, api)
        file.post_process_encoded_files unless options[:skip_post_processing]

        :ok
      end
    ensure
      file.save!
    end

    private

    def poll_zencoder(file, api)
      info = api.get_info(file.job_id)

      file.encoding_progress = info[:finished] ? 100 : info[:progress];
      file.encoding_error_message = nil

      if info[:state] === 'failed'
        throw(:halt, :error)
      elsif !info[:finished]
        throw(:halt, :pending)
      end
    rescue ZencoderApi::RecoverableError => e
      file.encoding_error_message = e.message
      throw(:halt, :pending)
    rescue ZencoderApi::Error => e
      file.encoding_error_message = e.message
      raise
    end

    def fetch_input_details(file, api)
      file.meta_data_attributes = api.get_details(file.job_id)
    rescue ZencoderApi::RecoverableError => e
      file.encoding_error_message = e.message
      throw(:halt, :pending)
    rescue ZencoderApi::Error => e
      file.encoding_error_message = e.message
      raise
    end
  end
end