lib/honeybadger/util/http.rb in honeybadger-5.2.0 vs lib/honeybadger/util/http.rb in honeybadger-5.2.1
- old
+ new
@@ -1,92 +1,92 @@
-require 'forwardable'
-require 'net/http'
-require 'json'
-require 'zlib'
-require 'openssl'
-
-require 'honeybadger/version'
-require 'honeybadger/logging'
-
-module Honeybadger
- module Util
- class HTTP
- extend Forwardable
-
- include Honeybadger::Logging::Helper
-
- HEADERS = {
- 'Content-type'.freeze => 'application/json'.freeze,
- 'Content-Encoding'.freeze => 'deflate'.freeze,
- 'Accept'.freeze => 'text/json, application/json'.freeze,
- 'User-Agent'.freeze => "HB-Ruby #{VERSION}; #{RUBY_VERSION}; #{RUBY_PLATFORM}".freeze
- }.freeze
-
- ERRORS = [Timeout::Error,
- Errno::EINVAL,
- Errno::ECONNRESET,
- Errno::ECONNREFUSED,
- Errno::ENETUNREACH,
- EOFError,
- Net::HTTPBadResponse,
- Net::HTTPHeaderSyntaxError,
- Net::ProtocolError,
- OpenSSL::SSL::SSLError,
- SocketError].freeze
-
- def initialize(config)
- @config = config
- end
-
- def get(endpoint)
- response = http_connection.get(endpoint)
- debug { sprintf("http method=GET path=%s code=%d", endpoint.dump, response.code) }
- response
- end
-
- def post(endpoint, payload, headers = nil)
- response = http_connection.post(endpoint, compress(payload.to_json), http_headers(headers))
- debug { sprintf("http method=POST path=%s code=%d", endpoint.dump, response.code) }
- response
- end
-
- private
-
- attr_reader :config
-
- def http_connection
- setup_http_connection
- end
-
- def http_headers(headers = nil)
- {}.tap do |hash|
- hash.merge!(HEADERS)
- hash.merge!({'X-API-Key' => config[:api_key].to_s})
- hash.merge!(headers) if headers
- end
- end
-
- def setup_http_connection
- http_class = Net::HTTP::Proxy(config[:'connection.proxy_host'], config[:'connection.proxy_port'], config[:'connection.proxy_user'], config[:'connection.proxy_pass'])
- http = http_class.new(config[:'connection.host'], config.connection_port)
-
- http.read_timeout = config[:'connection.http_read_timeout']
- http.open_timeout = config[:'connection.http_open_timeout']
-
- if config[:'connection.secure']
- http.use_ssl = true
-
- http.ca_file = config.ca_bundle_path
- http.verify_mode = OpenSSL::SSL::VERIFY_PEER
- else
- http.use_ssl = false
- end
-
- http
- end
-
- def compress(string, level = Zlib::DEFAULT_COMPRESSION)
- Zlib::Deflate.deflate(string, level)
- end
- end
- end
-end
+require 'forwardable'
+require 'net/http'
+require 'json'
+require 'zlib'
+require 'openssl'
+
+require 'honeybadger/version'
+require 'honeybadger/logging'
+
+module Honeybadger
+ module Util
+ class HTTP
+ extend Forwardable
+
+ include Honeybadger::Logging::Helper
+
+ HEADERS = {
+ 'Content-type'.freeze => 'application/json'.freeze,
+ 'Content-Encoding'.freeze => 'deflate'.freeze,
+ 'Accept'.freeze => 'text/json, application/json'.freeze,
+ 'User-Agent'.freeze => "HB-Ruby #{VERSION}; #{RUBY_VERSION}; #{RUBY_PLATFORM}".freeze
+ }.freeze
+
+ ERRORS = [Timeout::Error,
+ Errno::EINVAL,
+ Errno::ECONNRESET,
+ Errno::ECONNREFUSED,
+ Errno::ENETUNREACH,
+ EOFError,
+ Net::HTTPBadResponse,
+ Net::HTTPHeaderSyntaxError,
+ Net::ProtocolError,
+ OpenSSL::SSL::SSLError,
+ SocketError].freeze
+
+ def initialize(config)
+ @config = config
+ end
+
+ def get(endpoint)
+ response = http_connection.get(endpoint)
+ debug { sprintf("http method=GET path=%s code=%d", endpoint.dump, response.code) }
+ response
+ end
+
+ def post(endpoint, payload, headers = nil)
+ response = http_connection.post(endpoint, compress(payload.to_json), http_headers(headers))
+ debug { sprintf("http method=POST path=%s code=%d", endpoint.dump, response.code) }
+ response
+ end
+
+ private
+
+ attr_reader :config
+
+ def http_connection
+ setup_http_connection
+ end
+
+ def http_headers(headers = nil)
+ {}.tap do |hash|
+ hash.merge!(HEADERS)
+ hash.merge!({'X-API-Key' => config[:api_key].to_s})
+ hash.merge!(headers) if headers
+ end
+ end
+
+ def setup_http_connection
+ http_class = Net::HTTP::Proxy(config[:'connection.proxy_host'], config[:'connection.proxy_port'], config[:'connection.proxy_user'], config[:'connection.proxy_pass'])
+ http = http_class.new(config[:'connection.host'], config.connection_port)
+
+ http.read_timeout = config[:'connection.http_read_timeout']
+ http.open_timeout = config[:'connection.http_open_timeout']
+
+ if config[:'connection.secure']
+ http.use_ssl = true
+
+ http.ca_file = config.ca_bundle_path
+ http.verify_mode = OpenSSL::SSL::VERIFY_PEER
+ else
+ http.use_ssl = false
+ end
+
+ http
+ end
+
+ def compress(string, level = Zlib::DEFAULT_COMPRESSION)
+ Zlib::Deflate.deflate(string, level)
+ end
+ end
+ end
+end