Sample scheduler & filter

payload_builder.rb

Spree::Wombat::Config.configure do |config|
  config.connection_token = ENV["HUB_TOKEN"]
  config.connection_id = ENV["HUB_STORE_ID"]

  config.push_objects = ["Spree::Order", "Spree::Shipment"]
  config.payload_builder = {
    "Spree::Order"    => {serializer: 'Spree::Wombat::OrderSerializer', root: 'orders', filter: 'complete' },
    "Spree::Shipment" => {serializer: 'DemoShipmentSerializer', root: 'shipments' }
  }
end

#in this sample the 'filter :complete' will call Spree::Order.complete scope before timestamp check and pushing.

Procfile

scheduler: bundle exec ./push_it_scheduler.rb

push_it_scheduler.rb

# https://github.com/jmettraux/rufus-scheduler

#!/usr/bin/env ruby

## run this from Procfile to push data to wombat periodically

require 'rufus-scheduler'

scheduler = Rufus::Scheduler.new

scheduler.every '10s' do
  system 'rake wombat:push_it'
end

scheduler.join