Contents

require 'faraday'
# Default adapter needs to be required to be registered
require 'faraday/net_http_persistent' unless Faraday::VERSION < '1'
require 'chalk_ruby/error'

module ChalkRuby
  module Http
    class HttpRequesterChalk
      include Helpers

      # @param requester [ChalkRuby::Http::HttpRequester] requester used for sending requests.
      #
      def initialize(requester:)
        @http_requester = requester
      end

      def send_request(method:, host:, path:, timeout:, connect_timeout:, headers:, body:)
        response = @http_requester.send_request(
          host: host,
          method: method,
          path: path,
          body: body && to_json(body: body),
          headers: headers,
          timeout: timeout,
          connect_timeout: connect_timeout
        )

        if response.has_timed_out
          raise ChalkHttpError.new(code: Defaults::ERROR_TIMED_OUT, message: 'Request timed out')
        end

        if response.network_failure
          raise ChalkHttpError.new(code: 502, message: 'Network failure')
        end

        unless success?(http_response_code: response.status)
          decoded_error = json_to_hash(json: response.error, symbolize_keys: true)
          raise ChalkHttpError.new(
            code: get_option(hash: decoded_error, key: 'status'),
            message: get_option(hash: decoded_error, key: 'message')
          )
        end
        json_to_hash(json: response.body, symbolize_keys: true)
      end

      private

      def success?(http_response_code:)
        !http_response_code.nil? && (http_response_code.to_i / 100).floor == 2
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
chalk_ruby-0.1.3	lib/chalk_ruby/http/http_requester_chalk.rb
chalk_ruby-0.1.2	lib/chalk_ruby/http/http_requester_chalk.rb
chalk_ruby-0.1.1	lib/chalk_ruby/http/http_requester_chalk.rb