Class: EventMachine::Protocols::HttpClient2::Request

Inherits:
Object
  • Object
show all
Includes:
Deferrable
Defined in:
lib/em/protocols/httpclient2.rb

Overview

:nodoc:

Constant Summary collapse

HttpResponseRE =

– TODO, inefficient how we’re handling this. Part of it is done so as to make sure we don’t have problems in detecting chunked-encoding, content-length, etc.

/\AHTTP\/(1.[01]) ([\d]{3})/i
ClenRE = 
/\AContent-length:\s*(\d+)/i
ChunkedRE = 
/\ATransfer-encoding:\s*chunked/i
ColonRE = 
/\:\s*/

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from Deferrable

#callback, #cancel_timeout, #errback, #fail, future, #set_deferred_status, #succeed, #timeout

Constructor Details

#initialize(conn, args) ⇒ Request

Returns a new instance of Request.



54
55
56
57
58
59
60
 
# File 'lib/em/protocols/httpclient2.rb', line 54

def initialize conn, args
  @conn = conn
  @args = args
  @header_lines = []
  @headers = {}
  @blanks = 0
end

Instance Attribute Details

#content ⇒ Object (readonly)

Returns the value of attribute content.



51
52
53
 
# File 'lib/em/protocols/httpclient2.rb', line 51

def content
  @content
end

#header_lines ⇒ Object (readonly)

Returns the value of attribute header_lines.



49
50
51
 
# File 'lib/em/protocols/httpclient2.rb', line 49

def header_lines
  @header_lines
end

#headers ⇒ Object (readonly)

Returns the value of attribute headers.



50
51
52
 
# File 'lib/em/protocols/httpclient2.rb', line 50

def headers
  @headers
end

#internal_error ⇒ Object (readonly)

Returns the value of attribute internal_error.



52
53
54
 
# File 'lib/em/protocols/httpclient2.rb', line 52

def internal_error
  @internal_error
end

#status ⇒ Object (readonly)

Returns the value of attribute status.



48
49
50
 
# File 'lib/em/protocols/httpclient2.rb', line 48

def status
  @status
end

#version ⇒ Object (readonly)

Returns the value of attribute version.



47
48
49
 
# File 'lib/em/protocols/httpclient2.rb', line 47

def version
  @version
end

Instance Method Details

#receive_chunk_header(ln) ⇒ Object

– Cf RFC 2616 pgh 3.6.1 for the format of HTTP chunks.



124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
 
# File 'lib/em/protocols/httpclient2.rb', line 124

def receive_chunk_header ln
  if ln.length > 0
    chunksize = ln.to_i(16)
    if chunksize > 0
      @conn.set_text_mode(ln.to_i(16))
    else
      @content = @content ? @content.join : ''
      @chunk_trailer = true
    end
  else
    # We correctly come here after each chunk gets read.
    # p "Got A BLANK chunk line"
  end

end

#receive_chunk_trailer(ln) ⇒ Object

–



89
90
91
92
93
94
95
96
 
# File 'lib/em/protocols/httpclient2.rb', line 89

def receive_chunk_trailer ln
  if ln.length == 0
    @conn.pop_request
    succeed(self)
  else
    p "Received chunk trailer line"
  end
end

#receive_chunked_text(text) ⇒ Object

– We get a single chunk. Append it to the incoming content and switch back to line mode.



144
145
146
147
 
# File 'lib/em/protocols/httpclient2.rb', line 144

def receive_chunked_text text
  # p "RECEIVED #{text.length} CHUNK"
  (@content ||= []) << text
end

#receive_header_line(ln) ⇒ Object

– Allow up to ten blank lines before we get a real response line. Allow no more than 100 lines in the header.



102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
 
# File 'lib/em/protocols/httpclient2.rb', line 102

def receive_header_line ln
  if ln.length == 0
    if @header_lines.length > 0
      process_header
    else
      @blanks += 1
      if @blanks > 10
        @conn.close_connection
      end
    end
  else
    @header_lines << ln
    if @header_lines.length > 100
      @internal_error = :bad_header
      @conn.close_connection
    end
  end
end

#receive_line(ln) ⇒ Object

–



77
78
79
80
81
82
83
84
85
 
# File 'lib/em/protocols/httpclient2.rb', line 77

def receive_line ln
  if @chunk_trailer
    receive_chunk_trailer(ln)
  elsif @chunking
    receive_chunk_header(ln)
  else
    receive_header_line(ln)
  end
end

#receive_sized_text(text) ⇒ Object

– At the present time, we only handle contents that have a length specified by the content-length header.



219
220
221
222
223
 
# File 'lib/em/protocols/httpclient2.rb', line 219

def receive_sized_text text
  @content = text
  @conn.pop_request
  succeed(self)
end

#receive_text(text) ⇒ Object 



211
212
213
 
# File 'lib/em/protocols/httpclient2.rb', line 211

def receive_text text
  @chunking ? receive_chunked_text(text) : receive_sized_text(text)
end

#send_request ⇒ Object 



62
63
64
65
66
67
68
69
70
71
72
 
# File 'lib/em/protocols/httpclient2.rb', line 62

def send_request
  az = @args[:authorization] and az = "Authorization: #{az}\r\n"

  r = [
    "#{@args[:verb]} #{@args[:uri]} HTTP/#{@args[:version] || "1.1"}\r\n",
    "Host: #{@args[:host_header] || "_"}\r\n",
    az || "",
      "\r\n"
  ]
  @conn.send_data r.join
end