hub.rake

namespace :hub do
  namespace :push do
    task :products, [:limit] => [:environment] do |t, args|
      limit = args[:limit]

      Spree::Product.all.limit(limit).each do |p|
        # variants = p.variants_including_master
        ap HubPushWorker.perform_async({class_name:'Spree::Product',id:p.id})
      end
    end
    task :orders, [:limit] => [:environment] do |t, args|
      limit = args[:limit]

      Spree::Order.complete.limit(limit).each do |o|
        ap HubPushWorker.perform_async({class_name:'Spree::Order',number:o.number})
      end
    end    
    task :inventory, [:limit] => [:environment] do |t, args|
      limit = args[:limit]
      Spree::StockItem.limit(limit).each do |si|
        ap HubPushWorker.perform_async({class_name:'Spree::StockItem',id:si.id})
      end
    end        
        
  end
end