Sha256: 090ce128ea988f8256396f524831f7a7b204396bf972161ec61757b8b633b61a

Contents?: true

Size: 933 Bytes

Versions: 4

Compression:

Stored size: 933 Bytes

Contents

require 'active_support'

module LHC
  module BasicMethods
    extend ActiveSupport::Concern

    module ClassMethods
      def request(options)
        if options.is_a? Array
          parallel_requests(options)
        else
          LHC::Request.new(options).response
        end
      end

      [:get, :post, :put, :delete].each do |http_method|
        define_method(http_method) do |url, options = {}|
          request(options.merge(
                    url: url,
                    method: http_method
          ))
        end
      end

      private

      def parallel_requests(options)
        hydra = Typhoeus::Hydra.hydra
        requests = []
        options.each do |option|
          request = LHC::Request.new(option, false)
          requests << request
          hydra.queue request.raw unless request.response.present?
        end
        hydra.run
        requests.map(&:response)
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version Path
lhc-5.1.1 lib/lhc/concerns/lhc/basic_methods.rb
lhc-5.1.0 lib/lhc/concerns/lhc/basic_methods.rb
lhc-5.0.3 lib/lhc/concerns/lhc/basic_methods.rb
lhc-5.0.2 lib/lhc/concerns/lhc/basic_methods.rb