Contents

module Faraday
  module Adapter
    class Typhoeus < Middleware
      self.supports_parallel_requests = true

      def self.setup_parallel_manager(options = {})
        options.empty? ? ::Typhoeus::Hydra.hydra : ::Typhoeus::Hydra.new(options)
      end

      begin
        require 'typhoeus'
      rescue LoadError => e
        self.load_error = e
      end

      def call(env)
        process_body_for_request(env)

        hydra = env[:parallel_manager] || self.class.setup_parallel_manager
        req   = ::Typhoeus::Request.new env[:url].to_s, 
          :method  => env[:method],
          :body    => env[:body],
          :headers => env[:request_headers]

        req.on_complete do |resp|
          env.update \
            :status           => resp.code,
            :response_headers => parse_response_headers(resp.headers),
            :body             => resp.body
          env[:response].finish(env)
        end

        hydra.queue req

        if !env[:parallel_manager]
          hydra.run
        end

        @app.call env
      rescue Errno::ECONNREFUSED
        raise Error::ConnectionFailed, "connection refused"
      end

      def in_parallel(options = {})
        @hydra = ::Typhoeus::Hydra.new(options)
        yield
        @hydra.run
        @hydra = nil
      end

      def parse_response_headers(header_string)
        return {} unless header_string && !header_string.empty?
        Hash[*header_string.split(/\r\n/).
          tap  { |a|      a.shift           }. # drop the HTTP status line
          map! { |h|      h.split(/:\s+/,2) }. # split key and value
          map! { |(k, v)| [k.downcase, v]   }.flatten!]
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
faraday-0.2.1	lib/faraday/adapter/typhoeus.rb
faraday-0.2.0	lib/faraday/adapter/typhoeus.rb