Contents

require "json"
require "net/http/persistent"
require "faraday/http_cache"

module LaunchDarkly
  # @private
  class UnexpectedResponseError < StandardError
    def initialize(status)
      @status = status
    end

    def status
      @status
    end
  end

  # @private
  class Requestor
    def initialize(sdk_key, config)
      @sdk_key = sdk_key
      @config = config
      @client = Faraday.new do |builder|
        builder.use :http_cache, store: @config.cache_store, serializer: Marshal
        
        builder.adapter :net_http_persistent
      end
    end

    def request_flag(key)
      make_request("/sdk/latest-flags/" + key)
    end

    def request_segment(key)
      make_request("/sdk/latest-segments/" + key)
    end

    def request_all_data()
      make_request("/sdk/latest-all")
    end
    
    def make_request(path)
      uri = @config.base_uri + path
      res = @client.get (uri) do |req|
        req.headers["Authorization"] = @sdk_key
        req.headers["User-Agent"] = "RubyClient/" + LaunchDarkly::VERSION
        req.options.timeout = @config.read_timeout
        req.options.open_timeout = @config.connect_timeout
        if @config.proxy
          req.options.proxy = Faraday::ProxyOptions.from @config.proxy
        end
      end

      @config.logger.debug { "[LDClient] Got response from uri: #{uri}\n\tstatus code: #{res.status}\n\theaders: #{res.headers}\n\tbody: #{res.body}" }

      if res.status < 200 || res.status >= 300
        raise UnexpectedResponseError.new(res.status)
      end

      JSON.parse(res.body, symbolize_names: true)
    end

    private :make_request
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
ldclient-rb-5.5.2	lib/ldclient-rb/requestor.rb
ldclient-rb-5.5.1	lib/ldclient-rb/requestor.rb
ldclient-rb-5.5.0	lib/ldclient-rb/requestor.rb