Sha256: 442b800367eae2ea75d35f30af65eb61e81a566d3df4446a2c50a55f29a01a6b
Contents?: true
Size: 660 Bytes
Versions: 15
Compression:
Stored size: 660 Bytes
Contents
module Workarea
class BulkIndexProducts
include Sidekiq::Worker
sidekiq_options lock: :until_executing
class << self
def perform(ids = Catalog::Product.pluck(:id))
ids.each_slice(100) do |group|
perform_by_models(Catalog::Product.in(id: group).to_a)
end
end
def perform_by_models(products)
return if products.blank?
Search::Storefront.bulk do
Search::ProductEntries.new(products).map(&:as_bulk_document)
end
products.each { |p| p.set(last_indexed_at: Time.current) }
end
end
def perform(ids)
self.class.perform(ids)
end
end
end
Version data entries
15 entries across 15 versions & 1 rubygems