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

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

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_failure, #set_deferred_status, #set_deferred_success, #succeed, #timeout

Constructor Details

#initialize(conn, args) ⇒ Request

Returns a new instance of Request.



56
57
58
59
60
61
62
# File 'lib/protocols/httpcli2.rb', line 56

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

Instance Attribute Details

#contentObject (readonly)

Returns the value of attribute content.



53
54
55
# File 'lib/protocols/httpcli2.rb', line 53

def content
  @content
end

#header_linesObject (readonly)

Returns the value of attribute header_lines.



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

def header_lines
  @header_lines
end

#headersObject (readonly)

Returns the value of attribute headers.



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

def headers
  @headers
end

#internal_errorObject (readonly)

Returns the value of attribute internal_error.



54
55
56
# File 'lib/protocols/httpcli2.rb', line 54

def internal_error
  @internal_error
end

#statusObject (readonly)

Returns the value of attribute status.



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

def status
  @status
end

#versionObject (readonly)

Returns the value of attribute version.



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

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.



126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
# File 'lib/protocols/httpcli2.rb', line 126

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



91
92
93
94
95
96
97
98
# File 'lib/protocols/httpcli2.rb', line 91

def receive_chunk_trailer ln
	if ln.length == 0
		@conn.pop_request
		succeed
	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.



146
147
148
149
# File 'lib/protocols/httpcli2.rb', line 146

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.



104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
# File 'lib/protocols/httpcli2.rb', line 104

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



79
80
81
82
83
84
85
86
87
# File 'lib/protocols/httpcli2.rb', line 79

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.



222
223
224
225
226
# File 'lib/protocols/httpcli2.rb', line 222

def receive_sized_text text
	@content = text
	@conn.pop_request
	succeed
end

#receive_text(text) ⇒ Object



214
215
216
# File 'lib/protocols/httpcli2.rb', line 214

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

#send_requestObject



64
65
66
67
68
69
70
71
72
73
74
# File 'lib/protocols/httpcli2.rb', line 64

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