Module: PMP::Connection

Included in:
CollectionDocument, Credential
Defined in:
lib/pmp/connection.rb

Constant Summary collapse

ALLOWED_CONNECTION_OPTIONS = 
[
  :headers,
  :url,
  :params,
  :request,
  :adapter,
  :ssl,
  :oauth_token,
  :token_type,
  :basic_auth,
  :user,
  :password,
  :debug
].freeze

Instance Method Summary collapse

Instance Method Details

#connection(options = {}) ⇒ Object 



24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
 
# File 'lib/pmp/connection.rb', line 24

def connection(options={})
  opts = process_options(options)
  Faraday::Connection.new(opts) do |faraday|

    if opts[:basic_auth] && opts[:user] && opts[:password]
      faraday.request :basic_auth, opts[:user], opts[:password]
    elsif opts[:oauth_token]
      faraday.request :authorization, opts[:token_type], opts[:oauth_token]
    end

    faraday.request :multipart
    faraday.request :url_encoded

    faraday.response :mashify
    faraday.response :json
    faraday.response :raise_error
    faraday.response :logger if opts[:debug]

    faraday.adapter opts[:adapter]
  end
end

#process_options(opts = {}) ⇒ Object 



46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
 
# File 'lib/pmp/connection.rb', line 46

def process_options(opts={})
  headers = opts.delete(:headers) || {}
  options = {
    :headers => {
      # generic http headers
      'User-Agent'   => opts[:user_agent],
      'Accept'       => "application/vnd.pmp.collection.doc+json",
      'Content-Type' => "application/vnd.pmp.collection.doc+json"
    },
    :ssl => {:verify => false},
    :url => opts[:endpoint]
  }.merge(opts)
  options[:headers] = options[:headers].merge(headers)

  # clean out any that don't belong
  options.select{|k,v| ALLOWED_CONNECTION_OPTIONS.include?(k.to_sym)}
end