method_call_recorder.rb

require 'thread'

class Sqewer::CallRecorder
  Call = Struct.new(:method_name, :args, :blk)
  NOOP = ->(*){}
  
  def initialize(proxying_to)
    @obj = proxying_to
    @mutex = Mutex.new
    @calls = []
  end
  
  def respond_to_missing?(m, *a)
    @obj.respond_to?(m, *a)
  end
  
  def method_missing(m, *a, &blk)
    blk ||= NOOP
    @mutex.synchronize {
      @calls << Call.new(m, a, blk)
    }
  end
  
  def __replay(on_object)
    @mutex.synchronize {
      @calls.each do | call |
        on_object.public_send(call.method_name, call.args, &call.blk)
      end
      @calls.clear
    }
  end
end