Module: CC::Service::HTTP

Extended by:
ActiveSupport::Concern
Included in:
CC::Service
Defined in:
lib/cc/service/http.rb

Defined Under Namespace

Modules: ClassMethods

Constant Summary collapse

REDIRECT_CODES = 
[302, 307]

Instance Method Summary collapse

Instance Method Details

#ca_file ⇒ Object

Gets the path to the SSL Certificate Authority certs. These were taken from: curl.haxx.se/ca/cacert.pem

Returns a String path.



89
90
91
 
# File 'lib/cc/service/http.rb', line 89

def ca_file
  @ca_file ||= ENV.fetch("CODECLIMATE_CA_FILE", File.expand_path('../../../../config/cacert.pem', __FILE__))
end

#formatted_post_response(response, url, body) ⇒ Object 



93
94
95
96
97
98
99
100
101
 
# File 'lib/cc/service/http.rb', line 93

def formatted_post_response(response, url, body)
  {
    ok: response.success?,
    params: body.as_json,
    endpoint_url: url,
    status: response.status,
    message: "Success",
  }
end

#http(options = {}) ⇒ Object 



65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
 
# File 'lib/cc/service/http.rb', line 65

def http(options = {})
  @http ||= begin
    config = self.class.default_http_options
    config.each do |key, sub_options|
      next if key == :adapter
      sub_hash = options[key] ||= {}
      sub_options.each do |sub_key, sub_value|
        sub_hash[sub_key] ||= sub_value
      end
    end
    options[:ssl][:ca_file] ||= ca_file

    Faraday.new(options) do |b|
      b.use(CC::Service::ResponseCheck)
      b.request(:url_encoded)
      b.adapter(*Array(options[:adapter] || config[:adapter]))
    end
  end
end

#http_method(method, url = nil, body = nil, headers = nil) ⇒ Object 



54
55
56
57
58
59
60
61
62
63
 
# File 'lib/cc/service/http.rb', line 54

def http_method(method, url = nil, body = nil, headers = nil)
  block = Proc.new if block_given?

  http.send(method) do |req|
    req.url(url)                if url
    req.headers.update(headers) if headers
    req.body = body             if body
    block.call req if block
  end
end

#raw_get(url = nil, params = nil, headers = nil) ⇒ Object 



40
41
42
43
44
45
46
47
 
# File 'lib/cc/service/http.rb', line 40

def raw_get(url = nil, params = nil, headers = nil)
  http.get do |req|
    req.url(url)                if url
    req.params.update(params)   if params
    req.headers.update(headers) if headers
    yield req if block_given?
  end
end

#raw_post(url = nil, body = nil, headers = nil) ⇒ Object 



49
50
51
52
 
# File 'lib/cc/service/http.rb', line 49

def raw_post(url = nil, body = nil, headers = nil)
  block = Proc.new if block_given?
  http_method :post, url, body, headers, &block
end

#service_get(url = nil, body = nil, headers = nil, &block) ⇒ Object 



20
21
22
 
# File 'lib/cc/service/http.rb', line 20

def service_get(url = nil, body = nil, headers = nil, &block)
  raw_get(url, body, headers, &block)
end

#service_post(url, body = nil, headers = nil, &block) ⇒ Object 



24
25
26
27
28
 
# File 'lib/cc/service/http.rb', line 24

def service_post(url, body = nil, headers = nil, &block)
  block ||= lambda{|*_args| Hash.new }
  response = raw_post(url, body, headers)
  formatted_post_response(response, url, body).merge(block.call(response))
end

#service_post_with_redirects(url, body = nil, headers = nil, &block) ⇒ Object 



30
31
32
33
34
35
36
37
38
 
# File 'lib/cc/service/http.rb', line 30

def service_post_with_redirects(url, body = nil, headers = nil, &block)
  block ||= lambda{|*_args| Hash.new }
  response = raw_post(url, body, headers)
  if REDIRECT_CODES.include?(response.status)
    response = raw_post(response.headers["location"], body, headers)
  end

  formatted_post_response(response, url, body).merge(block.call(response))
end