Contents

module Fogged
  module Resources
    class ZencoderPollJob < ActiveJob::Base
      def perform(resource)
        return unless Fogged.zencoder_enabled
        update_encoding_progress(resource)

        return if resource.encoding_progress == 100

        frequency = Fogged.zencoder_polling_frequency
        retry_job(:wait => frequency.seconds)
      end

      private

      def update_encoding_progress(resource)
        job = Zencoder::Job.progress(resource.encoding_job_id)

        case job.body["state"]
        when "finished"
          job = Zencoder::Job.details(resource.encoding_job_id)
          f = job.body["job"]["output_media_files"][0]
          resource.update!(
            :encoding_progress => 100,
            :width => f["width"],
            :height => f["height"],
            :duration => f["duration_in_ms"].to_f / 1000.0
          )
        when "processing", "waiting"
          resource.update!(:encoding_progress => job.body["progress"].to_i)
        else
          fail(ArgumentError, "Unknown Zencoder job state #{job.body["state"]}")
        end
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
fogged-0.0.5	app/jobs/fogged/resources/zencoder_poll_job.rb