From 96166fc7b3cc53dedb09771f700a3bab210215b7 Mon Sep 17 00:00:00 2001
From: Luc DUZAN <lduzan@conduktor.io>
Date: Thu, 15 Feb 2024 16:39:49 +0100
Subject: [PATCH] Allow lib user to change ssl factory

---
 .../connect/apiclient/rest/HttpsContextBuilder.java  | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/src/main/java/org/sourcelab/kafka/connect/apiclient/rest/HttpsContextBuilder.java b/src/main/java/org/sourcelab/kafka/connect/apiclient/rest/HttpsContextBuilder.java
index 5e0c6d0..fe8c831 100644
--- a/src/main/java/org/sourcelab/kafka/connect/apiclient/rest/HttpsContextBuilder.java
+++ b/src/main/java/org/sourcelab/kafka/connect/apiclient/rest/HttpsContextBuilder.java
@@ -46,7 +46,7 @@
 /**
  * Utility for properly configuring the SSL Context based on client configuration settings.
  */
-class HttpsContextBuilder {
+public class HttpsContextBuilder {
     private static final Logger logger = LoggerFactory.getLogger(HttpsContextBuilder.class);
 
     /**
@@ -89,7 +89,7 @@ public LayeredConnectionSocketFactory createSslSocketFactory() {
      * Get HostnameVerifier instance based on client configuration.
      * @return HostnameVerifier instance.
      */
-    HostnameVerifier getHostnameVerifier() {
+    protected HostnameVerifier getHostnameVerifier() {
         // If we're configured to ignore invalid certificates
         if (configuration.getIgnoreInvalidSslCertificates()) {
             // Use the Noop verifier.
@@ -103,7 +103,7 @@ HostnameVerifier getHostnameVerifier() {
      * Get properly configured SSLContext instance based on client configuration.
      * @return SSLContext instance.
      */
-    SSLContext getSslContext() {
+    protected SSLContext getSslContext() {
         try {
             // Create default SSLContext
             final SSLContext sslcontext = SSLContexts.createDefault();
@@ -121,7 +121,7 @@ SSLContext getSslContext() {
      * Based on client configuration, construct KeyManager instances to use.
      * @return Array of 0 or more KeyManagers.
      */
-    KeyManager[] getKeyManagers() {
+    protected KeyManager[] getKeyManagers() {
         // If not configured to use a KeyStore
         if (configuration.getKeyStoreFile() == null) {
             // Return null array.
@@ -160,7 +160,7 @@ KeyManager[] getKeyManagers() {
      * Based on Client Configuration, construct TrustManager instances to use.
      * @return Array of 0 or more TrustManager instances.
      */
-    TrustManager[] getTrustManagers() {
+    protected TrustManager[] getTrustManagers() {
         try {
             final TrustManagerFactory trustManagerFactory = TrustManagerFactory.getInstance(TrustManagerFactory.getDefaultAlgorithm());
 
@@ -205,7 +205,7 @@ TrustManager[] getTrustManagers() {
      * Get allowed SSL Protocols.
      * @return allowed SslProtocols.
      */
-    private String[] getSslProtocols() {
+    protected String[] getSslProtocols() {
         return sslProtocols;
     }
 }