hub_push_worker.rb

class HubPushWorker
  include Sidekiq::Worker
  sidekiq_options unique: true#, unique_unlock_order: :never

  def perform(params)
    klass = params.delete('class_name').constantize
    objs = klass.where(params)

    push_spree_obj(objs)    
  end
  def push_spree_obj(objs)
    first = objs.first
    serializer = serializer_for_spree_obj(first)
    case first
    when Spree::Product
      objs = objs.map(&:variants_including_master).flatten
    end

    json = ActiveModel::ArraySerializer.new(objs, each_serializer:serializer, root: first.class.to_s.demodulize.downcase).to_json
    ap json
  end
  
  def serializer_for_spree_obj(obj)
    case obj
    when Spree::Product
      Spree::Hub::ProductSerializer #raise 'must use variant instead of product'
    when Spree::Variant
      Spree::Hub::ProductSerializer
    when Spree::Order
      Spree::Hub::OrderSerializer
    when Spree::StockItem
      Spree::Hub::InventorySerializer
    when Spree::Address
      Spree::Hub::AddressSerializer
    end    
  end
end