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

Inherits:
Request 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

#protocol

Attributes inherited from Request

#authority, #body, #headers, #method, #path, #scheme, #version

Instance Method Summary collapse

Methods inherited from Request

#peer, #remote_address, #remote_address=

Methods inherited from Request

[], #connect?, #head?, #idempotent?, #to_s

Methods included from Body::Reader

#body?, #close, #each, #finish, #read, #save

Constructor Details

#initialize(protocol, 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(protocol, stream_id)
	super(nil, nil, nil, nil, VERSION, Headers.new)
	
	@input = nil
	@protocol = protocol
	@stream = Stream.new(self, protocol, 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

#hijack? ⇒ Boolean

Returns:

  • (Boolean) 


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

def hijack?
	false
end

#receive_data(stream, data, end_stream) ⇒ Object 



75
76
77
78
79
80
81
82
83
 
# File 'lib/async/http/protocol/http2/request.rb', line 75

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 



43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
 
# File 'lib/async/http/protocol/http2/request.rb', line 43

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
		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:
	@protocol.requests.enqueue self
end

#receive_reset_stream(stream, error_code) ⇒ Object 



85
86
 
# File 'lib/async/http/protocol/http2/request.rb', line 85

def receive_reset_stream(stream, error_code)
end

#send_response(response) ⇒ Object 



96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
 
# File 'lib/async/http/protocol/http2/request.rb', line 96

def send_response(response)
	if response.nil?
		@stream.send_headers(nil, NO_RESPONSE, ::HTTP::Protocol::HTTP2::END_STREAM)
	elsif response.body?
		pseudo_headers = [
			[STATUS, response.status],
		]
		
		if length = response.body.length
			pseudo_headers << [CONTENT_LENGTH, length]
		end
		
		headers = 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, ::HTTP::Protocol::HTTP2::END_STREAM)
	end
end

#stop_connection(error) ⇒ Object 



88
89
 
# File 'lib/async/http/protocol/http2/request.rb', line 88

def stop_connection(error)
end