Class: Net::HTTPGenericRequest

# File 'lib/net/http/generic_request.rb', line 91

def body=(str)
  @body = str
  @body_stream = nil
  @body_data = nil
  str
end

# File 'lib/net/http/generic_request.rb', line 84

def body_exist?
  warn "Net::HTTPRequest#body_exist? is obsolete; use response_body_permitted?" if $VERBOSE
  response_body_permitted?
end

# File 'lib/net/http/generic_request.rb', line 98

attr_reader :body_stream

# File 'lib/net/http/generic_request.rb', line 100

def body_stream=(input)
  @body = nil
  @body_stream = input
  @body_data = nil
  input
end

# File 'lib/net/http/generic_request.rb', line 60

attr_reader :decode_content

# File 'lib/net/http/generic_request.rb', line 53

attr_reader :method

# File 'lib/net/http/generic_request.rb', line 54

attr_reader :path

# File 'lib/net/http/generic_request.rb', line 76

def request_body_permitted?
  @request_has_body
end

# File 'lib/net/http/generic_request.rb', line 80

def response_body_permitted?
  @response_has_body
end

# File 'lib/net/http/generic_request.rb', line 55

attr_reader :uri

# File 'lib/net/http/generic_request.rb', line 292

def flush_buffer(out, buf, chunked_p)
  return unless buf
  out << "%x\r\n"%buf.bytesize if chunked_p
  out << buf
  out << "\r\n" if chunked_p
  buf.clear
end

# File 'lib/net/http/generic_request.rb', line 62

def inspect
  "\#<#{self.class} #{@method}>"
end

# File 'lib/net/http/generic_request.rb', line 287

def quote_string(str, charset)
  str = str.encode(charset, fallback:->(c){'&#%d;'%c.encode("UTF-8").ord}) if charset
  str.gsub(/[\\"]/, '\\\\\&')
end

# File 'lib/net/http/generic_request.rb', line 182

def send_request_with_body(sock, ver, path, body)
  self.content_length = body.bytesize
  delete 'Transfer-Encoding'
  supply_default_content_type
  write_header sock, ver, path
  wait_for_continue sock, ver if sock.continue_timeout
  sock.write body
end

# File 'lib/net/http/generic_request.rb', line 210

def send_request_with_body_data(sock, ver, path, params)
  if /\Amultipart\/form-data\z/i !~ self.content_type
    self.content_type = 'application/x-www-form-urlencoded'
    return send_request_with_body(sock, ver, path, URI.encode_www_form(params))
  end

  opt = @form_option.dup
  require 'securerandom' unless defined?(SecureRandom)
  opt[:boundary] ||= SecureRandom.urlsafe_base64(40)
  self.set_content_type(self.content_type, boundary: opt[:boundary])
  if chunked?
    write_header sock, ver, path
    encode_multipart_form_data(sock, params, opt)
  else
    require 'tempfile'
    file = Tempfile.new('multipart')
    file.binmode
    encode_multipart_form_data(file, params, opt)
    file.rewind
    self.content_length = file.size
    write_header sock, ver, path
    IO.copy_stream(file, sock)
    file.close(true)
  end
end

# File 'lib/net/http/generic_request.rb', line 191

def send_request_with_body_stream(sock, ver, path, f)
  unless content_length() or chunked?
    raise ArgumentError,
        "Content-Length not given and Transfer-Encoding is not `chunked'"
  end
  supply_default_content_type
  write_header sock, ver, path
  wait_for_continue sock, ver if sock.continue_timeout
  if chunked?
    chunker = Chunker.new(sock)
    IO.copy_stream(f, chunker)
    chunker.finish
  else
    # copy_stream can sendfile() to sock.io unless we use SSL.
    # If sock.io is an SSLSocket, copy_stream will hit SSL_write()
    IO.copy_stream(f, sock.io)
  end
end

# File 'lib/net/http/generic_request.rb', line 300

def supply_default_content_type
  return if content_type()
  warn 'net/http: warning: Content-Type did not set; using application/x-www-form-urlencoded' if $VERBOSE
  set_content_type 'application/x-www-form-urlencoded'
end

# File 'lib/net/http/generic_request.rb', line 310

def wait_for_continue(sock, ver)
  if ver >= '1.1' and @header['expect'] and
      @header['expect'].include?('100-continue')
    if sock.io.to_io.wait_readable(sock.continue_timeout)
      res = Net::HTTPResponse.read_new(sock)
      unless res.kind_of?(Net::HTTPContinue)
        res.decode_content = @decode_content
        throw :response, res
      end
    end
  end
end

# File 'lib/net/http/generic_request.rb', line 323

def write_header(sock, ver, path)
  reqline = "#{@method} #{path} HTTP/#{ver}"
  if /[\r\n]/ =~ reqline
    raise ArgumentError, "A Request-Line must not contain CR or LF"
  end
  buf = ""
  buf << reqline << "\r\n"
  each_capitalized do |k,v|
    buf << "#{k}: #{v}\r\n"
  end
  buf << "\r\n"
  sock.write buf
end