Class: Async::HTTP::Protocol::HTTP2::Request

Inherits:
Request
  • Object
show all
Defined in:
lib/async/http/protocol/http2/request.rb

Constant Summary collapse

NO_RESPONSE = 
[
	[STATUS, '500'],
	[REASON, "No response generated"]
]

Instance Attribute Summary collapse

Attributes inherited from Request

#connection

Instance Method Summary collapse

Methods inherited from Request

#peer, #remote_address, #remote_address=

Constructor Details

#initialize(connection, stream_id) ⇒ Request

Returns a new instance of Request.



29
30
31
32
33
34
35
 
# File 'lib/async/http/protocol/http2/request.rb', line 29

def initialize(connection, stream_id)
	super(nil, nil, nil, nil, VERSION, ::Protocol::HTTP::Headers.new)
	
	@input = nil
	@connection = connection
	@stream = Stream.new(self, connection, stream_id)
end

Instance Attribute Details

#stream ⇒ Object (readonly)

Returns the value of attribute stream.



37
38
39
 
# File 'lib/async/http/protocol/http2/request.rb', line 37

def stream
  @stream
end

Instance Method Details

#close!(state) ⇒ Object 



54
55
 
# File 'lib/async/http/protocol/http2/request.rb', line 54

def close!(state)
end

#create_promise_stream(headers, stream_id) ⇒ Object 



47
48
49
50
51
52
 
# File 'lib/async/http/protocol/http2/request.rb', line 47

def create_promise_stream(headers, stream_id)
	request = self.class.new(@connection, stream_id)
	request.receive_headers(self, headers, false)
	
	return request.stream
end

#hijack? ⇒ Boolean

Returns:

  • (Boolean) 


39
40
41
 
# File 'lib/async/http/protocol/http2/request.rb', line 39

def hijack?
	false
end

#push(path, headers = nil) ⇒ Stream

Returns the promised stream, on which to send data.

Returns:

  • (Stream) —

    the promised stream, on which to send data.



58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
 
# File 'lib/async/http/protocol/http2/request.rb', line 58

def push(path, headers = nil)
	push_headers = [
		[SCHEME, @scheme],
		[METHOD, ::Protocol::HTTP::Methods::GET],
		[PATH, path],
		[AUTHORITY, @authority]
	]
	
	if headers
		push_headers = Headers::Merged.new(
			push_headers,
			headers
		)
	end
	
	@stream.send_push_promise(push_headers)
end

#push? ⇒ Boolean

Returns:

  • (Boolean) 


43
44
45
 
# File 'lib/async/http/protocol/http2/request.rb', line 43

def push?
	@connection.enable_push?
end

#receive_data(stream, data, end_stream) ⇒ Object 



112
113
114
115
116
117
118
119
120
 
# File 'lib/async/http/protocol/http2/request.rb', line 112

def receive_data(stream, data, end_stream)
	unless data.empty?
		@input.write(data)
	end
	
	if end_stream
		@input.close
	end
end

#receive_headers(stream, headers, end_stream) ⇒ Object 



76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
 
# File 'lib/async/http/protocol/http2/request.rb', line 76

def receive_headers(stream, headers, end_stream)
	headers.each do |key, value|
		if key == SCHEME
			return @stream.send_failure(400, "Request scheme already specified") if @scheme
			
			@scheme = value
		elsif key == AUTHORITY
			return @stream.send_failure(400, "Request authority already specified") if @authority
			
			@authority = value
		elsif key == METHOD
			return @stream.send_failure(400, "Request method already specified") if @method
			
			@method = value
		elsif key == PATH
			return @stream.send_failure(400, "Request path already specified") if @path
			
			@path = value
		elsif key == PROTOCOL
			return @stream.send_failure(400, "Request protocol already specified") if @protocol
			
			@protocol = value
		else
			@headers[key] = value
		end
	end
	
	# We only construct the input/body if data is coming.
	unless end_stream
		@body = @input = Body::Writable.new
	end
	
	# We are ready for processing:
	@connection.requests.enqueue self
end

#receive_reset_stream(stream, error_code) ⇒ Object 



122
123
 
# File 'lib/async/http/protocol/http2/request.rb', line 122

def receive_reset_stream(stream, error_code)
end

#send_response(response) ⇒ Object 



133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
 
# File 'lib/async/http/protocol/http2/request.rb', line 133

def send_response(response)
	if response.nil?
		@stream.send_headers(nil, NO_RESPONSE, ::Protocol::HTTP2::END_STREAM)
	elsif response.body?
		pseudo_headers = [
			[STATUS, response.status],
		]
		
		if length = response.body.length
			pseudo_headers << [CONTENT_LENGTH, length]
		end
		
		if protocol = response.protocol
			pseudo_headers << [PROTOCOL, protocol]
		end
		
		headers = ::Protocol::HTTP::Headers::Merged.new(
			pseudo_headers,
			response.headers
		)
		
		@stream.send_headers(nil, headers)
		@stream.send_body(response.body)
	else
		headers = Headers::Merged.new([
			[STATUS, response.status],
		], response.headers)
		
		@stream.send_headers(nil, headers, ::Protocol::HTTP2::END_STREAM)
	end
end

#stop_connection(error) ⇒ Object 



125
126
 
# File 'lib/async/http/protocol/http2/request.rb', line 125

def stop_connection(error)
end