mirror of
https://github.com/HoneyryderChuck/httpx.git
synced 2025-10-06 00:02:08 -04:00
035eda1f95
server not being processed While introducing yet another test to catch frame processing errors, in this case with the SETTINGS_TIMEOUT error, another loop was found. It was caused by two reasons: * connection was signaling it was "closing" on such an error, which is not really true (server already closed the stream, so no need to close it again); it should be marked as closed instead. * write buffer was still full (with the handshake in this case), so the connection was still trying to write;
119 lines
4.3 KiB
Ruby
119 lines
4.3 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
require_relative "support/http_helpers"
|
|
|
|
class HTTPSTest < Minitest::Test
|
|
include HTTPHelpers
|
|
include Requests
|
|
include Get
|
|
include Head
|
|
include WithBody
|
|
include Headers
|
|
include ResponseBody
|
|
include IO
|
|
include Errors
|
|
include Resolvers if ENV.key?("HTTPX_RESOLVER_URI")
|
|
# TODO: uncomment as soon as nghttpx supports altsvc for HTTP/2
|
|
# include AltSvc if ENV.key?("HTTPBIN_ALTSVC_HOST")
|
|
|
|
include Plugins::Proxy unless ENV.key?("HTTPX_NO_PROXY")
|
|
include Plugins::Authentication
|
|
include Plugins::FollowRedirects
|
|
include Plugins::Cookies
|
|
include Plugins::Compression
|
|
include Plugins::PushPromise if OpenSSL::SSL::SSLContext.instance_methods.include?(:alpn_protocols)
|
|
include Plugins::Retries
|
|
include Plugins::Multipart
|
|
include Plugins::Expect
|
|
include Plugins::RateLimiter
|
|
include Plugins::Persistent unless RUBY_ENGINE == "jruby" || RUBY_VERSION < "2.3"
|
|
include Plugins::Stream
|
|
|
|
def test_connection_coalescing
|
|
coalesced_origin = "https://#{ENV["HTTPBIN_COALESCING_HOST"]}"
|
|
HTTPX.wrap do |http|
|
|
response1 = http.get(origin)
|
|
verify_status(response1, 200)
|
|
response2 = http.get(coalesced_origin)
|
|
verify_status(response2, 200)
|
|
# introspection time
|
|
pool = http.__send__(:pool)
|
|
connections = pool.instance_variable_get(:@connections)
|
|
assert connections.any? { |conn|
|
|
conn.instance_variable_get(:@origins) == [origin, coalesced_origin]
|
|
}, "connections didn't coalesce (expected connection with both origins)"
|
|
end
|
|
end if ENV.key?("HTTPBIN_COALESCING_HOST")
|
|
|
|
def test_verbose_log
|
|
log = StringIO.new
|
|
uri = build_uri("/get")
|
|
response = HTTPX.get(uri, debug: log, debug_level: 2)
|
|
verify_status(response, 200)
|
|
log_output = log.string
|
|
# assert tls output
|
|
assert log_output.match(%r{SSL connection using TLSv\d+\.\d+ / \w+})
|
|
assert log_output.match(/ALPN, server accepted to use h2/) unless RUBY_ENGINE == "jruby" || RUBY_VERSION < "2.3"
|
|
assert log_output.match(/Server certificate:/)
|
|
assert log_output.match(/ subject: .+/)
|
|
assert log_output.match(/ start date: .+ UTC/)
|
|
assert log_output.match(/ expire date: .+ UTC/)
|
|
assert log_output.match(/ issuer: .+/)
|
|
assert log_output.match(/ SSL certificate verify ok./)
|
|
|
|
return if RUBY_ENGINE == "jruby" || RUBY_VERSION < "2.3"
|
|
|
|
# assert request headers
|
|
assert log_output.match(/HEADER: :scheme: https/)
|
|
assert log_output.match(/HEADER: :method: GET/)
|
|
assert log_output.match(/HEADER: :path: .+/)
|
|
assert log_output.match(/HEADER: :authority: .+/)
|
|
assert log_output.match(%r{HEADER: accept: */*})
|
|
# assert response headers
|
|
assert log_output.match(/HEADER: :status: 200/)
|
|
assert log_output.match(/HEADER: content-type: \w+/)
|
|
assert log_output.match(/HEADER: content-length: \d+/)
|
|
end
|
|
|
|
unless RUBY_ENGINE == "jruby" || RUBY_VERSION < "2.3"
|
|
# HTTP/2-specific tests
|
|
|
|
def test_http2_max_streams
|
|
uri = build_uri("/get")
|
|
HTTPX.plugin(SessionWithSingleStream).plugin(SessionWithPool).wrap do |http|
|
|
http.get(uri, uri)
|
|
connection_count = http.pool.connection_count
|
|
assert connection_count == 2, "expected to have 2 connections, instead have #{connection_count}"
|
|
assert http.connection_exausted, "expected 1 connnection to have exhausted"
|
|
end
|
|
end
|
|
|
|
def test_http2_uncoalesce_on_misdirected
|
|
uri = build_uri("/status/421")
|
|
HTTPX.plugin(SessionWithPool).wrap do |http|
|
|
response = http.get(uri)
|
|
verify_status(response, 421)
|
|
connection_count = http.pool.connection_count
|
|
assert connection_count == 2, "expected to have 2 connections, instead have #{connection_count}"
|
|
assert response.version == "1.1", "request should have been retried with HTTP/1.1"
|
|
end
|
|
end
|
|
|
|
def test_http2_settings_timeout
|
|
uri = build_uri("/get")
|
|
HTTPX.plugin(SessionWithPool).plugin(SessionWithFrameDelay).wrap do |http|
|
|
response = http.get(uri)
|
|
assert response.is_a?(HTTPX::ErrorResponse), "expected to fail for settings timeout"
|
|
assert response.status =~ /settings_timeout/,
|
|
"connection should have terminated due to HTTP/2 settings timeout"
|
|
end
|
|
end
|
|
end
|
|
|
|
private
|
|
|
|
def origin(orig = httpbin)
|
|
"https://#{orig}"
|
|
end
|
|
end
|