Contents

require 'request-replay'

class RequestReplay::Middleware
  def initialize app, host, options={}
    @app, @host, @options = app, host, options
  end

  def call env
    # We don't want to read the socket in a thread, so create it in main
    # thread, and send the data in a thread as we don't care the responses.
    Thread.new(RequestReplay.new(rewrite_env(env), @host, @options), &:start)
    @app.call(env)
  end

  def rewrite_env env
    # Unfortunately, we need to dup env because other middleware might be
    # modifying it and make RequestReplay not able to get the original env.
    if rewrite = @options[:rewrite_env]
      rewrite.call(env.dup)
    else
      env.dup
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
request-replay-0.7.1	lib/request-replay/middleware.rb
request-replay-0.7.0	lib/request-replay/middleware.rb