# frozen_string_literal: true

module Spotlight
  ##
  # Reindex the given resources or exhibits
  class ReindexJob < Spotlight::ApplicationJob
    include Spotlight::JobTracking
    with_job_tracking(resource: ->(job) { job.exhibit })

    include Spotlight::LimitConcurrency

    before_perform do |job|
      pagination = job.arguments.last.slice(:start, :finish) if job.arguments.last.is_a? Hash
      pagination ||= {}

      progress.total = resource_list(job.arguments.first, **pagination).sum(&:estimated_size)
    end

    after_perform do
      exhibit&.touch # rubocop:disable Rails/SkipsModelValidations
    end

    after_perform :commit

    # rubocop:disable Metrics/AbcSize, Metrics/MethodLength
    def perform(exhibit_or_resources, start: nil, finish: nil, **)
      errors = 0

      error_handler = lambda do |pipeline, exception, _data|
        job_tracker.append_log_entry(
          type: :error,
          exhibit: exhibit,
          message: exception.to_s,
          backtrace: exception.backtrace.first(5).join("\n"),
          resource_id: (pipeline.source.id if pipeline.source.respond_to?(:id))
        )
        mark_job_as_failed!
        errors += 1
      end

      resource_list(exhibit_or_resources, start: start, finish: finish).each do |resource|
        resource.reindex(touch: false, commit: false, job_tracker: job_tracker, additional_data: job_data, on_error: error_handler) do |*|
          progress&.increment
        end
      rescue StandardError => e
        error_handler.call(Struct.new(:source).new(resource), e, nil)
      end

      job_tracker.append_log_entry(
        type: :summary,
        exhibit: exhibit,
        message: I18n.t(
          'spotlight.job_trackers.show.messages.status.in_progress',
          progress: progress.progress,
          total: progress.total,
          errors: (I18n.t('spotlight.job_trackers.show.messages.errors', count: errors) if errors.positive?)
        ),
        progress: progress.progress, total: progress.total, errors: errors
      )
    end
    # rubocop:enable Metrics/AbcSize, Metrics/MethodLength

    def exhibit
      exhibit_or_resources = arguments.first

      case exhibit_or_resources
      when Spotlight::Exhibit
        exhibit_or_resources
      when Spotlight::Resource
        exhibit_or_resources.exhibit
      end
    end

    private

    def commit
      Blacklight.default_index.connection.commit
    end

    def job_data
      return unless job_tracker

      @job_data ||= { Spotlight::Engine.config.job_tracker_id_field => job_tracker.top_level_job_tracker.job_id }
    end

    def resource_list(exhibit_or_resources, start: nil, finish: nil)
      if exhibit_or_resources.is_a?(Spotlight::Exhibit)
        exhibit_or_resources.resources.find_each(start: start, finish: finish)
      else
        Array(exhibit_or_resources)
      end
    end
  end
end