Class: WpApiClient::Connection

Inherits:
Object
  • Object
show all
Defined in:
lib/wp_api_client/connection.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(configuration) ⇒ Connection

Returns a new instance of Connection.



13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
 
# File 'lib/wp_api_client/connection.rb', line 13

def initialize(configuration)
  @configuration = configuration
  @queue = []
  @conn = Faraday.new(url: configuration.endpoint) do |faraday|

    if configuration.oauth_credentials
      faraday.use FaradayMiddleware::OAuth, configuration.oauth_credentials
    end

    if configuration.basic_auth
      faraday.basic_auth(configuration.basic_auth[:username], configuration.basic_auth[:password])
    end

    if configuration.debug
      faraday.response :logger
      faraday.use :instrumentation
    end

    if configuration.cache
      faraday.use :http_cache, store: configuration.cache, shared_cache: false
    end

    faraday.use Faraday::Response::RaiseError
    faraday.response :json, :content_type => /\bjson$/
    faraday.adapter  :typhoeus
  end
end

Instance Attribute Details

#concurrent ⇒ Object (readonly)

Returns the value of attribute concurrent.



11
12
13
 
# File 'lib/wp_api_client/connection.rb', line 11

def concurrent
  @concurrent
end

#headers ⇒ Object

Returns the value of attribute headers.



10
11
12
 
# File 'lib/wp_api_client/connection.rb', line 10

def headers
  @headers
end

Instance Method Details

#get(url, params = {}) ⇒ Object

translate requests into wp-api urls



42
43
44
 
# File 'lib/wp_api_client/connection.rb', line 42

def get(url, params = {})
  @conn.get url, parse_params(params)
end

#get_concurrently(requests) ⇒ Object

requests come in as url/params pairs



47
48
49
50
51
52
53
54
55
 
# File 'lib/wp_api_client/connection.rb', line 47

def get_concurrently(requests)
  responses = []
  @conn.in_parallel do
    requests.map do |r|
      responses << get(r[0], r[1])
    end
  end
  responses
end