Contents

module AMQParty
  class AMQPartyError < StandardError; end
  class UnsupportedURISchemeError < AMQPartyError; end
  class UnconfiguredError < AMQPartyError; end

  class Request < HTTParty::Request
    def perform(&block)
      unless %w{amqp}.include? uri.scheme.to_s.downcase
        raise UnsupportedURISchemeError, "#{uri.scheme} must be amqp"
      end
      validate
      setup_raw_request
      chunked_body = nil

      path = "#{uri.host}#{uri.path}"
      connection_options = options[:amqp_client_options]

      #connection_options[:user]     = uri.user     if uri.user
      #connection_options[:password] = uri.password if uri.password

      Rack::AMQP::Client.with_client(connection_options) do |client|
        method_name = http_method.name.split(/::/).last.upcase
        body = options[:body] || ""
        body = HTTParty::HashConversions.to_params(options[:body]) if body.is_a?(Hash)
        headers = options[:headers] || {}

        response = client.request(path, {body: body, http_method: method_name, headers: headers, timeout: 5})

        klass = Net::HTTPResponse.send(:response_class,response.response_code.to_s)
        http_response = klass.new("1.1", response.response_code, "Found")
        response.headers.each_pair do |key, value|
          http_response.add_field key, value
        end
        http_response.body = response.payload
        http_response.send(:instance_eval, "def body; @body; end") # TODO GIANT HACK
        self.last_response = http_response
      end

      handle_deflation unless http_method == Net::HTTP::Head
      handle_response(chunked_body, &block)
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
amqparty-0.0.2	lib/amqparty/request.rb