pgr0ss · February 28, 2010 18:14
diff --git a/request_processor.rb b/request_processor.rb
 class RequestProcessor
  @queue = :requests

  APP = Rack::Builder.new do
    use Rails::Rack::Static
    use Rack::CommonLogger
    run ActionController::Dispatcher.new
  end

  RACK_BASE_REQUEST = {
    "PATH_INFO"=>"/things",
    "QUERY_STRING"=>"",
    "REQUEST_METHOD"=>"GET",
    "SERVER_NAME"=>"localhost",
    "SERVER_PORT"=>"3000",
    "rack.errors" => STDERR,
    "rack.input" => StringIO.new(""),
    "rack.multiprocess"=>true,
    "rack.multithread" => false,
    "rack.run_once" => false,
    "rack.url_scheme" => "http",
    "rack.version"=>[1, 0],
  }

  def self.perform(hash)
    url = hash.delete("url")

    request = RACK_BASE_REQUEST.clone
    request["PATH_INFO"] = url
    response = APP.call(request)

    body = ""
    response.last.each { |part| body << part }

    hash["body"] = URI.escape(body)
    cmd = "redis-cli rpush responses #{hash.to_json.inspect}"
    system cmd
  end
 end
	class RequestProcessor
	@queue = :requests

	APP = Rack::Builder.new do
	use Rails::Rack::Static
	use Rack::CommonLogger
	run ActionController::Dispatcher.new
	end

	RACK_BASE_REQUEST = {
	"PATH_INFO"=>"/things",
	"QUERY_STRING"=>"",
	"REQUEST_METHOD"=>"GET",
	"SERVER_NAME"=>"localhost",
	"SERVER_PORT"=>"3000",
	"rack.errors" => STDERR,
	"rack.input" => StringIO.new(""),
	"rack.multiprocess"=>true,
	"rack.multithread" => false,
	"rack.run_once" => false,
	"rack.url_scheme" => "http",
	"rack.version"=>[1, 0],
	}

	def self.perform(hash)
	url = hash.delete("url")

	request = RACK_BASE_REQUEST.clone
	request["PATH_INFO"] = url
	response = APP.call(request)

	body = ""
	response.last.each { \|part\| body << part }

	hash["body"] = URI.escape(body)
	cmd = "redis-cli rpush responses #{hash.to_json.inspect}"
	system cmd
	end
	end