class Request
An incoming HTTP/1 request parsed from the connection.
Definitions
def self.valid_path?(target)
Check whether the given request target is a valid path.
Signature
-
parameter
targetString The request target to validate.
-
returns
Boolean Whether the target is a valid path.
Implementation
def self.valid_path?(target)
if target.start_with?("/")
return true
elsif target == "*"
return true
else
return false
end
end
def self.read(connection)
Read and parse the next request from the connection.
Signature
-
parameter
connectionConnection The HTTP/1 connection to read from.
-
returns
Request | Nil The parsed request, or
nilif the connection is closed.
Implementation
def self.read(connection)
connection.read_request do |authority, method, target, version, headers, body|
if method == ::Protocol::HTTP::Methods::CONNECT
# We put the target into the authority field for CONNECT requests, as per HTTP/2 semantics.
self.new(connection, nil, target, method, nil, version, headers, body)
elsif valid_path?(target)
# This is a valid request.
self.new(connection, nil, authority, method, target, version, headers, body)
elsif match = target.match(URI_PATTERN)
# We map the incoming absolute URI target to the scheme, authority, and path fields of the request.
self.new(connection, match[:scheme], match[:authority], method, match[:path], version, headers, body)
else
# This is an invalid request.
raise ::Protocol::HTTP1::BadRequest.new("Invalid request target: #{target}")
end
end
end
def initialize(connection, scheme, authority, method, path, version, headers, body)
Initialize the request from the parsed components.
Signature
-
parameter
connectionConnection The underlying connection.
-
parameter
schemeString | Nil The request scheme.
-
parameter
authorityString | Nil The request authority.
-
parameter
methodString The HTTP method.
-
parameter
pathString | Nil The request path.
-
parameter
versionString The HTTP version.
-
parameter
headersProtocol::HTTP::Headers The request headers.
-
parameter
bodyProtocol::HTTP::Body::Readable | Nil The request body.
Implementation
def initialize(connection, scheme, authority, method, path, version, headers, body)
@connection = connection
# HTTP/1 requests with an upgrade header (which can contain zero or more values) are extracted into the protocol field of the request, and we expect a response to select one of those protocols with a status code of 101 Switching Protocols.
protocol = headers.delete("upgrade")
super(scheme, authority, method, path, version, headers, body, protocol, self.public_method(:write_interim_response))
end
def connection
Signature
-
returns
Connection The underlying HTTP/1 connection.
Implementation
def connection
@connection
end
def hijack?
Signature
-
returns
Boolean Whether connection hijacking is supported.
Implementation
def hijack?
true
end
def hijack!
Hijack the underlying connection for bidirectional communication.
Implementation
def hijack!
@connection.hijack!
end
def write_interim_response(status, headers = nil)
Write an interim (1xx) response to the client.
Signature
-
parameter
statusInteger The interim HTTP status code.
-
parameter
headersHash | Nil Optional interim response headers.
Implementation
def write_interim_response(status, headers = nil)
@connection.write_interim_response(@version, status, headers)
end