Common class to make HTTP requests using Faraday. Parallel POST requests with Faraday and Typhoeus Hydra.

Http.rb

class Http
  class << self
    def send_request(url, options = {}, verb = :get)
      headers = options[:headers]
      headers = headers.present? ? default_headers.merge(headers) : default_headers
      body = options[:body].presence
      body = body.to_json if headers['Content-Type'] == 'application/json'
      query = options[:query].presence

      payload = verb == :get ? query : body

      response = Faraday.public_send(verb, url, payload, headers)

      parsed_response(response.body)
    rescue StandardError => e
      raise 'Invalid request'
    end

    # Only for :post request for now
    def send_parallel_request(url, options = {}, verb = :post)
      custom_headers = options[:headers]
      headers = custom_headers.present? ? default_headers.merge(custom_headers) : default_headers

      manager = Typhoeus::Hydra.new(max_concurrency: 10)
      connection = Faraday.new(url: url, parallel_manager: manager) do |faraday|
        faraday.adapter :typhoeus
      end

      responses = []
      connection.in_parallel do
        options[:body].each do |payload|
          responses << Faraday.public_send(verb, url, payload.to_json, headers)
        end
      end

      parsed_response(successful_requests)
    end

    def default_headers
      {
        'Content-Type' => 'application/json',
        'Accept' => '*/*'
      }
    end

    def parsed_response(response)
      response = response.map { |res| JSON.parse(res.body).deep_symbolize_keys! } if response.is_a?(Array)
      response = JSON.parse(response).deep_symbolize_keys! if response.is_a?(String)

      response
    end
  end
end