Class: Async::HTTP::Protocol::HTTP11
- Inherits:
-
IO::Protocol::Line
- Object
- IO::Protocol::Line
- Async::HTTP::Protocol::HTTP11
- Defined in:
- lib/async/http/protocol/http11.rb
Overview
Implements basic HTTP/1.1 request/response.
Direct Known Subclasses
Constant Summary collapse
- CRLF =
"\r\n".freeze
- CONNECTION =
'connection'.freeze
- HOST =
'host'.freeze
- CLOSE =
'close'.freeze
- VERSION =
"HTTP/1.1".freeze
Instance Attribute Summary collapse
-
#count ⇒ Object
readonly
Returns the value of attribute count.
Instance Method Summary collapse
- #call(request) ⇒ Object
-
#initialize(stream) ⇒ HTTP11
constructor
A new instance of HTTP11.
-
#multiplex ⇒ Object
Only one simultaneous connection at a time.
- #persistent?(headers) ⇒ Boolean
- #read_request ⇒ Object
- #read_response ⇒ Object
-
#receive_requests(task: Task.current) ⇒ Object
Server loop.
- #reusable? ⇒ Boolean
- #version ⇒ Object
- #write_request(authority, method, path, version, headers) ⇒ Object
- #write_response(version, status, headers, body) ⇒ Object
Constructor Details
Instance Attribute Details
#count ⇒ Object (readonly)
Returns the value of attribute count.
51 52 53 |
# File 'lib/async/http/protocol/http11.rb', line 51 def count @count end |
Instance Method Details
#call(request) ⇒ Object
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/http11.rb', line 97 def call(request) request.version ||= self.version Async.logger.debug(self) {"#{request.method} #{request.path} #{request.headers.inspect}"} # We carefully interpret https://tools.ietf.org/html/rfc7230#section-6.3.1 to implement this correctly. begin write_request(request., request.method, request.path, request.version, request.headers) rescue # If we fail to fully write the request and body, we can retry this request. raise RequestFailed.new end # Once we start writing the body, we can't recover if the request fails. That's because the body might be generated dynamically, streaming, etc. write_body(request.body) return Response.new(*read_response) rescue # This will ensure that #reusable? returns false. @stream.close raise end |
#multiplex ⇒ Object
Only one simultaneous connection at a time.
54 55 56 |
# File 'lib/async/http/protocol/http11.rb', line 54 def multiplex 1 end |
#persistent?(headers) ⇒ Boolean
71 72 73 |
# File 'lib/async/http/protocol/http11.rb', line 71 def persistent?(headers) headers.delete(CONNECTION) != CLOSE end |
#read_request ⇒ Object
141 142 143 144 145 146 147 148 149 |
# File 'lib/async/http/protocol/http11.rb', line 141 def read_request method, path, version = read_line.split(/\s+/, 3) headers = read_headers body = read_body(headers) @count += 1 return headers.delete(HOST), method, path, version, headers, body end |
#read_response ⇒ Object
129 130 131 132 133 134 135 136 137 138 139 |
# File 'lib/async/http/protocol/http11.rb', line 129 def read_response version, status, reason = read_line.split(/\s+/, 3) headers = read_headers body = read_body(headers) @count += 1 @persistent = persistent?(headers) return version, Integer(status), reason, headers, body end |
#receive_requests(task: Task.current) ⇒ Object
Server loop.
76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 |
# File 'lib/async/http/protocol/http11.rb', line 76 def receive_requests(task: Task.current) while @persistent request = Request.new(*read_request) unless persistent?(request.headers) @persistent = false end response = yield request response.version ||= request.version write_response(response.version, response.status, response.headers, response.body) request.finish # This ensures we yield at least once every iteration of the loop and allow other fibers to execute. task.yield end end |
#reusable? ⇒ Boolean
58 59 60 |
# File 'lib/async/http/protocol/http11.rb', line 58 def reusable? @persistent && !@stream.closed? end |
#version ⇒ Object
67 68 69 |
# File 'lib/async/http/protocol/http11.rb', line 67 def version VERSION end |
#write_request(authority, method, path, version, headers) ⇒ Object
121 122 123 124 125 126 127 |
# File 'lib/async/http/protocol/http11.rb', line 121 def write_request(, method, path, version, headers) @stream.write("#{method} #{path} #{version}\r\n") @stream.write("Host: #{}\r\n") write_headers(headers) @stream.flush end |
#write_response(version, status, headers, body) ⇒ Object
151 152 153 154 155 156 157 |
# File 'lib/async/http/protocol/http11.rb', line 151 def write_response(version, status, headers, body) @stream.write("#{version} #{status}\r\n") write_headers(headers) write_body(body) @stream.flush end |