Contents

module Workarea
  class RestockNotifier
    include Sidekiq::Worker
    include Sidekiq::CallbacksWorker

    sidekiq_options(
      enqueue_on: { Inventory::Sku => :save },
      queue: 'low',
      retry: false
    )

    def perform(id)
      sku = Inventory::Sku.find(id)

      return unless sku.purchasable?

      InventoryNotification.unsent.where(sku: sku.id).each do |notification|
        send_notification(notification);
      end
    end

    def send_notification(notification)
      attrs = notification.attributes.values_at('product_id', 'sku', 'email')
      notification.mark_as_sent! if Storefront::InventoryUpdateMailer.notify(*attrs).deliver
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
workarea-inventory_notifications-2.1.5	app/workers/workarea/restock_notifier.rb
workarea-inventory_notifications-2.1.4	app/workers/workarea/restock_notifier.rb
workarea-inventory_notifications-2.1.3	app/workers/workarea/restock_notifier.rb
workarea-inventory_notifications-2.1.2	app/workers/workarea/restock_notifier.rb