zammad/lib/sequencer/unit/import/freshdesk/sub_sequence/generic.rb

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

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

  uses :dry_run, :import_job, :field_map, :id_map, :time_entry_available, :skip_initial_contacts

  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,
                                      skip_initial_contacts: skip_initial_contacts,
                                      time_entry_available:  time_entry_available,
                                    },
                                    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 || result[:action] == :skipped
    return true if result[:response].header['link'].blank?

    false
  end
end