Class: Net::HTTPResponse

# File 'lib/net/http/response.rb', line 24

def exception_type   # :nodoc: internal use only
  self::EXCEPTION_TYPE
end

# File 'lib/net/http/response.rb', line 28

def read_new(sock)   #:nodoc: internal use only
  httpv, code, msg = read_status_line(sock)
  res = response_class(code).new(httpv, code, msg)
  each_response_header(sock) do |k,v|
    res.add_field k, v
  end
  res
end

# File 'lib/net/http/response.rb', line 39

def read_status_line(sock)
  str = sock.readline
  m = /\AHTTP(?:\/(\d\.\d))?\s(\d\d\d)(?:\s(.*))?\z/in.match(str) or
    raise Net::HTTPBadResponse, "wrong status line: #{str.dump}"
  m.captures
end

# File 'lib/net/http/response.rb', line 46

def response_class(code)
  CODE_TO_OBJ[code] or
  CODE_CLASS_TO_OBJ[code[0,1]] or
  Net::HTTPUnknownResponse
end

# File 'lib/net/http/response.rb', line 234

def body=(value)
  @body = value
end

# File 'lib/net/http/response.rb', line 93

attr_reader :code

# File 'lib/net/http/response.rb', line 105

attr_accessor :decode_content

# File 'lib/net/http/response.rb', line 238

alias entity body   #:nodoc: obsolete

# File 'lib/net/http/response.rb', line 88

attr_reader :http_version

# File 'lib/net/http/response.rb', line 96

attr_reader :message

# File 'lib/net/http/response.rb', line 97

alias msg message   # :nodoc: obsolete

# File 'lib/net/http/response.rb', line 101

attr_reader :uri

# File 'lib/net/http/response.rb', line 134

def uri= uri # :nodoc:
  @uri = uri.dup if uri
end

# File 'lib/net/http/response.rb', line 119

def error!   #:nodoc:
  message = @code
  message += ' ' + @message.dump if @message
  raise error_type().new(message, self)
end

# File 'lib/net/http/response.rb', line 125

def error_type   #:nodoc:
  self.class::EXCEPTION_TYPE
end

# File 'lib/net/http/response.rb', line 147

def header   #:nodoc:
  warn "Net::HTTPResponse#header is obsolete", uplevel: 1 if $VERBOSE
  self
end

# File 'lib/net/http/response.rb', line 251

def inflater # :nodoc:
  return yield @socket unless Net::HTTP::HAVE_ZLIB
  return yield @socket unless @decode_content
  return yield @socket if self['content-range']

  v = self['content-encoding']
  case v&.downcase
  when 'deflate', 'gzip', 'x-gzip' then
    self.delete 'content-encoding'

    inflate_body_io = Inflater.new(@socket)

    begin
      yield inflate_body_io
      success = true
    ensure
      begin
        inflate_body_io.finish
      rescue => err
        # Ignore #finish's error if there is an exception from yield
        raise err if success
      end
    end
  when 'none', 'identity' then
    self.delete 'content-encoding'

    yield @socket
  else
    yield @socket
  end
end

# File 'lib/net/http/response.rb', line 107

def inspect
  "#<#{self.class} #{@code} #{@message} readbody=#{@read}>"
end

# File 'lib/net/http/response.rb', line 337

def procdest(dest, block)
  raise ArgumentError, 'both arg and block given for HTTP method' if
    dest and block
  if block
    Net::ReadAdapter.new(block)
  else
    dest || ''
  end
end

# File 'lib/net/http/response.rb', line 196

def read_body(dest = nil, &block)
  if @read
    raise IOError, "#{self.class}\#read_body called twice" if dest or block
    return @body
  end
  to = procdest(dest, block)
  stream_check
  if @body_exist
    read_body_0 to
    @body = to
  else
    @body = nil
  end
  @read = true

  @body
end

# File 'lib/net/http/response.rb', line 283

def read_body_0(dest)
  inflater do |inflate_body_io|
    if chunked?
      read_chunked dest, inflate_body_io
      return
    end

    @socket = inflate_body_io

    clen = content_length()
    if clen
      @socket.read clen, dest, true   # ignore EOF
      return
    end
    clen = range_length()
    if clen
      @socket.read clen, dest
      return
    end
    @socket.read_all dest
  end
end

# File 'lib/net/http/response.rb', line 313

def read_chunked(dest, chunk_data_io) # :nodoc:
  total = 0
  while true
    line = @socket.readline
    hexlen = line.slice(/[0-9a-fA-F]+/) or
        raise Net::HTTPBadResponse, "wrong chunk size line: #{line}"
    len = hexlen.hex
    break if len == 0
    begin
      chunk_data_io.read len, dest
    ensure
      total += len
      @socket.read 2   # \r\n
    end
  end
  until @socket.readline.empty?
    # none
  end
end

# File 'lib/net/http/response.rb', line 152

def read_header   #:nodoc:
  warn "Net::HTTPResponse#read_header is obsolete", uplevel: 1 if $VERBOSE
  self
end

# File 'lib/net/http/response.rb', line 161

def reading_body(sock, reqmethodallowbody)  #:nodoc: internal use only
  @socket = sock
  @body_exist = reqmethodallowbody && self.class.body_permitted?
  begin
    yield
    self.body   # ensure to read body
  ensure
    @socket = nil
  end
end

# File 'lib/net/http/response.rb', line 142

def response   #:nodoc:
  warn "Net::HTTPResponse#response is obsolete", uplevel: 1 if $VERBOSE
  self
end

# File 'lib/net/http/response.rb', line 333

def stream_check
  raise IOError, 'attempt to read body out of block' if @socket.closed?
end

# File 'lib/net/http/response.rb', line 130

def value
  error! unless self.kind_of?(Net::HTTPSuccess)
end