class Async::HTTP::Internet

def call(method, url, headers = nil, body = nil)
	endpoint = Endpoint.parse(url)
	key = host_key(endpoint)
	
	client = @clients.fetch(key) do
		@clients[key] = self.client_for(endpoint)
	end
	
	body = Body::Buffered.wrap(body)
	headers = ::Protocol::HTTP::Headers[headers]
	
	request = ::Protocol::HTTP::Request.new(client.scheme, endpoint.authority, method, endpoint.path, nil, headers, body)
	
	return client.call(request)
end

def client_for(endpoint)
	Client.new(endpoint, **@options)
end

def close
	# The order of operations here is to avoid a race condition between iterating over clients (#close may yield) and creating new clients.
	clients = @clients.values
	@clients.clear
	
	clients.each(&:close)
end

def host_key(endpoint)
	url = endpoint.url.dup
	
	url.path = ""
	url.fragment = nil
	url.query = nil
	
	return url
end

def initialize(**options)
	@clients = {}
	@options = options
end