dev

Author: alexander-baz

Gemfile.lock

@@ -1,7 +1,7 @@
 PATH
   remote: .
   specs:
-    ezclient (1.7.1)
+    ezclient (1.7.2)
       http (>= 4)
 
 GEM

lib/ezclient/client.rb

@@ -28,9 +28,12 @@ def request(verb, url, **options)
 
     keep_alive_timeout = options.delete(:keep_alive)
     api_auth = options.delete(:api_auth)
+    ssl_context = options[:ssl_context]
 
     if keep_alive_timeout
-      client = persistent_client_registry.for(url, timeout: keep_alive_timeout)
+      client = persistent_client_registry.for(
+        url, ssl_context: ssl_context, timeout: keep_alive_timeout
+      )
     else
       client = HTTP::Client.new
     end

lib/ezclient/persistent_client_registry.rb

@@ -5,17 +5,31 @@ def initialize
     self.registry = {}
   end
 
-  def for(url, timeout:)
+  def for(url, ssl_context:, timeout:)
     cleanup_registry!
-    uri = HTTP::URI.parse(url)
-    registry[uri.origin] ||= EzClient::PersistentClient.new(uri.origin, timeout)
+
+    origin = get_origin(url)
+    registry[origin] ||= {}
+
+    ssl_bucket = ssl_context ? get_cert_sha256(ssl_context.cert) : nil
+    registry[origin][ssl_bucket] ||= EzClient::PersistentClient.new(origin, timeout)
   end
 
   private
 
   attr_accessor :registry
 
+  def get_cert_sha256(cert)
+    Digest::SHA256.hexdigest(cert.to_der)
+  end
+
+  def get_origin(url)
+    HTTP::URI.parse(url).origin
+  end
+
   def cleanup_registry!
-    registry.delete_if { |_origin, client| client.timed_out? }
+    registry.each do |_origin, ssl_bucket_clients|
+      ssl_bucket_clients.delete_if { |_ssl_bucket, client| client.timed_out? }
+    end
   end
 end

lib/ezclient/version.rb

@@ -1,5 +1,5 @@
 # frozen_string_literal: true
 
 module EzClient
-  VERSION = "1.7.1"
+  VERSION = "1.7.2"
 end