trabajo-afectivo/lib/sequencer/unit/import/freshdesk/sub_sequence/generic.rb

# Copyright (C) 2012-2021 Zammad Foundation, http://zammad-foundation.org/

class Sequencer
  class Unit
    module Import
      module Freshdesk
        module SubSequence
          class Generic < Sequencer::Unit::Base

            uses :dry_run, :import_job, :field_map, :id_map

            attr_accessor :iteration, :result

            EXPECTING = %i[action response].freeze

            def process
              loop.each_with_index do |_, iteration|
                @iteration = iteration
                @result = ::Sequencer.process(sequence_name,
                                              parameters: {
                                                request_params:      request_params,
                                                import_job:          import_job,
                                                dry_run:             dry_run,
                                                object:              object,
                                                field_map:           field_map,
                                                id_map:              id_map,
                                                skipped_resource_id: skipped_resource_id,
                                              },
                                              expecting:  self.class.const_get(:EXPECTING))
                break if iteration_should_stop?
              end
            end

            def request_params
              {
                page: page,
              }
            end

            def page
              iteration + 1
            end

            def object
              @object ||= self.class.name.demodulize.singularize
            end

            def sequence_name
              raise NotImplementedError
            end

            private

            def skipped_resource_id
              @skipped_resource_id ||= nil
            end

            def iteration_should_stop?
              return true if result[:action] == :failed
              return true if result[:response].header['link'].blank?

              false
            end
          end
        end
      end
    end
  end
end