Sha256: 8bc7a2da07dc68684779d759a4f37cccb70af1d3df2aa28f20fe3a79705f4515
Contents?: true
Size: 1.37 KB
Versions: 15
Compression:
Stored size: 1.37 KB
Contents
# frozen_string_literal: true
module Spotlight
##
# Reindex the given resources or exhibits
class ReindexJob < ActiveJob::Base
queue_as :default
before_perform do |job|
job_log_entry = log_entry(job)
next unless job_log_entry
items_reindexed_estimate = resource_list(job.arguments.first).sum do |resource|
resource.document_builder.documents_to_index.size
end
job_log_entry.update(items_reindexed_estimate: items_reindexed_estimate)
end
around_perform do |job, block|
job_log_entry = log_entry(job)
job_log_entry.in_progress! if job_log_entry
begin
block.call
rescue
job_log_entry.failed! if job_log_entry
raise
end
job_log_entry.succeeded! if job_log_entry
end
def perform(exhibit_or_resources, log_entry = nil)
resource_list(exhibit_or_resources).each do |resource|
resource.reindex(log_entry)
end
end
private
def resource_list(exhibit_or_resources)
if exhibit_or_resources.is_a?(Spotlight::Exhibit)
exhibit_or_resources.resources.find_each
elsif exhibit_or_resources.is_a?(Enumerable)
exhibit_or_resources
else
Array(exhibit_or_resources)
end
end
def log_entry(job)
job.arguments.second if job.arguments.second.is_a?(Spotlight::ReindexingLogEntry)
end
end
end
Version data entries
15 entries across 15 versions & 1 rubygems