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].freeze

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.



97
98
99
 
# File 'lib/cc/service/http.rb', line 97

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 



101
102
103
104
105
106
107
108
109
 
# File 'lib/cc/service/http.rb', line 101

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 



72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
 
# File 'lib/cc/service/http.rb', line 72

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
    adapters = Array(options.delete(:adapter) || config[:adapter])

    Faraday.new(options) do |b|
      b.use(CC::Service::ResponseCheck)
      b.request(:url_encoded)
      b.adapter(*adapters)
    end
  end
end

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



54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
 
# File 'lib/cc/service/http.rb', line 54

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

  CC::Resolv.with_fixed_dns do
    CC::Service::SafeWebhook.ensure_safe!(url)

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

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



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

def raw_get(url = nil, params = nil, headers = nil)
  http_method(:get, url, nil, headers) do |req|
    req.params.update(params) if params
    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 



22
23
24
 
# File 'lib/cc/service/http.rb', line 22

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 



26
27
28
29
30
 
# File 'lib/cc/service/http.rb', line 26

def service_post(url, body = nil, headers = nil, &block)
  block ||= ->(*_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 



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

def service_post_with_redirects(url, body = nil, headers = nil, &block)
  block ||= ->(*_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