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?, #inspect, #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 



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

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