trabajo-afectivo/lib/sequencer/unit/import/zendesk/sub_sequence/base.rb

class Sequencer
  class Unit
    module Import
      module Zendesk
        module SubSequence
          module Base
            module ClassMethods

              def resource_klass
                @resource_klass ||= name.split('::').last.singularize
              end
            end

            def self.included(base)
              base.extend(ClassMethods)

              base.uses :dry_run, :import_job
            end

            private

            def default_params
              {
                dry_run:    dry_run,
                import_job: import_job,
              }
            end

            def resource_klass
              # base.instance_delegate [:resource_klass] => base
              # doesn't work since we are included and then inherited
              # there might be multiple inherited hooks which overwrite
              # each other :/
              self.class.resource_klass
            end

            def sequence_name
              "Import::Zendesk::#{resource_klass}"
            end

            def resource_iteration(&block)
              resource_collection.public_send(resource_iteration_method, &block)
            rescue ZendeskAPI::Error::NetworkError => e
              status = e.response.status.to_s

              if status.match?(/^(4|5)\d\d$/)

                # #2262 Zendesk-Import fails for User & Organizations when 403 "access" denied
                return if status == '403' && resource_klass.in?(%w[UserField OrganizationField])

                raise if (fail_count ||= 1) > 10

                logger.error e
                logger.info "Sleeping 10 seconds after ZendeskAPI::Error::NetworkError and retry (##{fail_count}/10)."
                sleep 10

                (fail_count += 1) && retry
              end

              raise
            end

            def resource_collection
              @resource_collection ||= collection_provider.public_send(resource_collection_attribute)
            end

            def resource_iteration_method
              :all!
            end

            def resource_collection_attribute
              @resource_collection_attribute ||= resource_klass.pluralize.underscore
            end
          end
        end
      end
    end
  end
end