allow using custom endpoints for Async::HTTP::Internet.

Author: binarycode

lib/async/http/endpoint.rb

@@ -229,5 +229,15 @@ def tcp_endpoint
 				::IO::Endpoint.tcp(self.hostname, port, **tcp_options)
 			end
 		end
+		
+		# Coerce the given object into an endpoint.
+		# @parameter url [String | Endpoint] The URL or endpoint to convert.
+		def self.Endpoint(url, **options)
+			if url.is_a?(Endpoint)
+				return url
+			else
+				Endpoint.parse(url, **options)
+			end
+		end
 	end
 end

lib/async/http/internet.rb

@@ -39,7 +39,7 @@ def client_for(endpoint)
 			# @parameter headers [Hash | Protocol::HTTP::Headers] The headers to send with the request.
 			# @parameter body [String | Protocol::HTTP::Body] The body to send with the request.
 			def call(method, url, headers = nil, body = nil)
-				endpoint = Endpoint.parse(url)
+				endpoint = HTTP.Endpoint(url)
 				client = self.client_for(endpoint)
 
 				body = Body::Buffered.wrap(body)
@@ -59,8 +59,9 @@ def close
 			end
 
 			::Protocol::HTTP::Methods.each do |name, verb|
-				define_method(verb.downcase) do |url, headers = nil, body = nil|
-					self.call(verb, url.to_str, headers, body)
+				define_method(verb.downcase) do |url_or_endpoint, headers = nil, body = nil|
+					url_or_endpoint = url_or_endpoint.to_str unless url_or_endpoint.is_a?(Endpoint)
+					self.call(verb, url_or_endpoint, headers, body)
 				end
 			end
 

test/async/http/internet.rb

@@ -33,4 +33,18 @@
 		expect(response).to be(:success?)
 		expect{JSON.parse(response.read)}.not.to raise_exception
 	end
+	
+	it 'can fetch remote website when given custom endpoint instead of url' do
+		ssl_context = OpenSSL::SSL::SSLContext.new
+		ssl_context.set_params(verify_mode: OpenSSL::SSL::VERIFY_NONE)
+		
+		# example of site with invalid certificate that will fail to be fetched without custom SSL options
+		endpoint = Async::HTTP::Endpoint.parse('https://expired.badssl.com', ssl_context: ssl_context)
+		
+		response = internet.get(endpoint, headers)
+		
+		expect(response).to be(:success?)
+	ensure
+		response&.close
+	end
 end