Class: EventMachine::AblyHttpRequest::Middleware::OAuth

Inherits:
Object
  • Object
show all
Includes:
HttpEncoding
Defined in:
lib/em-http/middleware/oauth.rb

Constant Summary

Constants included from HttpEncoding

HttpEncoding::FIELD_ENCODING, HttpEncoding::HTTP_REQUEST_HEADER

Instance Method Summary collapse

Methods included from HttpEncoding

#bytesize, #encode_auth, #encode_cookie, #encode_field, #encode_headers, #encode_host, #encode_param, #encode_query, #encode_request, #escape, #form_encode_body, #munge_header_keys, #unescape

Constructor Details

#initialize(opts = {}) ⇒ OAuth

Returns a new instance of OAuth.



10
11
12
13
14
15
 
# File 'lib/em-http/middleware/oauth.rb', line 10

def initialize(opts = {})
  @opts = opts.dup
  # Allow both `oauth` gem and `simple_oauth` gem opts formats
  @opts[:token] ||= @opts.delete(:access_token)
  @opts[:token_secret] ||= @opts.delete(:access_token_secret)
end

Instance Method Details

#request(client, head, body) ⇒ Object 



17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
 
# File 'lib/em-http/middleware/oauth.rb', line 17

def request(client, head, body)
  request = client.req
  uri     = request.uri.join(encode_query(request.uri, request.query))
  params  = {}

  # from https://github.com/oauth/oauth-ruby/blob/master/lib/oauth/request_proxy/em_http_request.rb
  if ["POST", "PUT"].include?(request.method)
    head["content-type"] ||= "application/x-www-form-urlencoded" if body.is_a? Hash
    form_encoded = head["content-type"].to_s.downcase.start_with?("application/x-www-form-urlencoded")

    if form_encoded
      CGI.parse(client.normalize_body(body)).each do |k,v|
        # Since `CGI.parse` always returns values as an array
        params[k] = v.size == 1 ? v.first : v
      end
    end
  end

  head["Authorization"] = SimpleOAuth::Header.new(request.method, uri, params, @opts)

  [head,body]
end