Simple mocking for Resque

resque_mock.rb

require 'resque'

module Resque
  def self.mock!
    puts "*** Mocking Resque" if ENV['VERBOSE']
    extend MockExt
    @jobs = []
  end

  module MockExt
    def enqueue(klass, *args)
      puts "Mock enqueue: jobs.size=#{@jobs.size}, #{klass}, #{args.inspect}" if ENV['VERBOSE']
      validate(klass)
      add_job('payload' => { 'class' => klass, 'args' => args })
    end

    def process_queue
      while job = @jobs.shift do
        process(job)
      end
    end

    def process(data)
      klass = data['payload']['class']
      puts "Mock perform: #{klass}.perform(*#{data['payload']['args'].inspect})" if ENV['VERBOSE']
      klass.perform(*roundtrip(data['payload']['args']))
      puts "Mock exit: #{klass}.perform(*#{data['payload']['args'].inspect})" if ENV['VERBOSE']
    end

    def roundtrip(args)
      decode(encode(args))
    end

    def add_job(data)
      @jobs << data
    end
  end
end