class Faraday::Adapter::Typhoeus

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

def call(env)
  super
  # TODO: support streaming requests
  env[:body] = env[:body].read if env[:body].respond_to? :read
  req = ::Typhoeus::Request.new env[:url].to_s,
    :method  => env[:method],
    :body    => env[:body],
    :headers => env[:request_headers],
    :disable_ssl_peer_verification => (env[:ssl] && !env[:ssl].fetch(:verify, true))
  if ssl = env[:ssl]
    req.ssl_cert   = ssl[:client_cert_file] if ssl[:client_cert_file]
    req.ssl_key    = ssl[:client_key_file]  if ssl[:client_key_file]
    req.ssl_cacert = ssl[:ca_file]          if ssl[:ca_file]
    req.ssl_capath = ssl[:ca_path]          if ssl[:ca_path]
  end
  env_req = env[:request]
  
  if proxy = env_req[:proxy]
    req.proxy = "#{proxy[:uri].host}:#{proxy[:uri].port}"
    
    if proxy[:username] && proxy[:password]
      req.proxy_username = proxy[:username]
      req.proxy_password = proxy[:password]
    end
  end
  
  req.timeout = req.connect_timeout = (env_req[:timeout] * 1000) if env_req[:timeout]
  req.connect_timeout = (env_req[:open_timeout] * 1000)          if env_req[:open_timeout]
  is_parallel = !!env[:parallel_manager]
  req.on_complete do |resp|
    save_response(env, resp.code, resp.body) do |response_headers|
      response_headers.parse resp.headers
    end
    # in async mode, :response is initialized at this point
    env[:response].finish(env) if is_parallel
  end
  hydra = env[:parallel_manager] || self.class.setup_parallel_manager
  hydra.queue req
  hydra.run unless is_parallel
  @app.call env
rescue Errno::ECONNREFUSED
  raise Error::ConnectionFailed, $!
end