Sha256: a716dbc1fa0706486844d51e70ae5fb6e7bccb1122e37ea8b339d4841707646d

Contents?: true

Size: 1.42 KB

Versions: 1

Compression:

Stored size: 1.42 KB

Contents

module JsonApiClient
  class Connection

    attr_reader :faraday

    def initialize(options = {})
      site = options.fetch(:site)
      connection_options = options.slice(:proxy, :ssl, :request, :headers, :params)
      adapter_options = Array(options.fetch(:adapter, Faraday.default_adapter))
      status_middleware_options = {}
      status_middleware_options[:custom_handlers] = options[:status_handlers] if options[:status_handlers].present?
      @faraday = Faraday.new(site, connection_options) do |builder|
        builder.request :json
        builder.use Middleware::JsonRequest
        builder.use Middleware::Status, status_middleware_options
        builder.response :json
        builder.use ::Faraday::Gzip::Middleware
        builder.adapter(*adapter_options)
      end
      yield(self) if block_given?
    end

    # insert middleware before ParseJson - middleware executed in reverse order -
    #   inserted middleware will run after json parsed
    def use(middleware, *args, &block)
      return if faraday.builder.locked?
      faraday.builder.insert_before(::Faraday::Response::Json, middleware, *args, &block)
    end

    def delete(middleware)
      faraday.builder.delete(middleware)
    end

    def run(request_method, path, params: nil, headers: {}, body: nil)
      faraday.run_request(request_method, path, body, headers) do |request|
        request.params.update(params) if params
      end
    end

  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version Path
json_api_client-1.23.0 lib/json_api_client/connection.rb