class Excon::Connection

def request(params, &block)
  begin
    params[:path] ||= @connection[:path]
    unless params[:path][0..0] == '/'
      params[:path] = "/#{params[:path]}"
    end
    request = "#{params[:method]} #{params[:path]}?"
    for key, value in (params[:query] || @connection[:query] || {})
      request << "#{key}#{value && "=#{CGI.escape(value.to_s)}"}&"
    end
    request.chop!
    request << " HTTP/1.1\r\n"
    params[:headers] ||= @connection[:headers]
    params[:headers]['Host'] ||= params[:host] || @connection[:host]
    unless params[:headers]['Content-Length']
      params[:headers]['Content-Length'] = (params[:body] && params[:body].length) || 0
    end
    for key, value in params[:headers]
      request << "#{key}: #{value}\r\n"
    end
    request << "\r\n"
    socket.write(request)
    if params[:body] ||= @connection[:body]
      if params[:body].is_a?(String)
        socket.write(params[:body])
      else
        while chunk = params[:body].read(CHUNK_SIZE)
          socket.write(chunk)
        end
      end
    end
    response = Excon::Response.parse(socket, params, &block)
    if response.headers['Connection'] == 'close'
      reset_socket
    end
    response
  rescue => socket_error
    reset_socket
    raise(socket_error)
  end
  if params[:expects] && ![*params[:expects]].include?(response.status)
    reset_socket
    raise(Excon::Errors.status_error(params, response))
  else
    response
  end
rescue => request_error
  if params[:idempotent] &&
      (!request_error.is_a?(Excon::Errors::Error) || response.status != 404)
    retries_remaining ||= 4
    retries_remaining -= 1
    if retries_remaining > 0
      retry
    else
      raise(request_error)
    end
  else
    raise(request_error)
  end
end