require "test_helper"

module Fogged
  module Resources
    class ZencoderPollJobTest < ActiveSupport::TestCase
      def setup
        super
        @resource = fogged_resources(:encoding_resource)
      end

      test "should poll job with status success" do
        in_a_fork do
          require "zencoder"
          require "delayed_job_active_record"
          Rails.application.config.active_job.queue_adapter = :delayed_job
          Fogged.configure

          Zencoder::Job.expects(:progress).with("1234567890").returns(
            OpenStruct.new(:body => progress_output("finished"))
          )
          Zencoder::Job.expects(:details).with("1234567890").returns(
            OpenStruct.new(:body => details_output)
          )

          assert_no_difference("Delayed::Job.count") do
            ZencoderPollJob.perform_now(@resource)
          end
          refute @resource.reload.encoding?
          assert_equal 800, @resource.width
          assert_equal 600, @resource.height
          assert_equal 15, @resource.duration
        end
      end

      %w(processing waiting).each do |status|
        test "should poll job with status #{status}" do
          in_a_fork do
            require "zencoder"
            require "delayed_job_active_record"
            Rails.application.config.active_job.queue_adapter = :delayed_job
            Fogged.configure

            Zencoder::Job.expects(:progress).with("1234567890").returns(
              OpenStruct.new(:body => progress_output(status))
            )

            assert_difference("Delayed::Job.count") do
              ZencoderPollJob.perform_now(@resource)
            end
            assert @resource.reload.encoding?
            assert_equal 55, @resource.encoding_progress
          end
        end
      end

      test "should poll job with status unknown" do
        in_a_fork do
          require "zencoder"
          require "delayed_job_active_record"
          Fogged.configure

          Zencoder::Job.expects(:progress).with("1234567890").returns(
            OpenStruct.new(:body => progress_output("unknown"))
          )

          assert_raise(ArgumentError) do
            assert_no_difference("Delayed::Job.count") do
              ZencoderPollJob.perform_now(@resource)
            end
          end
        end
      end

      private

      def progress_output(state)
        {
          :state => state,
          :progress => "55.5"
        }.with_indifferent_access
      end

      def details_output
        {
          :job => {
            :output_media_files => [{
              :width => 800,
              :height => 600,
              :duration_in_ms => 15753
            }]
          }
        }.with_indifferent_access
      end
    end
  end
end