Contents

# frozen_string_literal: true

class EzClient::Client
  def initialize(options = {})
    self.options = options
    self.clients = {}
  end

  def request(verb, url, **options)
    options = { **default_options, **options } # TODO: raise on unknown options

    keep_alive_timeout = options.delete(:keep_alive)
    api_auth = options.delete(:api_auth)

    if keep_alive_timeout
      client = persistent_client_for(url, timeout: keep_alive_timeout)
    else
      client = HTTP::Client.new
    end

    EzClient::Request.new(verb, url, client: client, **options).tap do |request|
      request.api_auth!(*api_auth) if api_auth
    end
  end

  def perform(*args)
    request(*args).perform
  end

  def perform!(*args)
    request(*args).perform!
  end

  private

  attr_accessor :options, :clients

  def persistent_client_for(url, timeout: 600)
    uri = HTTP::URI.parse(url)
    clients[uri.origin] ||= HTTP.persistent(uri.origin, timeout: timeout)
  end

  def default_options
    keys = %i[
      api_auth
      keep_alive
      max_retries
      on_complete
      on_error
      retry_exceptions
      ssl_context
      timeout
    ]

    # RUBY25: Hash#slice
    options.select { |key| keys.include?(key) }
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
ezclient-0.9.1	lib/ezclient/client.rb
ezclient-0.9.0	lib/ezclient/client.rb
ezclient-0.8.0	lib/ezclient/client.rb
ezclient-0.7.0	lib/ezclient/client.rb