Example of pushing a order payload to a transactional email service only when the state on the order is unique. http://github.com/nebulab/cangaroo/pulls

cangaroo_order_job.rb

module Mandrill
  class OrderJob < Cangaroo::Job
    include Rollbar::ActiveJob

    connection :mandrill
    path '/orders'

    def perform?
      type == 'orders' &&

      %w(the_store the_internet).include?(self.payload["channel"]) &&

      self.unique_state?
    end

    # we only want to send an email once based on if we have received this payload in the past
    # we'll need to query the cangaroo translation log to see if any matching payloads for this order have existed before

    def unique_state?
      !self.
        translation.
        related_translations.
        map { |t| t.request['status'] }.
        uniq.
        include? self.payload['status']
    end

  end
end